Home
last modified time | relevance | path

Searched refs:request_ptr (Results 26 – 50 of 252) sorted by relevance

1234567891011

/dports/net/mpich2/mpich2-1.5/src/mpi/coll/
H A Dhelper_fns.c51 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 Drecv.c70 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 Dstart.c49 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 Dsend.c66 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 Drsend.c61 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 Dssend.c60 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 Dwrite_pool.h42 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 Drequest_queue_impl_1q.cpp34 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 Drequest_queue_impl_qwqr.cpp33 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 Ddisk_queued_file.cpp24 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 Dstart.c45 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 Dwrite_pool.hpp50 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 Dprefetch_pool.hpp64 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 Drequest_queue_impl_1q.cpp37 : 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 Drequest_queue_impl_qwqr.cpp36 : 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 Dirsend.c62 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 Disend.c60 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 Direcv.c61 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 Dissend.c61 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 Drecv.c67 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 Drsend.c57 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 Dssend.c56 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 Dsend.c62 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 Dinit_async.c52 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 Dmpidpost.h203 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()

1234567891011