/dports/net/mpich/mpich-3.4.3/src/mpi/request/ |
H A D | mpir_request.c | 70 switch (request_ptr->kind) { in MPIR_Request_completion_processing() 107 request_ptr->cc_ptr = &request_ptr->cc; in MPIR_Request_completion_processing() 150 request_ptr->cc_ptr = &request_ptr->cc; in MPIR_Request_completion_processing() 201 MPID_Cancel_recv(request_ptr); in MPIR_Request_handle_proc_failed() 220 switch (request_ptr->kind) { in MPIR_Request_get_error() 302 rc = (request_ptr->u.ureq.greq_fns->U.C.cancel_fn) (request_ptr->u.ureq. in MPIR_Grequest_cancel() 315 (request_ptr->u.ureq.greq_fns->U.F.cancel_fn) (request_ptr->u.ureq. in MPIR_Grequest_cancel() 352 rc = (request_ptr->u.ureq.greq_fns->U.C.query_fn) (request_ptr->u.ureq. in MPIR_Grequest_query() 367 (request_ptr->u.ureq.greq_fns->U.F.query_fn) (request_ptr->u.ureq. in MPIR_Grequest_query() 404 rc = (request_ptr->u.ureq.greq_fns->U.C.free_fn) (request_ptr->u.ureq. in MPIR_Grequest_free() [all …]
|
H A D | wait.c | 31 while (!MPIR_Request_is_complete(request_ptr)) { in MPIR_Wait_state() 53 MPIR_Assert(request_ptr != NULL); in MPIR_Wait_impl() 65 MPIR_Request *request_ptr = NULL; in MPIR_Wait() local 73 MPIR_Request_get_ptr(*request, request_ptr); in MPIR_Wait() 74 MPIR_Assert(request_ptr != NULL); in MPIR_Wait() 76 if (!MPIR_Request_is_complete(request_ptr)) { in MPIR_Wait() 101 MPIR_Request_free(request_ptr); in MPIR_Wait() 138 MPIR_Request *request_ptr = NULL; in MPI_Wait() local 169 MPIR_Request_get_ptr(*request, request_ptr); in MPI_Wait() 187 if (request_ptr) in MPI_Wait() [all …]
|
H A D | cancel.c | 27 int MPIR_Cancel(MPIR_Request * request_ptr) in MPIR_Cancel() argument 31 switch (request_ptr->kind) { in MPIR_Cancel() 34 mpi_errno = MPID_Cancel_send(request_ptr); in MPIR_Cancel() 41 mpi_errno = MPID_Cancel_recv(request_ptr); in MPIR_Cancel() 48 if (request_ptr->u.persist.real_request != NULL) { in MPIR_Cancel() 64 request_ptr->cc_ptr = request_ptr->u.persist.real_request->cc_ptr; in MPIR_Cancel() 98 MPIR_Grequest_cancel(request_ptr, MPIR_cc_is_complete(&request_ptr->cc)); in MPIR_Cancel() 154 MPIR_Request *request_ptr; in MPI_Cancel() local 163 MPIR_Request_get_ptr(*request, request_ptr); in MPI_Cancel() 171 MPIR_Request_valid_ptr(request_ptr, mpi_errno); in MPI_Cancel() [all …]
|
H A D | request_get_status.c | 55 MPIR_Request *request_ptr = NULL; in MPI_Request_get_status() local 88 MPIR_Request_get_ptr(request, request_ptr); in MPI_Request_get_status() 96 MPIR_Request_valid_ptr(request_ptr, mpi_errno); in MPI_Request_get_status() 106 if (!MPIR_Request_is_complete(request_ptr)) { in MPI_Request_get_status() 113 if (MPIR_Request_is_complete(request_ptr)) { in MPI_Request_get_status() 114 switch (request_ptr->kind) { in MPI_Request_get_status() 119 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Request_get_status() 125 MPIR_Request_extract_status(request_ptr, status); in MPI_Request_get_status() 126 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Request_get_status() 181 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Request_get_status() [all …]
|
H A D | test.c | 35 if (MPIR_Request_has_poll_fn(request_ptr)) { in MPIR_Test_state() 40 if (MPIR_Request_is_complete(request_ptr)) in MPIR_Test_state() 60 MPIR_Request *request_ptr = NULL; in MPIR_Test() local 69 MPIR_Request_get_ptr(*request, request_ptr); in MPIR_Test() 70 MPIR_Assert(request_ptr != NULL); in MPIR_Test() 72 mpi_errno = MPID_Test(request_ptr, flag, status); in MPIR_Test() 78 MPIR_Request_free(request_ptr); in MPIR_Test() 123 MPIR_Request *request_ptr = NULL; in MPI_Test() local 144 MPIR_Request_get_ptr(*request, request_ptr); in MPI_Test() 170 if (request_ptr) in MPI_Test() [all …]
|
H A D | request_free.c | 64 MPIR_Request *request_ptr = NULL; in MPI_Request_free() local 85 MPIR_Request_get_ptr(*request, request_ptr); in MPI_Request_free() 93 MPIR_Request_valid_ptr(request_ptr, mpi_errno); in MPI_Request_free() 105 switch (request_ptr->kind) { in MPI_Request_free() 108 MPII_SENDQ_FORGET(request_ptr); in MPI_Request_free() 119 MPID_Prequest_free_hook(request_ptr); in MPI_Request_free() 122 if (request_ptr->u.persist.real_request != NULL) { in MPI_Request_free() 136 MPID_Prequest_free_hook(request_ptr); in MPI_Request_free() 139 if (request_ptr->u.persist.real_request != NULL) { in MPI_Request_free() 147 mpi_errno = MPIR_Grequest_free(request_ptr); in MPI_Request_free() [all …]
|
H A D | greq_start.c | 88 MPIR_Object_set_ref(*request_ptr, 1); in MPIR_Grequest_start() 89 (*request_ptr)->cc_ptr = &(*request_ptr)->cc; in MPIR_Grequest_start() 90 MPIR_cc_set((*request_ptr)->cc_ptr, 1); in MPIR_Grequest_start() 91 (*request_ptr)->comm = NULL; in MPIR_Grequest_start() 95 (*request_ptr)->u.ureq.greq_fns->U.C.free_fn = free_fn; in MPIR_Grequest_start() 96 (*request_ptr)->u.ureq.greq_fns->U.C.query_fn = query_fn; in MPIR_Grequest_start() 97 (*request_ptr)->u.ureq.greq_fns->poll_fn = NULL; in MPIR_Grequest_start() 98 (*request_ptr)->u.ureq.greq_fns->wait_fn = NULL; in MPIR_Grequest_start() 105 MPIR_Request_add_ref((*request_ptr)); in MPIR_Grequest_start() 175 MPIR_Request *request_ptr; in MPI_Grequest_start() local [all …]
|
H A D | greq_complete.c | 32 void MPIR_Grequest_complete(MPIR_Request * request_ptr) in MPIR_Grequest_complete() argument 34 MPIR_Request_complete(request_ptr); in MPIR_Grequest_complete() 57 MPIR_Request *request_ptr; in MPI_Grequest_complete() local 77 MPIR_Request_get_ptr(request, request_ptr); in MPI_Grequest_complete() 84 MPIR_Request_valid_ptr(request_ptr, mpi_errno); in MPI_Grequest_complete() 85 if (request_ptr && request_ptr->kind != MPIR_REQUEST_KIND__GREQUEST) { in MPI_Grequest_complete() 99 MPIR_Grequest_complete(request_ptr); in MPI_Grequest_complete()
|
/dports/net/mpich2/mpich2-1.5/src/mpi/pt2pt/ |
H A D | mpir_request.c | 67 switch(request_ptr->kind) in MPIR_Request_complete() 77 MPIR_SENDQ_FORGET(request_ptr); in MPIR_Request_complete() 99 request_ptr->cc_ptr = &request_ptr->cc; in MPIR_Request_complete() 100 request_ptr->partner_request = NULL; in MPIR_Request_complete() 171 request_ptr->cc_ptr = &request_ptr->cc; in MPIR_Request_complete() 257 switch(request_ptr->kind) in MPIR_Request_get_error() 275 request_ptr->partner_request); in MPIR_Request_get_error() 318 &request_ptr->status); in MPIR_Request_get_error() 448 rc = (request_ptr->greq_fns->query_fn)(request_ptr->greq_fns->grequest_extra_state, in MPIR_Grequest_query() 449 &request_ptr->status); in MPIR_Grequest_query() [all …]
|
H A D | cancel.c | 31 int MPIR_Cancel_impl(MPID_Request *request_ptr) in MPIR_Cancel_impl() argument 35 switch (request_ptr->kind) in MPIR_Cancel_impl() 39 mpi_errno = MPID_Cancel_send(request_ptr); in MPIR_Cancel_impl() 46 mpi_errno = MPID_Cancel_recv(request_ptr); in MPIR_Cancel_impl() 53 if (request_ptr->partner_request != NULL) { in MPIR_Cancel_impl() 69 request_ptr->cc_ptr = request_ptr->partner_request->cc_ptr; in MPIR_Cancel_impl() 89 if (request_ptr->partner_request != NULL) { in MPIR_Cancel_impl() 100 mpi_errno = MPIR_Grequest_cancel(request_ptr, MPID_cc_is_complete(&request_ptr->cc)); in MPIR_Cancel_impl() 160 MPID_Request * request_ptr; in MPI_Cancel() local 169 MPID_Request_get_ptr( *request, request_ptr ); in MPI_Cancel() [all …]
|
H A D | request_get_status.c | 58 MPID_Request *request_ptr = NULL; in MPI_Request_get_status() local 91 MPID_Request_get_ptr( request, request_ptr ); in MPI_Request_get_status() 99 MPID_Request_valid_ptr( request_ptr, mpi_errno ); in MPI_Request_get_status() 108 if (!MPID_Request_is_complete(request_ptr)) { in MPI_Request_get_status() 114 if (MPID_Request_is_complete(request_ptr)) in MPI_Request_get_status() 116 switch(request_ptr->kind) in MPI_Request_get_status() 124 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Request_get_status() 131 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Request_get_status() 145 status->cancelled = request_ptr->status.cancelled; in MPI_Request_get_status() 203 mpi_errno = request_ptr->status.MPI_ERROR; in MPI_Request_get_status() [all …]
|
H A D | request_free.c | 68 MPID_Request *request_ptr = NULL; in MPI_Request_free() local 89 MPID_Request_get_ptr( *request, request_ptr ); in MPI_Request_free() 108 switch (request_ptr->kind) in MPI_Request_free() 112 MPIR_SENDQ_FORGET(request_ptr); in MPI_Request_free() 124 if (request_ptr->partner_request != NULL) in MPI_Request_free() 130 request_ptr->partner_request); in MPI_Request_free() 132 MPID_Request_release(request_ptr->partner_request); in MPI_Request_free() 142 if (request_ptr->partner_request != NULL) in MPI_Request_free() 151 mpi_errno = MPIR_Grequest_free(request_ptr); in MPI_Request_free() 160 "**request_invalid_kind %d", request_ptr->kind); in MPI_Request_free() [all …]
|
H A D | test.c | 34 MPID_Request *request_ptr = NULL; in MPIR_Test_impl() local 45 MPID_Request_get_ptr( *request, request_ptr ); in MPIR_Test_impl() 53 if (request_ptr->kind == MPID_UREQUEST && in MPIR_Test_impl() 54 request_ptr->greq_fns != NULL && in MPIR_Test_impl() 55 request_ptr->greq_fns->poll_fn != NULL) in MPIR_Test_impl() 57 … mpi_errno = (request_ptr->greq_fns->poll_fn)(request_ptr->greq_fns->grequest_extra_state, status); in MPIR_Test_impl() 61 if (MPID_Request_is_complete(request_ptr)) { in MPIR_Test_impl() 107 MPID_Request *request_ptr = NULL; in MPI_Test() local 127 MPID_Request_get_ptr( *request, request_ptr ); in MPI_Test() 137 MPID_Request_valid_ptr( request_ptr, mpi_errno ); in MPI_Test() [all …]
|
H A D | wait.c | 33 MPID_Request *request_ptr = NULL; in MPIR_Wait_impl() local 42 MPID_Request_get_ptr(*request, request_ptr); in MPIR_Wait_impl() 44 if (!MPID_Request_is_complete(request_ptr)) in MPIR_Wait_impl() 49 while (!MPID_Request_is_complete(request_ptr)) in MPIR_Wait_impl() 52 if (request_ptr->kind == MPID_UREQUEST && in MPIR_Wait_impl() 53 request_ptr->greq_fns->wait_fn != NULL) in MPIR_Wait_impl() 115 MPID_Request * request_ptr = NULL; in MPI_Wait() local 147 MPID_Request_get_ptr(*request, request_ptr); in MPI_Wait() 154 MPID_Request_valid_ptr( request_ptr, mpi_errno ); in MPI_Wait() 164 if (request_ptr) in MPI_Wait() [all …]
|
H A D | greq_start.c | 83 *request_ptr = MPID_Request_create(); in MPIR_Grequest_start_impl() 86 (*request_ptr)->kind = MPID_UREQUEST; in MPIR_Grequest_start_impl() 87 MPIU_Object_set_ref( *request_ptr, 1 ); in MPIR_Grequest_start_impl() 88 (*request_ptr)->cc_ptr = &(*request_ptr)->cc; in MPIR_Grequest_start_impl() 89 MPID_cc_set((*request_ptr)->cc_ptr, 1); in MPIR_Grequest_start_impl() 90 (*request_ptr)->comm = NULL; in MPIR_Grequest_start_impl() 91 (*request_ptr)->greq_fns = NULL; in MPIR_Grequest_start_impl() 96 (*request_ptr)->greq_fns->poll_fn = NULL; in MPIR_Grequest_start_impl() 97 (*request_ptr)->greq_fns->wait_fn = NULL; in MPIR_Grequest_start_impl() 173 MPID_Request *request_ptr; in MPI_Grequest_start() local [all …]
|
H A D | greq_complete.c | 34 void MPIR_Grequest_complete_impl(MPID_Request *request_ptr) in MPIR_Grequest_complete_impl() argument 38 MPID_Request_set_completed( request_ptr ); in MPIR_Grequest_complete_impl() 68 MPID_Request *request_ptr; in MPI_Grequest_complete() local 88 MPID_Request_get_ptr( request, request_ptr ); in MPI_Grequest_complete() 95 MPID_Request_valid_ptr(request_ptr,mpi_errno); in MPI_Grequest_complete() 96 if (request_ptr && request_ptr->kind != MPID_UREQUEST) { in MPI_Grequest_complete() 108 MPIR_Grequest_complete_impl(request_ptr); in MPI_Grequest_complete()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/common/fetch/ |
H A D | fetch_api_request_proto.cc | 47 request_ptr->mode = in DeserializeFetchRequestFromString() 50 request_ptr->request_context_type = in DeserializeFetchRequestFromString() 54 request_ptr->url = GURL(request_proto.url()); in DeserializeFetchRequestFromString() 55 request_ptr->method = request_proto.method(); in DeserializeFetchRequestFromString() 58 request_ptr->referrer = blink::mojom::Referrer::New( in DeserializeFetchRequestFromString() 62 request_ptr->is_reload = request_proto.is_reload(); in DeserializeFetchRequestFromString() 65 request_ptr->cache_mode = in DeserializeFetchRequestFromString() 67 request_ptr->redirect_mode = in DeserializeFetchRequestFromString() 70 request_ptr->integrity = request_proto.integrity(); in DeserializeFetchRequestFromString() 71 request_ptr->keepalive = request_proto.keepalive(); in DeserializeFetchRequestFromString() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/content/common/fetch/ |
H A D | fetch_api_request_proto.cc | 44 auto request_ptr = blink::mojom::FetchAPIRequest::New(); in DeserializeFetchRequestFromString() local 45 request_ptr->mode = in DeserializeFetchRequestFromString() 49 request_ptr->url = GURL(request_proto.url()); in DeserializeFetchRequestFromString() 50 request_ptr->method = request_proto.method(); in DeserializeFetchRequestFromString() 53 request_ptr->referrer = blink::mojom::Referrer::New( in DeserializeFetchRequestFromString() 57 request_ptr->is_reload = request_proto.is_reload(); in DeserializeFetchRequestFromString() 60 request_ptr->cache_mode = in DeserializeFetchRequestFromString() 62 request_ptr->redirect_mode = in DeserializeFetchRequestFromString() 65 request_ptr->integrity = request_proto.integrity(); in DeserializeFetchRequestFromString() 66 request_ptr->keepalive = request_proto.keepalive(); in DeserializeFetchRequestFromString() [all …]
|
/dports/devel/stxxl/stxxl-1.4.1/include/stxxl/bits/io/ |
H A D | request_operations.h | 37 (request_ptr(*reqs_begin))->wait(); in wait_all() 43 inline void wait_all(request_ptr req_array[], size_t count) in wait_all() 63 if ((request_ptr(*reqs_begin))->cancel()) in cancel_all() 79 if ((request_ptr(*reqs_begin))->poll()) in poll_any() 94 request_ptr* res = poll_any(req_array, req_array + count); in poll_any() 114 if ((request_ptr(*cur))->add_waiter(&sw)) in wait_any() 122 (request_ptr(*cur))->delete_waiter(&sw); in wait_any() 124 (request_ptr(*cur))->delete_waiter(&sw); in wait_any() 127 (request_ptr(*result))->check_errors(); in wait_any() 137 (request_ptr(*cur))->delete_waiter(&sw); in wait_any() [all …]
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/foxxll/io/ |
H A D | request_operations.hpp | 36 (request_ptr(*reqs_begin))->wait(); in wait_all() 62 if ((request_ptr(*reqs_begin))->cancel()) in cancel_all() 78 if ((request_ptr(*reqs_begin))->poll()) in poll_any() 94 request_ptr* res = poll_any(req_array, req_array + count); in poll_any() 114 if ((request_ptr(*cur))->add_waiter(&sw)) in wait_any() 122 (request_ptr(*cur))->delete_waiter(&sw); in wait_any() 124 (request_ptr(*cur))->delete_waiter(&sw); in wait_any() 127 (request_ptr(*result))->check_errors(); in wait_any() 137 (request_ptr(*cur))->delete_waiter(&sw); in wait_any() 138 if (result == reqs_end && (request_ptr(*cur))->poll()) in wait_any() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/google_apis/drive/ |
H A D | request_sender_unittest.cc | 145 TestRequest* request_ptr = request.get(); in TEST_F() local 147 request_ptr->GetWeakPtr(); in TEST_F() 156 request_ptr->FinishRequestWithSuccess(); in TEST_F() 209 TestRequest* request_ptr = request.get(); in TEST_F() local 211 request_ptr->GetWeakPtr(); in TEST_F() 221 request_ptr->FinishRequestWithSuccess(); in TEST_F() 233 request_ptr->GetWeakPtr(); in TEST_F() 242 request_ptr->passed_reauth_callback().Run(request_ptr); in TEST_F() 246 request_ptr->passed_reauth_callback().Run(request_ptr); in TEST_F() 250 request_ptr->passed_reauth_callback().Run(request_ptr); in TEST_F() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/google_apis/drive/ |
H A D | request_sender_unittest.cc | 145 TestRequest* request_ptr = request.get(); in TEST_F() local 147 request_ptr->GetWeakPtr(); in TEST_F() 156 request_ptr->FinishRequestWithSuccess(); in TEST_F() 209 TestRequest* request_ptr = request.get(); in TEST_F() local 211 request_ptr->GetWeakPtr(); in TEST_F() 221 request_ptr->FinishRequestWithSuccess(); in TEST_F() 233 request_ptr->GetWeakPtr(); in TEST_F() 242 request_ptr->passed_reauth_callback().Run(request_ptr); in TEST_F() 246 request_ptr->passed_reauth_callback().Run(request_ptr); in TEST_F() 250 request_ptr->passed_reauth_callback().Run(request_ptr); in TEST_F() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/ |
H A D | helper_fns.c | 62 request_ptr->status.MPI_TAG = 0; in MPIC_Wait() 110 MPIR_Request *request_ptr = NULL; in MPIC_Send() local 131 if (request_ptr) { in MPIC_Send() 145 if (request_ptr) in MPIC_Send() 164 MPIR_Request *request_ptr = NULL; in MPIC_Recv() local 189 if (request_ptr) { in MPIC_Recv() 214 if (request_ptr) in MPIC_Recv() 225 MPIR_Request *request_ptr = NULL; in MPIC_Ssend() local 255 if (request_ptr) { in MPIC_Ssend() 269 if (request_ptr) in MPIC_Ssend() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/include/ |
H A D | mpir_request.h | 527 if (request_ptr->kind == MPIR_REQUEST_KIND__SEND) { in MPIR_Request_completion_processing_fastpath() 529 MPII_SENDQ_FORGET(request_ptr); in MPIR_Request_completion_processing_fastpath() 534 mpi_errno = request_ptr->status.MPI_ERROR; in MPIR_Request_completion_processing_fastpath() 535 MPIR_Request_free(request_ptr); in MPIR_Request_completion_processing_fastpath() 567 int MPIR_Grequest_query(MPIR_Request * request_ptr); 568 int MPIR_Grequest_free(MPIR_Request * request_ptr); 570 void MPIR_Grequest_complete(MPIR_Request * request_ptr); 586 request_ptr->u.ureq.greq_fns != NULL && request_ptr->u.ureq.greq_fns->poll_fn != NULL); in MPIR_Request_has_poll_fn() 592 request_ptr->u.ureq.greq_fns != NULL && request_ptr->u.ureq.greq_fns->wait_fn != NULL); in MPIR_Request_has_wait_fn() 599 mpi_errno = (request_ptr->u.ureq.greq_fns->wait_fn) (1, in MPIR_Grequest_wait() [all …]
|
/dports/devel/cgdb/cgdb-0.8.0/lib/tgdb/ |
H A D | tgdb.cpp | 660 tgdb_request_ptr request_ptr; in tgdb_issue_request() local 662 request_ptr->header = type; in tgdb_issue_request() 705 if (!request_ptr) in tgdb_request_destroy() 724 free(request_ptr); in tgdb_request_destroy() 725 request_ptr = NULL; in tgdb_request_destroy() 1258 tgdb_request_ptr request_ptr; in tgdb_request_inferiors_source_files() local 1269 tgdb_request_ptr request_ptr; in tgdb_request_current_location() local 1280 tgdb_request_ptr request_ptr; in tgdb_request_breakpoints() local 1292 tgdb_request_ptr request_ptr; in tgdb_request_run_debugger_command() local 1306 tgdb_request_ptr request_ptr; in tgdb_request_modify_breakpoint() local [all …]
|