libxmp/libxmpf in Omni Compiler
1.3.4
|
#include "xmp_internal.h"
#include <string.h>
◆ _XMP_get_async()
35 if(async->
async_id == async_id)
return async;
◆ _XMP_get_current_async()
◆ _XMP_initialize_async_comm_tab()
void _XMP_initialize_async_comm_tab |
( |
| ) |
|
53 _XMP_async_comm_tab[i].
nreqs = 0;
54 _XMP_async_comm_tab[i].
nnodes = 0;
55 _XMP_async_comm_tab[i].
is_used =
false;
57 _XMP_async_comm_tab[i].
node = NULL;
58 _XMP_async_comm_tab[i].
reqs = NULL;
59 _XMP_async_comm_tab[i].
gmove = NULL;
60 _XMP_async_comm_tab[i].
a = NULL;
61 _XMP_async_comm_tab[i].
next = NULL;
◆ _XMP_nodes_dealloc_after_wait_async()
void _XMP_nodes_dealloc_after_wait_async |
( |
_XMP_nodes_t * |
n | ) |
|
277 if(_tmp_async->
nnodes == 0)
◆ _XMP_wait_async__()
void _XMP_wait_async__ |
( |
int |
async_id | ) |
|
93 int nreqs = async->
nreqs;
94 MPI_Request *reqs = async->
reqs;
96 #if defined(_KCOMPUTER) && defined(K_RDMA_REFLECT)
99 _XMP_wait_async_rdma(async);
107 MPI_Waitall(nreqs, reqs, MPI_STATUSES_IGNORE);
112 MPI_Waitall(nreqs, reqs, MPI_STATUSES_IGNORE);
122 #ifdef _XMP_MPI3_ONESIDED
◆ xmp_is_async()
◆ xmp_test_async_()
int xmp_test_async_ |
( |
int * |
async_id | ) |
|
141 int nreqs = async->
nreqs;
142 MPI_Request *reqs = async->
reqs;
144 #if defined(_KCOMPUTER) && defined(K_RDMA_REFLECT)
146 _XMP_fatal(
"xmp_test_async not supported for RDMA.");
150 MPI_Testall(nreqs, reqs, &flag, MPI_STATUSES_IGNORE);
154 if (gmove) _XMP_finalize_async_gmove(gmove);
◆ xmpc_end_async()
void xmpc_end_async |
( |
int |
async_id | ) |
|
339 if(async->
next == NULL){
340 initialize_async(async);
344 initialize_async(async);
361 while((async = prev->
next)){
364 initialize_async(async);
◆ xmpc_init_async()
void xmpc_init_async |
( |
int |
async_id | ) |
|
221 _xmp_is_async =
true;
◆ xmpc_start_async()
void xmpc_start_async |
( |
| ) |
|
291 _xmp_is_async =
false;
◆ _XMP_unpack_comm_set
#define _XMP_COMM_NONE
Definition: xmp_constant.h:135
#define _XMP_ASYNC_COMM_SIZE
Definition: xmp_data_struct.h:471
#define _XMP_MAX_ASYNC_REQS
Definition: xmp_data_struct.h:472
#define _XMP_MAX_ASYNC_NODES
Definition: xmp_data_struct.h:473
void * _XMP_alloc(size_t size)
Definition: xmp_util.c:21
struct _XMP_async_comm * next
Definition: xmp_data_struct.h:468
#define _XMP_N_GMOVE_NORMAL
Definition: xmp_constant.h:69
void * sendbuf
Definition: xmp_data_struct.h:451
void xmpc_end_async(int async_id)
Definition: xmp_async.c:327
_XMP_async_gmove_t * gmove
Definition: xmp_data_struct.h:466
#define _XMP_TEND(t, t0)
Definition: xmp_internal.h:748
int type
Definition: xmp_data_struct.h:463
_Bool is_used
Definition: xmp_data_struct.h:462
#define _XMP_COMM_REDUCE_SHADOW
Definition: xmp_constant.h:137
#define _XMP_TSTART(t0)
Definition: xmp_internal.h:747
int nnodes
Definition: xmp_data_struct.h:461
int nreqs
Definition: xmp_data_struct.h:460
MPI_Request * reqs
Definition: xmp_data_struct.h:464
Definition: xmp_data_struct.h:458
void _XMP_free(void *p)
Definition: xmp_util.c:37
_XMP_array_t * a
Definition: xmp_data_struct.h:467
void _XMP_sync_images_COMM(MPI_Comm *comm, int *status)
Definition: xmp_coarray_mpi.c:1105
_XMP_nodes_t ** node
Definition: xmp_data_struct.h:465
_XMP_async_comm_t * _XMP_get_async(int async_id)
Definition: xmp_async.c:30
void _XMP_fatal(char *msg)
Definition: xmp_util.c:42
void _XMP_reduce_shadow_sum(_XMP_array_t *a)
Definition: xmp_reduce_shadow.c:153
Definition: xmp_data_struct.h:40
int async_id
Definition: xmp_data_struct.h:459
int mode
Definition: xmp_data_struct.h:450
Definition: xmp_data_struct.h:449