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
|
/*
* Copyright (c) 2004-2007 The Trustees of the University of Tennessee.
* All rights reserved.
* $COPYRIGHT$
*
* Additional copyrights may follow
*
* $HEADER$
*/
#include "ompi_config.h"
#include "vprotocol_pessimist.h"
static inline int replay_iprobe(int src, int tag,
struct ompi_communicator_t *comm,
int *matched, ompi_status_public_t * status );
static inline void log_iprobe(int ret, int src, int tag,
struct ompi_communicator_t *comm,
int *matched, ompi_status_public_t * status);
static inline int replay_probe(int src, int tag,
struct ompi_communicator_t *comm,
ompi_status_public_t * status);
static inline void log_probe(int ret, int src, int tag,
struct ompi_communicator_t *comm,
ompi_status_public_t * status);
/*******************************************************************************
* MPI level functions
*/
int mca_vprotocol_pessimist_iprobe( int src, int tag,
struct ompi_communicator_t *comm,
int *matched, ompi_status_public_t * status )
{
int ret;
if(mca_vprotocol_pessimist.replay)
{
ret = replay_iprobe(src, tag, comm, matched, status);
}
else
{
ret = mca_pml_v.host_pml.pml_iprobe(src, tag, comm, matched, status);
log_iprobe(ret, src, tag, comm, matched, status);
}
return ret;
}
int mca_vprotocol_pessimist_probe( int src, int tag,
struct ompi_communicator_t *comm,
ompi_status_public_t * status )
{
int ret;
if(mca_vprotocol_pessimist.replay)
{
ret = replay_probe(src, tag, comm, status);
}
else
{
ret = mca_pml_v.host_pml.pml_probe(src, tag, comm, status);
log_probe(ret, src, tag, comm, status);
}
return ret;
}
/*******************************************************************************
* message logging internals
*/
static inline int replay_iprobe(int src, int tag,
struct ompi_communicator_t *comm,
int *matched, ompi_status_public_t * status )
{
return OMPI_ERROR;
}
static inline void log_iprobe(int ret, int src, int tag,
struct ompi_communicator_t *comm,
int *matched, ompi_status_public_t * status)
{
return;
}
static inline int replay_probe(int src, int tag,
struct ompi_communicator_t *comm,
ompi_status_public_t * status)
{
return OMPI_ERROR;
}
static inline void log_probe(int ret, int src, int tag,
struct ompi_communicator_t *comm,
ompi_status_public_t * status)
{
return;
}
|
