/dports/net/samba412/samba-4.12.15/source3/winbindd/ |
H A D | wb_seqnums.c | 30 struct tevent_req **subreqs; in wb_seqnum_send() 57 state->subreqs = talloc_array(state, struct tevent_req *, 64 if ((state->subreqs == NULL) || (state->domains == NULL) || 74 state->subreqs[i] = wb_seqnum_send(state->subreqs, ev, domain); 75 if (tevent_req_nomem(state->subreqs[i], req)) { 77 TALLOC_FREE(state->subreqs); 80 tevent_req_set_callback(state->subreqs[i], wb_seqnums_done, 100 if (subreq == state->subreqs[i]) { 107 state->subreqs[i] = NULL;
|
/dports/net/samba412/samba-4.12.15/source3/libads/ |
H A D | cldap.c | 40 struct tevent_req **subreqs; member 123 state->subreqs = talloc_zero_array(state, in cldap_multi_netlogon_send() 126 if (tevent_req_nomem(state->subreqs, req)) { in cldap_multi_netlogon_send() 188 state->subreqs[i] = cldap_netlogon_send(state->subreqs, in cldap_multi_netlogon_send() 192 if (tevent_req_nomem(state->subreqs[i], req)) { in cldap_multi_netlogon_send() 196 state->subreqs[i], cldap_multi_netlogon_done, req); in cldap_multi_netlogon_send() 227 if (state->subreqs[i] == subreq) { in cldap_multi_netlogon_done() 238 state->subreqs[i] = NULL; in cldap_multi_netlogon_done() 279 subreq = cldap_netlogon_send(state->subreqs, in cldap_multi_netlogon_next() 287 state->subreqs[state->num_sent] = subreq; in cldap_multi_netlogon_next()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/communicator/ |
H A D | comm_request.c | 32 ompi_request_t *subreqs[OMPI_COMM_REQUEST_MAX_SUBREQ]; member 72 ompi_request_t *subreqs[], int subreq_count) in ompi_comm_request_schedule_append() argument 89 request_item->subreqs[i] = subreqs[i]; in ompi_comm_request_schedule_append() 120 ompi_request_t *subreq = request_item->subreqs[request_item->subreq_count-1]; in ompi_comm_request_progress() 187 ompi_request_cancel (item->subreqs[i]); in ompi_comm_request_cancel()
|
H A D | comm_request.h | 34 ompi_request_t *subreqs[], int subreq_count);
|
H A D | comm_cid.c | 706 ompi_request_t *subreqs[2]; in ompi_comm_allreduce_inter_leader_exchange() local 712 intercomm, subreqs)); in ompi_comm_allreduce_inter_leader_exchange() 718 MCA_PML_BASE_SEND_STANDARD, intercomm, subreqs + 1)); in ompi_comm_allreduce_inter_leader_exchange() 723 …n ompi_comm_request_schedule_append (request, ompi_comm_allreduce_inter_leader_reduce, subreqs, 2); in ompi_comm_allreduce_inter_leader_exchange()
|
/dports/net/openmpi/openmpi-4.1.1/ompi/communicator/ |
H A D | comm_request.c | 32 ompi_request_t *subreqs[OMPI_COMM_REQUEST_MAX_SUBREQ]; member 72 ompi_request_t *subreqs[], int subreq_count) in ompi_comm_request_schedule_append() argument 89 request_item->subreqs[i] = subreqs[i]; in ompi_comm_request_schedule_append() 121 ompi_request_t *subreq = request_item->subreqs[request_item->subreq_count-1]; in ompi_comm_request_progress() 189 ompi_request_cancel (item->subreqs[i]); in ompi_comm_request_cancel()
|
H A D | comm_request.h | 34 ompi_request_t *subreqs[], int subreq_count);
|
H A D | comm_cid.c | 706 ompi_request_t *subreqs[2]; in ompi_comm_allreduce_inter_leader_exchange() local 712 intercomm, subreqs)); in ompi_comm_allreduce_inter_leader_exchange() 718 MCA_PML_BASE_SEND_STANDARD, intercomm, subreqs + 1)); in ompi_comm_allreduce_inter_leader_exchange() 723 …n ompi_comm_request_schedule_append (request, ompi_comm_allreduce_inter_leader_reduce, subreqs, 2); in ompi_comm_allreduce_inter_leader_exchange()
|
/dports/net/samba412/samba-4.12.15/source4/libcli/raw/ |
H A D | rawtrans.c | 90 req->subreqs[0] = smb1cli_trans_send(req, in smb_raw_trans_backend_send() 116 if (req->subreqs[0] == NULL) { in smb_raw_trans_backend_send() 120 tevent_req_set_callback(req->subreqs[0], in smb_raw_trans_backend_send() 141 req->status = smb1cli_trans_recv(req->subreqs[0], req, in smb_raw_trans_backend_done() 152 TALLOC_FREE(req->subreqs[0]); in smb_raw_trans_backend_done() 319 req->subreqs[0] = smb1cli_trans_send(req, in smb_raw_nttrans_send() 345 if (req->subreqs[0] == NULL) { in smb_raw_nttrans_send() 349 tevent_req_set_callback(req->subreqs[0], in smb_raw_nttrans_send() 369 req->status = smb1cli_trans_recv(req->subreqs[0], req, in smb_raw_nttrans_done() 380 TALLOC_FREE(req->subreqs[0]); in smb_raw_nttrans_done()
|
H A D | clitransport.c | 394 for (i = 0; i < ARRAY_SIZE(req->subreqs); i++) { in smbcli_transport_send() 395 if (req->subreqs[i] == NULL) { in smbcli_transport_send() 396 req->subreqs[i] = subreq; in smbcli_transport_send() 399 if (req->subreqs[i] == NULL) { in smbcli_transport_send() 403 if (!tevent_req_is_in_progress(req->subreqs[i])) { in smbcli_transport_send() 412 tevent_req_set_callback(req->subreqs[0], smbcli_request_done, req); in smbcli_transport_send() 414 status = smb1cli_req_chain_submit(req->subreqs, num_subreqs); in smbcli_transport_send() 438 req->status = smb1cli_req_recv(req->subreqs[0], req, in smbcli_request_done() 449 TALLOC_FREE(req->subreqs[0]); in smbcli_request_done()
|
H A D | rawrequest.c | 262 if (req->subreqs[0] != NULL) { in smbcli_chained_request_setup() 265 if (req->subreqs[1] != NULL) { in smbcli_chained_request_setup() 269 req->subreqs[0] = smbcli_transport_setup_subreq(req); in smbcli_chained_request_setup() 270 if (req->subreqs[0] == NULL) { in smbcli_chained_request_setup() 274 wct_ofs = smb1cli_req_wct_ofs(req->subreqs, 1); in smbcli_chained_request_setup() 341 if (req->subreqs[0] != NULL) { in smbcli_chained_advance() 344 if (req->subreqs[1] == NULL) { in smbcli_chained_advance() 348 req->status = smb1cli_req_recv(req->subreqs[1], req, in smbcli_chained_advance() 359 TALLOC_FREE(req->subreqs[1]); in smbcli_chained_advance()
|
H A D | rawnotify.c | 112 if (oldreq->subreqs[0] == NULL) { in smb_raw_ntcancel() 116 ok = tevent_req_cancel(oldreq->subreqs[0]); in smb_raw_ntcancel()
|
H A D | libcliraw.h | 213 struct tevent_req *subreqs[2]; member
|
/dports/net/mpich/mpich-3.4.3/modules/yaksa/src/backend/src/ |
H A D | yaksuri_progress.c | 159 DL_DELETE(reqpriv->subreqs, subreq); in simple_release() 163 if (reqpriv->subreqs == NULL) { in simple_release() 1009 DL_APPEND(reqpriv->subreqs, subreq); in yaksuri_progress_enqueue() 1051 assert(reqpriv->subreqs); in yaksuri_progress_poke() 1054 DL_FOREACH_SAFE(reqpriv->subreqs, subreq, tmp2) { in yaksuri_progress_poke() 1063 DL_DELETE(reqpriv->subreqs, subreq); in yaksuri_progress_poke() 1065 if (reqpriv->subreqs == NULL) { in yaksuri_progress_poke() 1091 assert(reqpriv->subreqs); in yaksuri_progress_poke() 1094 DL_FOREACH_SAFE(reqpriv->subreqs, subreq, tmp2) { in yaksuri_progress_poke()
|
H A D | yaksuri.h | 93 yaksuri_subreq_s *subreqs; member
|
H A D | yaksur_hooks.c | 217 reqpriv->subreqs = NULL; in yaksur_request_create_hook() 227 assert(reqpriv->subreqs == NULL); in yaksur_request_free_hook()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/mrail/src/ |
H A D | mrail_rma.c | 116 &req->subreqs[req->pending_subreq]); in mrail_post_req() 222 subreq = &req->subreqs[i]; in mrail_prepare_rma_subreqs()
|
H A D | mrail.h | 408 struct mrail_subreq subreqs[]; member
|
/dports/net/samba412/samba-4.12.15/source3/libsmb/ |
H A D | namequery.c | 1626 struct tevent_req **subreqs; member 1668 state->subreqs = talloc_zero_array( in name_queries_send() 1670 if (tevent_req_nomem(state->subreqs, req)) { in name_queries_send() 1676 state->subreqs, state->ev, name, name_type, bcast, recurse, in name_queries_send() 1688 state->subreqs[state->num_sent] = subreq; in name_queries_send() 1716 if (state->subreqs[i] == subreq) { in name_queries_done() 1724 TALLOC_FREE(state->subreqs[i]); in name_queries_done() 1756 state->subreqs, state->ev, in name_queries_next() 1768 state->subreqs[state->num_sent] = subreq; in name_queries_next()
|
/dports/www/htdigest/httpd-2.4.6/server/ |
H A D | core.c | 3540 int redirects = 0, subreqs = 0; in ap_is_recursion_limit_exceeded() local 3571 if (++subreqs >= slimit) { in ap_is_recursion_limit_exceeded()
|
/dports/www/apache24/httpd-2.4.53/server/ |
H A D | core.c | 3984 int redirects = 0, subreqs = 0; in ap_is_recursion_limit_exceeded() local 4015 if (++subreqs >= slimit) { in ap_is_recursion_limit_exceeded()
|