This source file includes following definitions.
- mca_vprotocol_pessimist_iprobe
- mca_vprotocol_pessimist_probe
- replay_iprobe
- log_iprobe
- replay_probe
- log_probe
1
2
3
4
5
6
7
8
9
10
11 #include "ompi_config.h"
12 #include "vprotocol_pessimist.h"
13
14 static inline int replay_iprobe(int src, int tag,
15 struct ompi_communicator_t *comm,
16 int *matched, ompi_status_public_t * status );
17 static inline void log_iprobe(int ret, int src, int tag,
18 struct ompi_communicator_t *comm,
19 int *matched, ompi_status_public_t * status);
20 static inline int replay_probe(int src, int tag,
21 struct ompi_communicator_t *comm,
22 ompi_status_public_t * status);
23 static inline void log_probe(int ret, int src, int tag,
24 struct ompi_communicator_t *comm,
25 ompi_status_public_t * status);
26
27
28
29
30 int mca_vprotocol_pessimist_iprobe( int src, int tag,
31 struct ompi_communicator_t *comm,
32 int *matched, ompi_status_public_t * status )
33 {
34 int ret;
35
36 if(mca_vprotocol_pessimist.replay)
37 {
38 ret = replay_iprobe(src, tag, comm, matched, status);
39 }
40 else
41 {
42 ret = mca_pml_v.host_pml.pml_iprobe(src, tag, comm, matched, status);
43 log_iprobe(ret, src, tag, comm, matched, status);
44 }
45 return ret;
46 }
47
48 int mca_vprotocol_pessimist_probe( int src, int tag,
49 struct ompi_communicator_t *comm,
50 ompi_status_public_t * status )
51 {
52 int ret;
53
54 if(mca_vprotocol_pessimist.replay)
55 {
56 ret = replay_probe(src, tag, comm, status);
57 }
58 else
59 {
60 ret = mca_pml_v.host_pml.pml_probe(src, tag, comm, status);
61 log_probe(ret, src, tag, comm, status);
62 }
63 return ret;
64 }
65
66
67
68
69 static inline int replay_iprobe(int src, int tag,
70 struct ompi_communicator_t *comm,
71 int *matched, ompi_status_public_t * status )
72 {
73 return OMPI_ERROR;
74 }
75
76 static inline void log_iprobe(int ret, int src, int tag,
77 struct ompi_communicator_t *comm,
78 int *matched, ompi_status_public_t * status)
79 {
80 return;
81 }
82
83 static inline int replay_probe(int src, int tag,
84 struct ompi_communicator_t *comm,
85 ompi_status_public_t * status)
86 {
87 return OMPI_ERROR;
88 }
89
90 static inline void log_probe(int ret, int src, int tag,
91 struct ompi_communicator_t *comm,
92 ompi_status_public_t * status)
93 {
94 return;
95 }