Home
last modified time | relevance | path

Searched refs:subreqs (Results 1 – 21 of 21) sorted by relevance

/dports/net/samba412/samba-4.12.15/source3/winbindd/
H A Dwb_seqnums.c30 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 Dcldap.c40 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 Dcomm_request.c32 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 Dcomm_request.h34 ompi_request_t *subreqs[], int subreq_count);
H A Dcomm_cid.c706 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 Dcomm_request.c32 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 Dcomm_request.h34 ompi_request_t *subreqs[], int subreq_count);
H A Dcomm_cid.c706 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 Drawtrans.c90 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 Dclitransport.c394 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 Drawrequest.c262 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 Drawnotify.c112 if (oldreq->subreqs[0] == NULL) { in smb_raw_ntcancel()
116 ok = tevent_req_cancel(oldreq->subreqs[0]); in smb_raw_ntcancel()
H A Dlibcliraw.h213 struct tevent_req *subreqs[2]; member
/dports/net/mpich/mpich-3.4.3/modules/yaksa/src/backend/src/
H A Dyaksuri_progress.c159 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 Dyaksuri.h93 yaksuri_subreq_s *subreqs; member
H A Dyaksur_hooks.c217 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 Dmrail_rma.c116 &req->subreqs[req->pending_subreq]); in mrail_post_req()
222 subreq = &req->subreqs[i]; in mrail_prepare_rma_subreqs()
H A Dmrail.h408 struct mrail_subreq subreqs[]; member
/dports/net/samba412/samba-4.12.15/source3/libsmb/
H A Dnamequery.c1626 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 Dcore.c3540 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 Dcore.c3984 int redirects = 0, subreqs = 0; in ap_is_recursion_limit_exceeded() local
4015 if (++subreqs >= slimit) { in ap_is_recursion_limit_exceeded()