1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
/*
* Copyright 1999-2014 University of Chicago
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* @file post_accept.c
* @brief globus_net_manager_context_post_accept()
*/
#include "globus_net_manager_context.h"
/**
* @brief Call Context Post Accept
* @ingroup globus_net_manager_context
* @details
* Call the chain of post_accept() functions in a context with the given
* task_id, transport, contact information, and attributes. If any manager in
* the context returns an error, the subsequent managers will not be called.
* The attributes are chained through all the calls, with any changed values
* returned from a manager passed to subsequent managers in the chain.
*
* @param [in] context
* The context to call functions in.
* @param [in] task_id
* The task_id associated with this network operation.
* @param [in] transport
* The transport driver associated with this network operation.
* @param [in] local_contact
* The string representation of the local address of the
* socket.
* @param [in] remote_contact
* The string representation of the remote address of the
* socket.
* @param [in] attr_array
* The set of attributes to pass to the managers.
* @param [out] attr_array_out
* The resulting set of attributes from the managers. This will be set
* to NULL if no manager modifies the attributes.
*
* @return
* On success, this function returns GLOBUS_SUCCESS. If any manager
* returns an error, the post_accept calls stop and the error is returned
* to the caller.
*/
globus_result_t
globus_net_manager_context_post_accept(
globus_net_manager_context_t context,
const char *task_id,
const char *transport,
const char *local_contact,
const char *remote_contact,
const globus_net_manager_attr_t *attr_array,
globus_net_manager_attr_t **attr_array_out)
{
globus_i_net_manager_context_t * ctx = context;
globus_list_t * list;
globus_result_t result = GLOBUS_SUCCESS;
globus_net_manager_attr_t * tmp_attr_array = NULL;
globus_i_net_manager_context_entry_t * ent;
if(!ctx || !task_id || !transport || !attr_array || !attr_array_out ||
!local_contact || !remote_contact)
{
result = GlobusNetManagerErrorParameter("No parameter may be NULL.");
goto error_bad_args;
}
for(list = ctx->managers;
!globus_list_empty(list) && result == GLOBUS_SUCCESS;
list = globus_list_rest(list))
{
ent = globus_list_first(list);
if(ent->manager->post_accept)
{
globus_net_manager_attr_t * ret_attr_array = NULL;
result = ent->manager->post_accept(
ent->manager,
ent->attrs,
task_id,
transport,
local_contact,
remote_contact,
tmp_attr_array ? tmp_attr_array : attr_array,
&ret_attr_array);
if(result != GLOBUS_SUCCESS)
{
result = GlobusNetManagerErrorManager(
result, ent->manager->name, "post_accept");
}
if(ret_attr_array != NULL)
{
globus_net_manager_attr_array_delete(tmp_attr_array);
tmp_attr_array = ret_attr_array;
}
}
}
*attr_array_out = tmp_attr_array;
return result;
error_bad_args:
return result;
}
/* globus_net_manager_context_post_accept() */
|
