This source file includes following definitions.
- ompi_request_construct
- ompi_request_destruct
- ompi_request_null_free
- ompi_request_null_cancel
- ompi_request_empty_free
- ompi_request_persistent_noop_free
- ompi_request_init
- ompi_request_finalize
- ompi_request_persistent_noop_create
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 #include "ompi_config.h"
29
30 #include "ompi/communicator/communicator.h"
31 #include "opal/class/opal_object.h"
32 #include "ompi/request/request.h"
33 #include "ompi/request/request_default.h"
34 #include "ompi/constants.h"
35
36 opal_pointer_array_t ompi_request_f_to_c_table = {{0}};
37 ompi_predefined_request_t ompi_request_null = {{{{{0}}}}};
38 ompi_predefined_request_t *ompi_request_null_addr = &ompi_request_null;
39 ompi_request_t ompi_request_empty = {{{{0}}}};
40 ompi_status_public_t ompi_status_empty = {0};
41 ompi_request_fns_t ompi_request_functions = {
42 ompi_request_default_test,
43 ompi_request_default_test_any,
44 ompi_request_default_test_all,
45 ompi_request_default_test_some,
46 ompi_request_default_wait,
47 ompi_request_default_wait_any,
48 ompi_request_default_wait_all,
49 ompi_request_default_wait_some
50 };
51
52 static void ompi_request_construct(ompi_request_t* req)
53 {
54
55
56 req->req_state = OMPI_REQUEST_INVALID;
57 req->req_complete = false;
58 req->req_persistent = false;
59 req->req_start = NULL;
60 req->req_free = NULL;
61 req->req_cancel = NULL;
62 req->req_complete_cb = NULL;
63 req->req_complete_cb_data = NULL;
64 req->req_f_to_c_index = MPI_UNDEFINED;
65 req->req_mpi_object.comm = (struct ompi_communicator_t*) NULL;
66 }
67
68 static void ompi_request_destruct(ompi_request_t* req)
69 {
70 assert( MPI_UNDEFINED == req->req_f_to_c_index );
71 assert( OMPI_REQUEST_INVALID == req->req_state );
72 }
73
74 static int ompi_request_null_free(ompi_request_t** request)
75 {
76 return OMPI_SUCCESS;
77 }
78
79 static int ompi_request_null_cancel(ompi_request_t* request, int flag)
80 {
81 return OMPI_SUCCESS;
82 }
83
84 static int ompi_request_empty_free(ompi_request_t** request)
85 {
86 *request = &ompi_request_null.request;
87 return OMPI_SUCCESS;
88 }
89
90 static int ompi_request_persistent_noop_free(ompi_request_t** request)
91 {
92 OMPI_REQUEST_FINI(*request);
93 (*request)->req_state = OMPI_REQUEST_INVALID;
94 OBJ_RELEASE(*request);
95 *request = &ompi_request_null.request;
96 return OMPI_SUCCESS;
97 }
98
99
100 OBJ_CLASS_INSTANCE(
101 ompi_request_t,
102 opal_free_list_item_t,
103 ompi_request_construct,
104 ompi_request_destruct);
105
106
107 int ompi_request_init(void)
108 {
109
110 OBJ_CONSTRUCT(&ompi_request_null, ompi_request_t);
111 OBJ_CONSTRUCT(&ompi_request_f_to_c_table, opal_pointer_array_t);
112 if( OPAL_SUCCESS != opal_pointer_array_init(&ompi_request_f_to_c_table,
113 0, OMPI_FORTRAN_HANDLE_MAX, 32) ) {
114 return OMPI_ERROR;
115 }
116 ompi_request_null.request.req_type = OMPI_REQUEST_NULL;
117 ompi_request_null.request.req_status.MPI_SOURCE = MPI_ANY_SOURCE;
118 ompi_request_null.request.req_status.MPI_TAG = MPI_ANY_TAG;
119 ompi_request_null.request.req_status.MPI_ERROR = MPI_SUCCESS;
120 ompi_request_null.request.req_status._ucount = 0;
121 ompi_request_null.request.req_status._cancelled = 0;
122
123 ompi_request_null.request.req_complete = REQUEST_COMPLETED;
124 ompi_request_null.request.req_state = OMPI_REQUEST_INACTIVE;
125 ompi_request_null.request.req_persistent = false;
126 ompi_request_null.request.req_f_to_c_index =
127 opal_pointer_array_add(&ompi_request_f_to_c_table, &ompi_request_null);
128 ompi_request_null.request.req_start = NULL;
129 ompi_request_null.request.req_free = ompi_request_null_free;
130 ompi_request_null.request.req_cancel = ompi_request_null_cancel;
131 ompi_request_null.request.req_mpi_object.comm = &ompi_mpi_comm_world.comm;
132
133 if (0 != ompi_request_null.request.req_f_to_c_index) {
134 return OMPI_ERR_REQUEST;
135 }
136
137
138
139
140
141
142
143
144
145
146
147
148 OBJ_CONSTRUCT(&ompi_request_empty, ompi_request_t);
149 ompi_request_empty.req_type = OMPI_REQUEST_NULL;
150 ompi_request_empty.req_status.MPI_SOURCE = MPI_PROC_NULL;
151 ompi_request_empty.req_status.MPI_TAG = MPI_ANY_TAG;
152 ompi_request_empty.req_status.MPI_ERROR = MPI_SUCCESS;
153 ompi_request_empty.req_status._ucount = 0;
154 ompi_request_empty.req_status._cancelled = 0;
155
156 ompi_request_empty.req_complete = REQUEST_COMPLETED;
157 ompi_request_empty.req_state = OMPI_REQUEST_ACTIVE;
158 ompi_request_empty.req_persistent = false;
159 ompi_request_empty.req_f_to_c_index =
160 opal_pointer_array_add(&ompi_request_f_to_c_table, &ompi_request_empty);
161 ompi_request_empty.req_start = NULL;
162 ompi_request_empty.req_free = ompi_request_empty_free;
163 ompi_request_empty.req_cancel = ompi_request_null_cancel;
164 ompi_request_empty.req_mpi_object.comm = &ompi_mpi_comm_world.comm;
165
166 if (1 != ompi_request_empty.req_f_to_c_index) {
167 return OMPI_ERR_REQUEST;
168 }
169
170 ompi_status_empty.MPI_SOURCE = MPI_ANY_SOURCE;
171 ompi_status_empty.MPI_TAG = MPI_ANY_TAG;
172 ompi_status_empty.MPI_ERROR = MPI_SUCCESS;
173 ompi_status_empty._ucount = 0;
174 ompi_status_empty._cancelled = 0;
175
176 return OMPI_SUCCESS;
177 }
178
179
180 int ompi_request_finalize(void)
181 {
182 OMPI_REQUEST_FINI( &ompi_request_null.request );
183 OBJ_DESTRUCT( &ompi_request_null.request );
184 OMPI_REQUEST_FINI( &ompi_request_empty );
185 OBJ_DESTRUCT( &ompi_request_empty );
186 OBJ_DESTRUCT( &ompi_request_f_to_c_table );
187 return OMPI_SUCCESS;
188 }
189
190
191 int ompi_request_persistent_noop_create(ompi_request_t** request)
192 {
193 ompi_request_t *req;
194
195 req = OBJ_NEW(ompi_request_t);
196 if (NULL == req) {
197 return OMPI_ERR_OUT_OF_RESOURCE;
198 }
199
200
201
202 req->req_type = OMPI_REQUEST_NOOP;
203 req->req_status = ompi_request_empty.req_status;
204 req->req_complete = REQUEST_COMPLETED;
205 req->req_state = OMPI_REQUEST_INACTIVE;
206 req->req_persistent = true;
207 req->req_free = ompi_request_persistent_noop_free;
208
209 *request = req;
210 return OMPI_SUCCESS;
211 }