Home
last modified time | relevance | path

Searched refs:mpi_status (Results 1 – 25 of 61) sorted by relevance

123

/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/pml/ucx/
H A Dpml_ucx_request.h148 mpi_status->MPI_ERROR = MPI_SUCCESS; in mca_pml_ucx_set_send_status()
149 mpi_status->_cancelled = false; in mca_pml_ucx_set_send_status()
151 mpi_status->_cancelled = true; in mca_pml_ucx_set_send_status()
153 mpi_status->MPI_ERROR = MPI_ERR_INTERN; in mca_pml_ucx_set_send_status()
165 mpi_status->MPI_ERROR = MPI_SUCCESS; in mca_pml_ucx_set_recv_status()
168 mpi_status->_cancelled = false; in mca_pml_ucx_set_recv_status()
169 mpi_status->_ucount = info->length; in mca_pml_ucx_set_recv_status()
173 mpi_status->MPI_ERROR = MPI_SUCCESS; in mca_pml_ucx_set_recv_status()
174 mpi_status->_cancelled = true; in mca_pml_ucx_set_recv_status()
176 mpi_status->MPI_ERROR = MPI_ERR_INTERN; in mca_pml_ucx_set_recv_status()
[all …]
H A Dpml_ucx.c573 ompi_status_public_t* mpi_status) in mca_pml_ucx_recv() argument
591 mca_pml_ucx_set_recv_status_safe(mpi_status, status, &info); in mca_pml_ucx_recv()
851 int *matched, ompi_status_public_t* mpi_status) in mca_pml_ucx_iprobe() argument
864 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_iprobe()
873 ompi_status_public_t* mpi_status) in mca_pml_ucx_probe() argument
886 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_probe()
896 ompi_status_public_t* mpi_status) in mca_pml_ucx_improbe() argument
911 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_improbe()
921 ompi_status_public_t* mpi_status) in mca_pml_ucx_mprobe() argument
936 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_mprobe()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/pml/ucx/
H A Dpml_ucx_request.h159 mpi_status->MPI_ERROR = MPI_SUCCESS; in mca_pml_ucx_set_send_status()
160 mpi_status->_cancelled = false; in mca_pml_ucx_set_send_status()
162 mpi_status->_cancelled = true; in mca_pml_ucx_set_send_status()
176 mpi_status->MPI_ERROR = MPI_SUCCESS; in mca_pml_ucx_set_recv_status()
179 mpi_status->_cancelled = false; in mca_pml_ucx_set_recv_status()
180 mpi_status->_ucount = info->length; in mca_pml_ucx_set_recv_status()
184 mpi_status->MPI_ERROR = MPI_SUCCESS; in mca_pml_ucx_set_recv_status()
185 mpi_status->_cancelled = true; in mca_pml_ucx_set_recv_status()
187 mpi_status->MPI_ERROR = MPI_ERR_INTERN; in mca_pml_ucx_set_recv_status()
190 return mpi_status->MPI_ERROR; in mca_pml_ucx_set_recv_status()
[all …]
H A Dpml_ucx.c614 ompi_status_public_t* mpi_status) in mca_pml_ucx_recv() argument
647 return mca_pml_ucx_set_recv_status_safe(mpi_status, status, &info); in mca_pml_ucx_recv()
953 int *matched, ompi_status_public_t* mpi_status) in mca_pml_ucx_iprobe() argument
968 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_iprobe()
978 ompi_status_public_t* mpi_status) in mca_pml_ucx_probe() argument
992 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_probe()
1000 ompi_status_public_t* mpi_status) in mca_pml_ucx_improbe() argument
1017 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_improbe()
1028 ompi_status_public_t* mpi_status) in mca_pml_ucx_mprobe() argument
1043 mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); in mca_pml_ucx_mprobe()
/dports/net/openmpi3/openmpi-3.1.6/ompi/mpi/cxx/
H A Dstatus_inln.h29 (void)MPI_Get_count(const_cast<MPI_Status*>(&mpi_status), datatype, &count); in Get_count()
37 (void)MPI_Test_cancelled(const_cast<MPI_Status*>(&mpi_status), &t); in Is_cancelled()
45 (void)MPI_Get_elements(const_cast<MPI_Status*>(&mpi_status), datatype, &count); in Get_elements()
56 source = mpi_status.MPI_SOURCE; in Get_source()
63 mpi_status.MPI_SOURCE = source; in Set_source()
70 tag = mpi_status.MPI_TAG; in Get_tag()
77 mpi_status.MPI_TAG = tag; in Set_tag()
84 error = mpi_status.MPI_ERROR; in Get_error()
91 mpi_status.MPI_ERROR = error; in Set_error()
97 MPI_Status_set_elements(&mpi_status, datatype, count); in Set_elements()
[all …]
H A Dstatus.h58 Status() : mpi_status() { } in Status()
60 Status(const Status& data) : mpi_status(data.mpi_status) { } in Status()
62 Status(const MPI_Status &i) : mpi_status(i) { } in Status()
67 mpi_status = data.mpi_status; return *this; }
73 mpi_status = i; return *this; }
74 operator MPI_Status () const { return mpi_status; } in MPI_Status()
112 MPI_Status mpi_status;
H A Dfile_inln.h260 (void) MPI_File_read_all_end(mpi_file, buf, &status.mpi_status); in Read_all_end()
281 &status.mpi_status); in Read_at()
300 &status.mpi_status); in Read_at_all()
343 &status.mpi_status); in Read_ordered()
385 &status.mpi_status); in Read_shared()
457 &status.mpi_status); in Write()
477 &status.mpi_status); in Write_all()
522 datatype, &status.mpi_status); in Write_at()
544 datatype, &status.mpi_status); in Write_at_all()
589 &status.mpi_status); in Write_ordered()
[all …]
H A Drequest_inln.h29 (void)MPI_Wait(&mpi_request, &status.mpi_status); in Wait()
48 (void)MPI_Test(&mpi_request, &t, &status.mpi_status); in Test()
69 (void)MPI_Waitany(count, array_of_requests, &index, &status.mpi_status); in Waitany()
102 (void)MPI_Testany(count, array_of_requests, &index, &flag, &status.mpi_status); in Testany()
H A Dcomm_inln.h37 (void)MPI_Recv(buf, count, datatype, source, tag, mpi_comm, &status.mpi_status); in Recv()
127 (void)MPI_Iprobe(source, tag, mpi_comm, &t, &status.mpi_status); in Iprobe()
142 (void)MPI_Probe(source, tag, mpi_comm, &status.mpi_status); in Probe()
212 source, recvtag, mpi_comm, &status.mpi_status); in Sendrecv()
237 &status.mpi_status); in Sendrecv_replace()
/dports/net/openmpi/openmpi-4.1.1/ompi/mpi/cxx/
H A Dstatus_inln.h29 (void)MPI_Get_count(const_cast<MPI_Status*>(&mpi_status), datatype, &count); in Get_count()
37 (void)MPI_Test_cancelled(const_cast<MPI_Status*>(&mpi_status), &t); in Is_cancelled()
45 (void)MPI_Get_elements(const_cast<MPI_Status*>(&mpi_status), datatype, &count); in Get_elements()
56 source = mpi_status.MPI_SOURCE; in Get_source()
63 mpi_status.MPI_SOURCE = source; in Set_source()
70 tag = mpi_status.MPI_TAG; in Get_tag()
77 mpi_status.MPI_TAG = tag; in Set_tag()
84 error = mpi_status.MPI_ERROR; in Get_error()
91 mpi_status.MPI_ERROR = error; in Set_error()
97 MPI_Status_set_elements(&mpi_status, datatype, count); in Set_elements()
[all …]
H A Dstatus.h58 Status() : mpi_status() { } in Status()
60 Status(const Status& data) : mpi_status(data.mpi_status) { } in Status()
62 Status(const MPI_Status &i) : mpi_status(i) { } in Status()
67 mpi_status = data.mpi_status; return *this; }
73 mpi_status = i; return *this; }
74 operator MPI_Status () const { return mpi_status; } in MPI_Status()
112 MPI_Status mpi_status;
H A Dfile_inln.h260 (void) MPI_File_read_all_end(mpi_file, buf, &status.mpi_status); in Read_all_end()
281 &status.mpi_status); in Read_at()
300 &status.mpi_status); in Read_at_all()
343 &status.mpi_status); in Read_ordered()
385 &status.mpi_status); in Read_shared()
457 &status.mpi_status); in Write()
477 &status.mpi_status); in Write_all()
522 datatype, &status.mpi_status); in Write_at()
544 datatype, &status.mpi_status); in Write_at_all()
589 &status.mpi_status); in Write_ordered()
[all …]
H A Drequest_inln.h29 (void)MPI_Wait(&mpi_request, &status.mpi_status); in Wait()
48 (void)MPI_Test(&mpi_request, &t, &status.mpi_status); in Test()
69 (void)MPI_Waitany(count, array_of_requests, &index, &status.mpi_status); in Waitany()
102 (void)MPI_Testany(count, array_of_requests, &index, &flag, &status.mpi_status); in Testany()
/dports/biology/fasta3/fasta-36.3.8/src/
H A Dpcomp_subs2.c68 MPI_Status mpi_status; in init_thr() local
128 MPI_COMM_WORLD, &mpi_status); in init_thr()
129 snode= mpi_status.MPI_SOURCE; in init_thr()
185 MPI_Status mpi_status; in next_work_result() local
190 MPI_COMM_WORLD, &mpi_status); in next_work_result()
191 this_node = mpi_status.MPI_SOURCE; in next_work_result()
335 MPI_Status mpi_status; in get_rbuf() local
360 MPI_Status mpi_status; in put_rbuf() local
453 MPI_Status mpi_status; in rbuf_done() local
486 MPI_Status mpi_status; in get_wbuf() local
[all …]
H A Dwork_thr2.c129 MPI_Status mpi_status; local
168 &mpi_status);
179 &mpi_status);
182 &mpi_status);
285 STARTTYPE3, MPI_COMM_WORLD,&mpi_status);
288 STARTTYPE3, MPI_COMM_WORLD,&mpi_status);
293 MPI_Recv(pascii, sizeof(aascii), MPI_BYTE, 0, STARTTYPE4, MPI_COMM_WORLD, &mpi_status);
334 QSEQTYPE0, MPI_COMM_WORLD, &mpi_status);
373 QSEQTYPE1,MPI_COMM_WORLD, &mpi_status);
382 QSEQTYPE1, MPI_COMM_WORLD, &mpi_status);
/dports/math/blocksolve95/BlockSolve95/src/
H A DBSbulletin_d.c116 MPI_Status mpi_status; in BSquery_match_bb_d() local
177 RECVSYNCUNSZ(BB_SQ_MSG,msg_buf,size,MPI_INT,procinfo,mpi_status); in BSquery_match_bb_d()
180 from = mpi_status.MPI_SOURCE; in BSquery_match_bb_d()
206 RECVSYNCUNSZ(BB_SA_MSG,msg_buf,size,MY_MPI_FLT,procinfo,mpi_status); in BSquery_match_bb_d()
209 from = mpi_status.MPI_SOURCE; in BSquery_match_bb_d()
269 MPI_Status mpi_status; in BSquery_nomatch_bb_d() local
372 &msg_avail,&mpi_status); in BSquery_nomatch_bb_d()
376 &msg_avail,&mpi_status); in BSquery_nomatch_bb_d()
386 from = mpi_status.MPI_SOURCE; in BSquery_nomatch_bb_d()
433 mpi_status); CHKERR(0); in BSquery_nomatch_bb_d()
[all …]
H A DBSbulletin.c118 MPI_Status mpi_status; in BSquery_match_bb() local
178 RECVSYNCUNSZ(BB_SQ_MSG,msg_buf,size,MPI_INT,procinfo,mpi_status); in BSquery_match_bb()
181 from = mpi_status.MPI_SOURCE; in BSquery_match_bb()
214 RECVSYNCUNSZ(BB_SA_MSG,msg_buf,size,MPI_INT,procinfo,mpi_status); in BSquery_match_bb()
217 from = mpi_status.MPI_SOURCE; in BSquery_match_bb()
285 MPI_Status mpi_status; in BSquery_nomatch_bb() local
388 &msg_avail,&mpi_status); in BSquery_nomatch_bb()
392 &msg_avail,&mpi_status); in BSquery_nomatch_bb()
398 RECVSYNCUNSZ(BB_SQ_MSG,msg_buf,size,MPI_INT,procinfo,mpi_status); in BSquery_nomatch_bb()
401 from = mpi_status.MPI_SOURCE; in BSquery_nomatch_bb()
[all …]
H A DBSoffset.c37 MPI_Status mpi_status; in BSoffset() local
64 mpi_status); in BSoffset()
68 if (mpi_status.MPI_SOURCE == l_child) l_buffer = recv_buf; in BSoffset()
69 if (mpi_status.MPI_SOURCE == r_child) r_buffer = recv_buf; in BSoffset()
87 mpi_status); in BSoffset()
H A DBMcomp_msg.c460 MPI_Status mpi_status; in BMfix_send() local
530 RECVSYNCUNSZN(msg_type,in_msg,size,MPI_INT,procinfo,mpi_status); in BMfix_send()
532 from = mpi_status.MPI_SOURCE; in BMfix_send()
809 MPI_Status mpi_status; in BMrecv_block_msg() local
826 msg_ptr->size,msg_ptr->msg_data_type,procinfo,mpi_status); in BMrecv_block_msg()
865 MPI_Status mpi_status; in BMrecv_msg() local
874 MPI_Test(&(msg_ptr->recv_id),&finished,&mpi_status); in BMrecv_msg()
/dports/science/gromacs/gromacs-2021.4/python_packaging/src/gmxapi/
H A Dtestsupport.py62 mpi_status = 'Test requires mpi4py managing 2 MPI ranks.' variable
69 mpi_status += ' MPI is not initialized'
72 mpi_status += ' MPI context is too small.'
75 mpi_status += ' mpi4py is not available.'
86 pytest.skip(mpi_status)
/dports/science/apbs/apbs-pdb2pqr-apbs-1.5-102-g500c1473/apbs/externals/fetk/maloc/src/psh/
H A Dvcom_p.h46 MPI_Status mpi_status; /* MPI_Status object (4-int struct) */ member
50 int mpi_status;
H A Dvcom.c500 core->mpi_comm, &(core->mpi_status)); in Vcom_recv()
664 MPI_Probe(src, VCOM_MPI_TAG, core->mpi_comm, &(core->mpi_status)); in Vcom_getCount()
665 return MPI_Get_count(&(core->mpi_status), datatype, length); in Vcom_getCount()
/dports/math/mfem/mfem-4.3/fem/
H A Dconduitdatacollection.cpp1028 int mpi_status = MPI_Bcast((void*)&json_str_size, // ptr in LoadRootFile() local
1034 if (mpi_status != MPI_SUCCESS) in LoadRootFile()
1040 mpi_status = MPI_Bcast((void*)root_json.c_str(), // ptr in LoadRootFile()
1046 if (mpi_status != MPI_SUCCESS) in LoadRootFile()
1059 int mpi_status = MPI_Bcast(&json_str_size, // ptr in LoadRootFile() local
1065 if (mpi_status != MPI_SUCCESS) in LoadRootFile()
1072 mpi_status = MPI_Bcast(json_buff, // ptr in LoadRootFile()
1078 if (mpi_status != MPI_SUCCESS) in LoadRootFile()
/dports/science/hdf5-18/hdf5-1.8.21/tools/perform/
H A Dpio_engine.c549 MPI_Status mpi_status; in do_write() local
1131 &mpi_status); in do_write()
1153 (int)1, mpi_blk_type, &mpi_status); in do_write()
1177 (int)(buf_size/blk_size), mpi_blk_type, &mpi_status); in do_write()
1292 (int)nbytes_xfer_advance, MPI_BYTE, &mpi_status); in do_write()
1318 MPI_BYTE, &mpi_status); in do_write()
1529 MPI_Status mpi_status; in do_read() local
2061 &mpi_status); in do_read()
2083 (int)1, mpi_blk_type, &mpi_status); in do_read()
2222 (int)nbytes_xfer_advance, MPI_BYTE, &mpi_status); in do_read()
[all …]
/dports/science/hdf5/hdf5-1.10.6/tools/test/perform/
H A Dpio_engine.c554 MPI_Status mpi_status; in do_write() local
1136 &mpi_status); in do_write()
1158 (int)1, mpi_blk_type, &mpi_status); in do_write()
1182 (int)(buf_size/blk_size), mpi_blk_type, &mpi_status); in do_write()
1297 (int)nbytes_xfer_advance, MPI_BYTE, &mpi_status); in do_write()
1323 MPI_BYTE, &mpi_status); in do_write()
1534 MPI_Status mpi_status; in do_read() local
2066 &mpi_status); in do_read()
2088 (int)1, mpi_blk_type, &mpi_status); in do_read()
2227 (int)nbytes_xfer_advance, MPI_BYTE, &mpi_status); in do_read()
[all …]

123