/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/pml/ucx/ |
H A D | pml_ucx_request.h | 148 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 D | pml_ucx.c | 573 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 D | pml_ucx_request.h | 159 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 D | pml_ucx.c | 614 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 D | status_inln.h | 29 (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 D | status.h | 58 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 D | file_inln.h | 260 (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 D | request_inln.h | 29 (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 D | comm_inln.h | 37 (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 D | status_inln.h | 29 (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 D | status.h | 58 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 D | file_inln.h | 260 (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 D | request_inln.h | 29 (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 D | pcomp_subs2.c | 68 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 D | work_thr2.c | 129 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 D | BSbulletin_d.c | 116 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 D | BSbulletin.c | 118 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 D | BSoffset.c | 37 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 D | BMcomp_msg.c | 460 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 D | testsupport.py | 62 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 D | vcom_p.h | 46 MPI_Status mpi_status; /* MPI_Status object (4-int struct) */ member 50 int mpi_status;
|
H A D | vcom.c | 500 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 D | conduitdatacollection.cpp | 1028 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 D | pio_engine.c | 549 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 D | pio_engine.c | 554 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 …]
|