/dports/net/mpich2/mpich2-1.5/src/mpi/coll/ |
H A D | helper_fns.c | 51 MPID_Request *request_ptr=NULL; in MPIC_Send() local 64 if (request_ptr) { in MPIC_Send() 67 MPID_Request_release(request_ptr); in MPIC_Send() 74 if (request_ptr) { in MPIC_Send() 89 MPID_Request *request_ptr=NULL; in MPIC_Recv() local 102 if (request_ptr) { in MPIC_Recv() 106 *status = request_ptr->status; in MPIC_Recv() 119 if (request_ptr) { in MPIC_Recv() 120 MPID_Request_release(request_ptr); in MPIC_Recv() 147 if (request_ptr) { in MPIC_Ssend() [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpi/pt2pt/ |
H A D | recv.c | 70 MPID_Request * request_ptr = NULL; in MPI_Recv() local 135 MPID_CONTEXT_INTRA_PT2PT, status, &request_ptr); in MPI_Recv() 138 if (request_ptr == NULL) in MPI_Recv() 145 if (!MPID_Request_is_complete(request_ptr)) in MPI_Recv() 150 while (!MPID_Request_is_complete(request_ptr)) in MPI_Recv() 166 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Recv() 167 MPIR_Request_extract_status(request_ptr, status); in MPI_Recv() 168 MPID_Request_release(request_ptr); in MPI_Recv()
|
H A D | start.c | 49 MPID_Request * request_ptr = NULL; in MPI_Start() local 71 MPID_Request_get_ptr( *request, request_ptr ); in MPI_Start() 78 MPID_Request_valid_ptr( request_ptr, mpi_errno ); in MPI_Start() 80 MPIR_ERRTEST_PERSISTENT(request_ptr, mpi_errno); in MPI_Start() 81 MPIR_ERRTEST_PERSISTENT_ACTIVE(request_ptr, mpi_errno); in MPI_Start() 89 mpi_errno = MPID_Startall(1, &request_ptr); in MPI_Start()
|
H A D | send.c | 66 MPID_Request * request_ptr = NULL; in MPI_Send() local 125 MPID_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Send() 128 if (request_ptr == NULL) in MPI_Send() 135 if (!MPID_Request_is_complete(request_ptr)) in MPI_Send() 140 while (!MPID_Request_is_complete(request_ptr)) in MPI_Send() 154 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Send() 155 MPID_Request_release(request_ptr); in MPI_Send()
|
H A D | rsend.c | 61 MPID_Request * request_ptr = NULL; in MPI_Rsend() local 120 MPID_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Rsend() 123 if (request_ptr == NULL) in MPI_Rsend() 130 if (!MPID_Request_is_complete(request_ptr)) in MPI_Rsend() 135 while (!MPID_Request_is_complete(request_ptr)) in MPI_Rsend() 149 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Rsend() 150 MPID_Request_release(request_ptr); in MPI_Rsend()
|
H A D | ssend.c | 60 MPID_Request * request_ptr = NULL; in MPI_Ssend() local 119 MPID_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Ssend() 122 if (request_ptr == NULL) in MPI_Ssend() 129 mpi_errno = MPIR_Progress_wait_request(request_ptr); in MPI_Ssend() 132 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Ssend() 133 MPID_Request_release(request_ptr); in MPI_Ssend()
|
/dports/devel/stxxl/stxxl-1.4.1/include/stxxl/bits/mng/ |
H A D | write_pool.h | 42 request_ptr req; 47 busy_entry(block_type*& bl, request_ptr& r, bid_type& bi) in busy_entry() 50 operator request_ptr () { return req; } in request_ptr() function 116 request_ptr write(block_type*& block, bid_type bid) in write() 131 request_ptr result = block->write(bid); in write() 186 STXXL_DEPRECATED(request_ptr get_request(bid_type bid)) in STXXL_DEPRECATED() 194 return request_ptr(); in STXXL_DEPRECATED() 224 std::pair<block_type*, request_ptr> steal_request(bid_type bid) in steal_request() 232 request_ptr req = i2->req; in steal_request() 237 return std::pair<block_type*, request_ptr>(blk, req); in steal_request() [all …]
|
/dports/devel/stxxl/stxxl-1.4.1/lib/io/ |
H A D | request_queue_impl_1q.cpp | 34 struct file_offset_match : public std::binary_function<request_ptr, request_ptr, bool> 37 const request_ptr& a, in operator ()() 38 const request_ptr& b) const in operator ()() 53 void request_queue_impl_1q::add_request(request_ptr& req) in add_request() 79 bool request_queue_impl_1q::cancel_request(request_ptr& req) in cancel_request() 123 request_ptr req = pthis->m_queue.front(); in worker()
|
H A D | request_queue_impl_qwqr.cpp | 33 struct file_offset_match : public std::binary_function<request_ptr, request_ptr, bool> 36 const request_ptr& a, in operator ()() 37 const request_ptr& b) const in operator ()() 52 void request_queue_impl_qwqr::add_request(request_ptr& req) in add_request() 97 bool request_queue_impl_qwqr::cancel_request(request_ptr& req) in cancel_request() 156 request_ptr req = pthis->m_write_queue.front(); in worker() 183 request_ptr req = pthis->m_read_queue.front(); in worker()
|
H A D | disk_queued_file.cpp | 24 request_ptr disk_queued_file::aread( in aread() 30 request_ptr req(new serving_request(on_cmpl, this, buffer, pos, bytes, in aread() 38 request_ptr disk_queued_file::awrite( in awrite() 44 request_ptr req(new serving_request(on_cmpl, this, buffer, pos, bytes, in awrite()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/request/ |
H A D | start.c | 45 MPIR_Request *request_ptr = NULL; in MPI_Start() local 67 MPIR_Request_get_ptr(*request, request_ptr); in MPI_Start() 74 MPIR_Request_valid_ptr(request_ptr, mpi_errno); in MPI_Start() 77 MPIR_ERRTEST_PERSISTENT(request_ptr, mpi_errno); in MPI_Start() 78 MPIR_ERRTEST_PERSISTENT_ACTIVE(request_ptr, mpi_errno); in MPI_Start() 86 mpi_errno = MPID_Startall(1, &request_ptr); in MPI_Start()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/foxxll/mng/ |
H A D | write_pool.hpp | 50 request_ptr req; 55 busy_entry(block_type*& bl, request_ptr& r, bid_type& bi) in busy_entry() 58 operator request_ptr () { return req; } in operator request_ptr() 131 request_ptr write(block_type*& block, bid_type bid) in write() 146 request_ptr result = block->write(bid); in write() 206 std::pair<block_type*, request_ptr> steal_request(bid_type bid) in steal_request() 214 request_ptr req = i2->req; in steal_request() 219 return std::pair<block_type*, request_ptr>(blk, req); in steal_request() 224 return std::pair<block_type*, request_ptr>(nullptr, request_ptr()); in steal_request()
|
H A D | prefetch_pool.hpp | 64 using busy_entry = std::pair<block_type*, request_ptr>; 188 request_ptr req = block->read(bid); in hint() 235 request_ptr req = block->read(bid); in hint() 270 request_ptr find(bid_type bid) in find() 275 return request_ptr(); // invalid pointer in find() 283 request_ptr req = find(bid); in poll() 301 request_ptr read(block_type*& block, bid_type bid) in read() 316 request_ptr result = cache_el->second.second; in read() 321 request_ptr read(block_type*& block, bid_type bid, write_pool<block_type>& w_pool) in read() 332 request_ptr result = cache_el->second.second; in read()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/foxxll/io/ |
H A D | request_queue_impl_1q.cpp | 37 : public std::binary_function<request_ptr, request_ptr, bool> 40 const request_ptr& a, in operator ()() 41 const request_ptr& b) const in operator ()() 62 void request_queue_impl_1q::add_request(request_ptr& req) in add_request() 90 bool request_queue_impl_1q::cancel_request(request_ptr& req) in cancel_request() 134 request_ptr req = pthis->queue_.front(); in worker()
|
H A D | request_queue_impl_qwqr.cpp | 36 : public std::binary_function<request_ptr, request_ptr, bool> 39 const request_ptr& a, in operator ()() 40 const request_ptr& b) const in operator ()() 61 void request_queue_impl_qwqr::add_request(request_ptr& req) in add_request() 110 bool request_queue_impl_qwqr::cancel_request(request_ptr& req) in cancel_request() 169 request_ptr req = pthis->write_queue_.front(); in worker() 196 request_ptr req = pthis->read_queue_.front(); in worker()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/pt2pt/ |
H A D | irsend.c | 62 MPIR_Request *request_ptr = NULL; in MPI_Irsend() local 123 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__SEND); in MPI_Irsend() 124 MPIR_ERR_CHKANDSTMT((request_ptr) == NULL, mpi_errno, MPIX_ERR_NOREQ, goto fn_fail, in MPI_Irsend() 126 *request = request_ptr->handle; in MPI_Irsend() 133 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Irsend() 136 MPII_SENDQ_REMEMBER(request_ptr, dest, tag, comm_ptr->context_id); in MPI_Irsend() 142 *request = request_ptr->handle; in MPI_Irsend()
|
H A D | isend.c | 60 MPIR_Request *request_ptr = NULL; in MPI_Isend() local 121 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__SEND); in MPI_Isend() 122 MPIR_ERR_CHKANDSTMT(request_ptr == NULL, mpi_errno, MPIX_ERR_NOREQ, goto fn_fail, in MPI_Isend() 124 *request = request_ptr->handle; in MPI_Isend() 131 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Isend() 135 MPII_SENDQ_REMEMBER(request_ptr, dest, tag, comm_ptr->context_id); in MPI_Isend() 141 *request = request_ptr->handle; in MPI_Isend()
|
H A D | irecv.c | 61 MPIR_Request *request_ptr = NULL; in MPI_Irecv() local 122 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__RECV); in MPI_Irecv() 123 MPIR_ERR_CHKANDSTMT((request_ptr) == NULL, mpi_errno, MPIX_ERR_NOREQ, goto fn_fail, in MPI_Irecv() 125 MPIR_Status_set_procnull(&request_ptr->status); in MPI_Irecv() 126 *request = request_ptr->handle; in MPI_Irecv() 133 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Irecv() 138 *request = request_ptr->handle; in MPI_Irecv()
|
H A D | issend.c | 61 MPIR_Request *request_ptr = NULL; in MPI_Issend() local 122 request_ptr = MPIR_Request_create_complete(MPIR_REQUEST_KIND__SEND); in MPI_Issend() 123 MPIR_ERR_CHKANDSTMT((request_ptr) == NULL, mpi_errno, MPIX_ERR_NOREQ, goto fn_fail, in MPI_Issend() 125 *request = request_ptr->handle; in MPI_Issend() 132 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Issend() 135 MPII_SENDQ_REMEMBER(request_ptr, dest, tag, comm_ptr->context_id); in MPI_Issend() 141 *request = request_ptr->handle; in MPI_Issend()
|
H A D | recv.c | 67 MPIR_Request *request_ptr = NULL; in MPI_Recv() local 140 MPIR_CONTEXT_INTRA_PT2PT, status, &request_ptr); in MPI_Recv() 144 if (request_ptr == NULL) { in MPI_Recv() 148 mpi_errno = MPID_Wait(request_ptr, MPI_STATUS_IGNORE); in MPI_Recv() 152 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Recv() 153 MPIR_Request_extract_status(request_ptr, status); in MPI_Recv() 154 MPIR_Request_free(request_ptr); in MPI_Recv()
|
H A D | rsend.c | 57 MPIR_Request *request_ptr = NULL; in MPI_Rsend() local 123 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Rsend() 127 if (request_ptr == NULL) { in MPI_Rsend() 133 mpi_errno = MPID_Wait(request_ptr, MPI_STATUS_IGNORE); in MPI_Rsend() 136 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Rsend() 137 MPIR_Request_free(request_ptr); in MPI_Rsend()
|
H A D | ssend.c | 56 MPIR_Request *request_ptr = NULL; in MPI_Ssend() local 122 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Ssend() 126 if (request_ptr == NULL) { in MPI_Ssend() 132 mpi_errno = MPID_Wait(request_ptr, MPI_STATUS_IGNORE); in MPI_Ssend() 135 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Ssend() 136 MPIR_Request_free(request_ptr); in MPI_Ssend()
|
H A D | send.c | 62 MPIR_Request *request_ptr = NULL; in MPI_Send() local 128 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPI_Send() 132 if (request_ptr == NULL) { in MPI_Send() 136 mpi_errno = MPID_Wait(request_ptr, MPI_STATUS_IGNORE); in MPI_Send() 139 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Send() 140 MPIR_Request_free(request_ptr); in MPI_Send()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/init/ |
H A D | init_async.c | 52 MPIR_Request *request_ptr = NULL; in progress_fn() local 71 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in progress_fn() 73 request = request_ptr->handle; in progress_fn() 114 MPIR_Request *request_ptr = NULL; in MPIR_Finalize_async_thread() local 124 MPIR_CONTEXT_INTRA_PT2PT, &request_ptr); in MPIR_Finalize_async_thread() 126 request = request_ptr->handle; in MPIR_Finalize_async_thread()
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/ |
H A D | mpidpost.h | 203 MPL_STATIC_INLINE_PREFIX int MPID_Request_is_anysource(MPIR_Request * request_ptr) in MPID_Request_is_anysource() argument 207 if (request_ptr->kind == MPIR_REQUEST_KIND__RECV) in MPID_Request_is_anysource() 208 ret = request_ptr->dev.match.parts.rank == MPI_ANY_SOURCE; in MPID_Request_is_anysource() 231 MPL_STATIC_INLINE_PREFIX int MPID_Test(MPIR_Request * request_ptr, int *flag, MPI_Status * status) in MPID_Test() argument 233 return MPIR_Test_impl(request_ptr, flag, status); in MPID_Test() 262 MPL_STATIC_INLINE_PREFIX int MPID_Wait(MPIR_Request * request_ptr, MPI_Status * status) in MPID_Wait() argument 264 return MPIR_Wait_impl(request_ptr, status); in MPID_Wait()
|