This source file includes following definitions.
- MPI_Comm_disconnect
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 #include "ompi_config.h"
23 #include <stdio.h>
24
25 #include "ompi/mpi/c/bindings.h"
26 #include "ompi/runtime/params.h"
27 #include "ompi/communicator/communicator.h"
28 #include "ompi/errhandler/errhandler.h"
29 #include "ompi/memchecker.h"
30
31 #if OMPI_BUILD_MPI_PROFILING
32 #if OPAL_HAVE_WEAK_SYMBOLS
33 #pragma weak MPI_Comm_disconnect = PMPI_Comm_disconnect
34 #endif
35 #define MPI_Comm_disconnect PMPI_Comm_disconnect
36 #endif
37
38 #include "ompi/dpm/dpm.h"
39
40
41 static const char FUNC_NAME[] = "MPI_Comm_disconnect";
42
43
44 int MPI_Comm_disconnect(MPI_Comm *comm)
45 {
46 int ret = MPI_SUCCESS;
47
48 MEMCHECKER(
49 memchecker_comm(*comm);
50 );
51
52 if ( MPI_PARAM_CHECK ) {
53 OMPI_ERR_INIT_FINALIZE(FUNC_NAME);
54
55 if ( ompi_comm_invalid (*comm))
56 return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
57 FUNC_NAME);
58 }
59
60 if (MPI_COMM_WORLD == *comm || MPI_COMM_SELF == *comm ) {
61 return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM, FUNC_NAME);
62 }
63
64 OPAL_CR_ENTER_LIBRARY();
65
66 if ( OMPI_COMM_IS_DYNAMIC(*comm)) {
67 if (OMPI_SUCCESS != ompi_dpm_disconnect (*comm)) {
68 ret = OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM, FUNC_NAME);
69 }
70 }
71 else {
72 (*comm)->c_coll->coll_barrier(*comm, (*comm)->c_coll->coll_barrier_module);
73 }
74
75 ompi_comm_free(comm);
76
77 OPAL_CR_EXIT_LIBRARY();
78 return ret;
79 }