Home
last modified time | relevance | path

Searched refs:request_ptr (Results 1 – 25 of 252) sorted by relevance

1234567891011

/dports/net/mpich/mpich-3.4.3/src/mpi/request/
H A Dmpir_request.c70 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 Dwait.c31 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 Dcancel.c27 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 Drequest_get_status.c55 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 Dtest.c35 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 Drequest_free.c64 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 Dgreq_start.c88 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 Dgreq_complete.c32 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 Dmpir_request.c67 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 Dcancel.c31 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 Drequest_get_status.c58 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 Drequest_free.c68 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 Dtest.c34 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 Dwait.c33 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 Dgreq_start.c83 *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 Dgreq_complete.c34 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 Dfetch_api_request_proto.cc47 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 Dfetch_api_request_proto.cc44 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 Drequest_operations.h37 (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 Drequest_operations.hpp36 (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 Drequest_sender_unittest.cc145 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 Drequest_sender_unittest.cc145 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 Dhelper_fns.c62 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 Dmpir_request.h527 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 Dtgdb.cpp660 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 …]

1234567891011