This source file includes following definitions.
- ompi_crcp_base_none_open
- ompi_crcp_base_none_close
- ompi_crcp_base_none_query
- ompi_crcp_base_module_init
- ompi_crcp_base_module_finalize
- ompi_crcp_base_none_quiesce_start
- ompi_crcp_base_none_quiesce_end
- ompi_crcp_base_none_pml_enable
- ompi_crcp_base_none_pml_add_comm
- ompi_crcp_base_none_pml_del_comm
- ompi_crcp_base_none_pml_add_procs
- ompi_crcp_base_none_pml_del_procs
- ompi_crcp_base_none_pml_progress
- ompi_crcp_base_none_pml_iprobe
- ompi_crcp_base_none_pml_probe
- ompi_crcp_base_none_pml_isend_init
- ompi_crcp_base_none_pml_isend
- ompi_crcp_base_none_pml_send
- ompi_crcp_base_none_pml_irecv_init
- ompi_crcp_base_none_pml_irecv
- ompi_crcp_base_none_pml_recv
- ompi_crcp_base_none_pml_dump
- ompi_crcp_base_none_pml_start
- ompi_crcp_base_none_pml_ft_event
- ompi_crcp_base_none_request_complete
- ompi_crcp_base_none_btl_add_procs
- ompi_crcp_base_none_btl_del_procs
- ompi_crcp_base_none_btl_register
- ompi_crcp_base_none_btl_finalize
- ompi_crcp_base_none_btl_alloc
- ompi_crcp_base_none_btl_free
- ompi_crcp_base_none_btl_prepare_src
- ompi_crcp_base_none_btl_prepare_dst
- ompi_crcp_base_none_btl_send
- ompi_crcp_base_none_btl_put
- ompi_crcp_base_none_btl_get
- ompi_crcp_base_none_btl_dump
- ompi_crcp_base_none_btl_ft_event
- ompi_crcp_base_quiesce_start
- ompi_crcp_base_quiesce_end
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 #include "ompi_config.h"
21
22 #ifdef HAVE_SYS_TYPES_H
23 #include <sys/types.h>
24 #endif
25 #ifdef HAVE_UNISTD_H
26 #include <unistd.h>
27 #endif
28 #include <time.h>
29 #include <ctype.h>
30
31 #include "opal/class/opal_bitmap.h"
32 #include "ompi/mca/mca.h"
33 #include "opal/mca/base/base.h"
34 #include "opal/mca/base/base.h"
35 #include "opal/mca/crs/crs.h"
36 #include "opal/mca/crs/base/base.h"
37
38 #include "ompi/communicator/communicator.h"
39 #include "ompi/proc/proc.h"
40 #include "ompi/mca/crcp/crcp.h"
41 #include "ompi/mca/crcp/base/base.h"
42 #include "ompi/mca/bml/base/base.h"
43 #include "ompi/info/info.h"
44 #include "ompi/mca/pml/pml.h"
45 #include "ompi/mca/pml/base/base.h"
46 #include "ompi/mca/pml/base/pml_base_request.h"
47
48
49
50
51
52
53
54
55 OBJ_CLASS_INSTANCE(ompi_crcp_base_pml_state_t,
56 opal_free_list_item_t,
57 NULL,
58 NULL
59 );
60
61 OBJ_CLASS_INSTANCE(ompi_crcp_base_btl_state_t,
62 opal_free_list_item_t,
63 NULL,
64 NULL
65 );
66
67
68
69
70 int ompi_crcp_base_none_open(void)
71 {
72 return OMPI_SUCCESS;
73 }
74
75 int ompi_crcp_base_none_close(void)
76 {
77 return OMPI_SUCCESS;
78 }
79
80 int ompi_crcp_base_none_query(mca_base_module_t **module, int *priority)
81 {
82 *module = NULL;
83 *priority = 0;
84
85 return OPAL_SUCCESS;
86 }
87
88 int ompi_crcp_base_module_init(void)
89 {
90 return OMPI_SUCCESS;
91 }
92
93 int ompi_crcp_base_module_finalize(void)
94 {
95 return OMPI_SUCCESS;
96 }
97
98
99
100
101 int ompi_crcp_base_none_quiesce_start(MPI_Info *info)
102 {
103 return OMPI_SUCCESS;
104 }
105
106 int ompi_crcp_base_none_quiesce_end(MPI_Info *info)
107 {
108 return OMPI_SUCCESS;
109 }
110
111
112
113
114 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_enable( bool enable,
115 ompi_crcp_base_pml_state_t* pml_state )
116 {
117 pml_state->error_code = OMPI_SUCCESS;
118 return pml_state;
119 }
120
121 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_add_comm( struct ompi_communicator_t* comm,
122 ompi_crcp_base_pml_state_t* pml_state )
123 {
124 pml_state->error_code = OMPI_SUCCESS;
125 return pml_state;
126 }
127
128 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_del_comm( struct ompi_communicator_t* comm,
129 ompi_crcp_base_pml_state_t* pml_state )
130 {
131 pml_state->error_code = OMPI_SUCCESS;
132 return pml_state;
133 }
134
135 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_add_procs( struct ompi_proc_t **procs,
136 size_t nprocs,
137 ompi_crcp_base_pml_state_t* pml_state )
138 {
139 pml_state->error_code = OMPI_SUCCESS;
140 return pml_state;
141 }
142
143 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_del_procs( struct ompi_proc_t **procs,
144 size_t nprocs,
145 ompi_crcp_base_pml_state_t* pml_state )
146 {
147 pml_state->error_code = OMPI_SUCCESS;
148 return pml_state;
149 }
150
151 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_progress(ompi_crcp_base_pml_state_t* pml_state)
152 {
153 pml_state->error_code = OMPI_SUCCESS;
154 return pml_state;
155 }
156
157 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_iprobe(int dst, int tag,
158 struct ompi_communicator_t* comm,
159 int *matched, ompi_status_public_t* status,
160 ompi_crcp_base_pml_state_t* pml_state )
161 {
162 pml_state->error_code = OMPI_SUCCESS;
163 return pml_state;
164 }
165
166 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_probe( int dst, int tag,
167 struct ompi_communicator_t* comm,
168 ompi_status_public_t* status,
169 ompi_crcp_base_pml_state_t* pml_state )
170 {
171 pml_state->error_code = OMPI_SUCCESS;
172 return pml_state;
173 }
174
175 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_isend_init( void *buf, size_t count,
176 ompi_datatype_t *datatype,
177 int dst, int tag,
178 mca_pml_base_send_mode_t mode,
179 struct ompi_communicator_t* comm,
180 struct ompi_request_t **request,
181 ompi_crcp_base_pml_state_t* pml_state )
182 {
183 pml_state->error_code = OMPI_SUCCESS;
184 return pml_state;
185 }
186
187 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_isend( void *buf, size_t count,
188 ompi_datatype_t *datatype,
189 int dst, int tag,
190 mca_pml_base_send_mode_t mode,
191 struct ompi_communicator_t* comm,
192 struct ompi_request_t **request,
193 ompi_crcp_base_pml_state_t* pml_state )
194 {
195 pml_state->error_code = OMPI_SUCCESS;
196 return pml_state;
197 }
198
199 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_send( void *buf, size_t count,
200 ompi_datatype_t *datatype,
201 int dst, int tag,
202 mca_pml_base_send_mode_t mode,
203 struct ompi_communicator_t* comm,
204 ompi_crcp_base_pml_state_t* pml_state )
205 {
206 pml_state->error_code = OMPI_SUCCESS;
207 return pml_state;
208 }
209
210 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_irecv_init( void *buf, size_t count,
211 ompi_datatype_t *datatype,
212 int src, int tag,
213 struct ompi_communicator_t* comm,
214 struct ompi_request_t **request,
215 ompi_crcp_base_pml_state_t* pml_state)
216 {
217 pml_state->error_code = OMPI_SUCCESS;
218 return pml_state;
219 }
220
221 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_irecv( void *buf, size_t count,
222 ompi_datatype_t *datatype,
223 int src, int tag,
224 struct ompi_communicator_t* comm,
225 struct ompi_request_t **request,
226 ompi_crcp_base_pml_state_t* pml_state )
227 {
228 pml_state->error_code = OMPI_SUCCESS;
229 return pml_state;
230 }
231
232 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_recv( void *buf, size_t count,
233 ompi_datatype_t *datatype,
234 int src, int tag,
235 struct ompi_communicator_t* comm,
236 ompi_status_public_t* status,
237 ompi_crcp_base_pml_state_t* pml_state)
238 {
239 pml_state->error_code = OMPI_SUCCESS;
240 return pml_state;
241 }
242
243 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_dump( struct ompi_communicator_t* comm,
244 int verbose,
245 ompi_crcp_base_pml_state_t* pml_state )
246 {
247 pml_state->error_code = OMPI_SUCCESS;
248 return pml_state;
249 }
250
251 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_start( size_t count,
252 ompi_request_t** requests,
253 ompi_crcp_base_pml_state_t* pml_state )
254 {
255 pml_state->error_code = OMPI_SUCCESS;
256 return pml_state;
257 }
258
259 ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_ft_event(int state,
260 ompi_crcp_base_pml_state_t* pml_state)
261 {
262 pml_state->error_code = OMPI_SUCCESS;
263 return pml_state;
264 }
265
266
267
268
269 int ompi_crcp_base_none_request_complete( struct ompi_request_t *request ) {
270 return OMPI_SUCCESS;
271 }
272
273
274
275
276 ompi_crcp_base_btl_state_t*
277 ompi_crcp_base_none_btl_add_procs( struct mca_btl_base_module_t* btl,
278 size_t nprocs,
279 struct ompi_proc_t** procs,
280 struct mca_btl_base_endpoint_t** endpoints,
281 struct opal_bitmap_t* reachable,
282 ompi_crcp_base_btl_state_t* btl_state)
283 {
284 btl_state->error_code = OMPI_SUCCESS;
285 return btl_state;
286 }
287
288 ompi_crcp_base_btl_state_t*
289 ompi_crcp_base_none_btl_del_procs( struct mca_btl_base_module_t* btl,
290 size_t nprocs,
291 struct ompi_proc_t** procs,
292 struct mca_btl_base_endpoint_t** endpoints,
293 ompi_crcp_base_btl_state_t* btl_state)
294 {
295 btl_state->error_code = OMPI_SUCCESS;
296 return btl_state;
297 }
298
299 ompi_crcp_base_btl_state_t*
300 ompi_crcp_base_none_btl_register( struct mca_btl_base_module_t* btl,
301 mca_btl_base_tag_t tag,
302 mca_btl_base_module_recv_cb_fn_t cbfunc,
303 void* cbdata,
304 ompi_crcp_base_btl_state_t* btl_state)
305 {
306 btl_state->error_code = OMPI_SUCCESS;
307 return btl_state;
308 }
309
310 ompi_crcp_base_btl_state_t*
311 ompi_crcp_base_none_btl_finalize( struct mca_btl_base_module_t* btl,
312 ompi_crcp_base_btl_state_t* btl_state)
313 {
314 btl_state->error_code = OMPI_SUCCESS;
315 return btl_state;
316 }
317
318 ompi_crcp_base_btl_state_t*
319 ompi_crcp_base_none_btl_alloc( struct mca_btl_base_module_t* btl,
320 size_t size,
321 ompi_crcp_base_btl_state_t* btl_state)
322 {
323 btl_state->error_code = OMPI_SUCCESS;
324 return btl_state;
325 }
326
327 ompi_crcp_base_btl_state_t*
328 ompi_crcp_base_none_btl_free( struct mca_btl_base_module_t* btl,
329 mca_btl_base_descriptor_t* descriptor,
330 ompi_crcp_base_btl_state_t* btl_state)
331 {
332 btl_state->error_code = OMPI_SUCCESS;
333 return btl_state;
334 }
335
336 ompi_crcp_base_btl_state_t*
337 ompi_crcp_base_none_btl_prepare_src( struct mca_btl_base_module_t* btl,
338 struct mca_btl_base_endpoint_t* endpoint,
339 mca_rcache_base_registration_t* registration,
340 struct opal_convertor_t* convertor,
341 size_t reserve,
342 size_t* size,
343 ompi_crcp_base_btl_state_t* btl_state)
344 {
345 btl_state->error_code = OMPI_SUCCESS;
346 return btl_state;
347 }
348
349 ompi_crcp_base_btl_state_t*
350 ompi_crcp_base_none_btl_prepare_dst( struct mca_btl_base_module_t* btl,
351 struct mca_btl_base_endpoint_t* endpoint,
352 mca_rcache_base_registration_t* registration,
353 struct opal_convertor_t* convertor,
354 size_t reserve,
355 size_t* size,
356 ompi_crcp_base_btl_state_t* btl_state)
357 {
358 btl_state->error_code = OMPI_SUCCESS;
359 return btl_state;
360 }
361
362 ompi_crcp_base_btl_state_t*
363 ompi_crcp_base_none_btl_send( struct mca_btl_base_module_t* btl,
364 struct mca_btl_base_endpoint_t* endpoint,
365 struct mca_btl_base_descriptor_t* descriptor,
366 mca_btl_base_tag_t tag,
367 ompi_crcp_base_btl_state_t* btl_state)
368 {
369 btl_state->error_code = OMPI_SUCCESS;
370 return btl_state;
371 }
372
373 ompi_crcp_base_btl_state_t*
374 ompi_crcp_base_none_btl_put( struct mca_btl_base_module_t* btl,
375 struct mca_btl_base_endpoint_t* endpoint,
376 struct mca_btl_base_descriptor_t* descriptor,
377 ompi_crcp_base_btl_state_t* btl_state)
378 {
379 btl_state->error_code = OMPI_SUCCESS;
380 return btl_state;
381 }
382
383 ompi_crcp_base_btl_state_t*
384 ompi_crcp_base_none_btl_get( struct mca_btl_base_module_t* btl,
385 struct mca_btl_base_endpoint_t* endpoint,
386 struct mca_btl_base_descriptor_t* descriptor,
387 ompi_crcp_base_btl_state_t* btl_state)
388 {
389 btl_state->error_code = OMPI_SUCCESS;
390 return btl_state;
391 }
392
393
394 ompi_crcp_base_btl_state_t*
395 ompi_crcp_base_none_btl_dump( struct mca_btl_base_module_t* btl,
396 struct mca_btl_base_endpoint_t* endpoint,
397 int verbose,
398 ompi_crcp_base_btl_state_t* btl_state)
399 {
400 btl_state->error_code = OMPI_SUCCESS;
401 return btl_state;
402 }
403
404 ompi_crcp_base_btl_state_t*
405 ompi_crcp_base_none_btl_ft_event(int state,
406 ompi_crcp_base_btl_state_t* btl_state)
407 {
408 btl_state->error_code = OMPI_SUCCESS;
409 return btl_state;
410 }
411
412
413
414
415
416
417
418
419
420 int ompi_crcp_base_quiesce_start(MPI_Info *info)
421 {
422 if( NULL != ompi_crcp.quiesce_start ) {
423 return ompi_crcp.quiesce_start(info);
424 } else {
425 return OMPI_SUCCESS;
426 }
427 }
428
429 int ompi_crcp_base_quiesce_end(MPI_Info *info)
430 {
431 if( NULL != ompi_crcp.quiesce_end ) {
432 return ompi_crcp.quiesce_end(info);
433 } else {
434 return OMPI_SUCCESS;
435 }
436 }