Home
last modified time | relevance | path

Searched refs:req_recv (Results 1 – 25 of 28) sorted by relevance

12

/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/pml/ob1/
H A Dpml_ob1_irecv.c70 recvreq->req_recv.req_base.req_pml_complete = true; in mca_pml_ob1_irecv_init()
131 &(recvreq->req_recv.req_base), in mca_pml_ob1_recv()
153 if (recvreq->req_recv.req_base.req_pml_complete) { in mca_pml_ob1_recv()
197 seq = recvreq->req_recv.req_base.req_sequence; in mca_pml_ob1_imrecv()
208 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_imrecv()
229 MCA_PML_BASE_RECV_START(&recvreq->req_recv); in mca_pml_ob1_imrecv()
232 recvreq->req_recv.req_base.req_sequence = seq; in mca_pml_ob1_imrecv()
290 seq = recvreq->req_recv.req_base.req_sequence; in mca_pml_ob1_mrecv()
301 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_mrecv()
321 MCA_PML_BASE_RECV_START(&recvreq->req_recv); in mca_pml_ob1_mrecv()
[all …]
H A Dpml_ob1_iprobe.c36 recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; in mca_pml_ob1_iprobe()
37 recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_IPROBE; in mca_pml_ob1_iprobe()
42 if( REQUEST_COMPLETE( &(recvreq.req_recv.req_base.req_ompi)) ) { in mca_pml_ob1_iprobe()
52 MCA_PML_BASE_RECV_REQUEST_FINI( &recvreq.req_recv ); in mca_pml_ob1_iprobe()
66 recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; in mca_pml_ob1_probe()
67 recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_PROBE; in mca_pml_ob1_probe()
73 rc = recvreq.req_recv.req_base.req_ompi.req_status.MPI_ERROR; in mca_pml_ob1_probe()
75 *status = recvreq.req_recv.req_base.req_ompi.req_status; in mca_pml_ob1_probe()
78 MCA_PML_BASE_RECV_REQUEST_FINI( &recvreq.req_recv ); in mca_pml_ob1_probe()
102 recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_IMPROBE; in mca_pml_ob1_improbe()
[all …]
H A Dpml_ob1_recvreq.h42 mca_pml_base_recv_request_t req_recv; member
133 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_recv_request_fini()
161 if(false == recvreq->req_recv.req_base.req_pml_complete){ in recv_request_pml_complete()
163 if(recvreq->req_recv.req_bytes_packed > 0) { in recv_request_pml_complete()
191 recvreq->req_recv.req_bytes_packed; in recv_request_pml_complete()
226 if( req->req_recv.req_base.req_datatype->super.size | req->req_recv.req_base.req_count ) { in prepare_recv_req_converter()
229 &(req->req_recv.req_base.req_datatype->super), in prepare_recv_req_converter()
230 req->req_recv.req_base.req_count, in prepare_recv_req_converter()
231 req->req_recv.req_base.req_addr, in prepare_recv_req_converter()
233 &req->req_recv.req_base.req_convertor); in prepare_recv_req_converter()
[all …]
H A Dpml_ob1_recvreq.c73 assert (false == recvreq->req_recv.req_base.req_free_called); in mca_pml_ob1_recv_request_free()
75 recvreq->req_recv.req_base.req_free_called = true; in mca_pml_ob1_recv_request_free()
79 if( true == recvreq->req_recv.req_base.req_pml_complete ) { in mca_pml_ob1_recv_request_free()
122 request->req_recv.req_base.req_pml_complete = true; in mca_pml_ob1_recv_request_cancel()
136 request->req_recv.req_base.req_addr, in mca_pml_ob1_recv_request_cancel()
137 request->req_recv.req_base.req_count, in mca_pml_ob1_recv_request_cancel()
855 recvreq->req_recv.req_bytes_packed = bytes_received; in mca_pml_ob1_recv_request_progress_match()
1079 int tag = req->req_recv.req_base.req_tag; in recv_req_match_specific_proc()
1167 MCA_PML_BASE_RECV_START(&req->req_recv); in mca_pml_ob1_recv_req_start()
1197 req->req_recv.req_base.req_proc = proc->ompi_proc; in mca_pml_ob1_recv_req_start()
[all …]
H A Dpml_ob1_recvfrag.c437 match->req_recv.req_base.req_addr, in mca_pml_ob1_recv_frag_callback_match()
461 match->req_recv.req_base.req_addr, in mca_pml_ob1_recv_frag_callback_match()
551 sendreq->req_recv = hdr->hdr_ack.hdr_dst_req; in mca_pml_ob1_recv_frag_callback_ack()
716 wild_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; in match_incomming()
718 specific_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; in match_incomming()
737 req_tag = (*match)->req_recv.req_base.req_tag; in match_incomming()
741 &((*match)->req_recv.req_base), PERUSE_RECV); in match_incomming()
760 int req_tag = recv_req->req_recv.req_base.req_tag; in match_incomming_no_any_source()
765 &(recv_req->req_recv.req_base), PERUSE_RECV); in match_incomming_no_any_source()
792 match->req_recv.req_base.req_proc = proc->ompi_proc; in match_one()
[all …]
H A Dpml_ob1_cuda.c160 …mca_bml_base_endpoint_t* bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_… in mca_pml_ob1_cuda_need_buffers()
170 if ((recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) && in mca_pml_ob1_cuda_need_buffers()
172 recvreq->req_recv.req_base.req_convertor.flags &= ~CONVERTOR_CUDA; in mca_pml_ob1_cuda_need_buffers()
173 if(opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == true) { in mca_pml_ob1_cuda_need_buffers()
174 recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; in mca_pml_ob1_cuda_need_buffers()
177 recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; in mca_pml_ob1_cuda_need_buffers()
H A Dpml_ob1_sendreq.h48 opal_ptr_t req_recv; member
157 (sendreq)->req_recv.pval = NULL; \
H A Dpml_ob1_sendreq.c1023 sendreq->req_recv.lval); in mca_pml_ob1_send_request_schedule_once()
1105 if (NULL != sendreq->req_recv.pval) in mca_pml_ob1_send_request_put_frag_failed()
1209 sendreq->req_recv.pval = hdr->hdr_recv_req.pval; in mca_pml_ob1_send_request_put()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/pml/ob1/
H A Dpml_ob1_irecv.c70 recvreq->req_recv.req_base.req_pml_complete = true; in mca_pml_ob1_irecv_init()
131 &(recvreq->req_recv.req_base), in mca_pml_ob1_recv()
153 if (recvreq->req_recv.req_base.req_pml_complete) { in mca_pml_ob1_recv()
197 seq = recvreq->req_recv.req_base.req_sequence; in mca_pml_ob1_imrecv()
208 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_imrecv()
229 MCA_PML_BASE_RECV_START(&recvreq->req_recv); in mca_pml_ob1_imrecv()
232 recvreq->req_recv.req_base.req_sequence = seq; in mca_pml_ob1_imrecv()
290 seq = recvreq->req_recv.req_base.req_sequence; in mca_pml_ob1_mrecv()
301 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_mrecv()
321 MCA_PML_BASE_RECV_START(&recvreq->req_recv); in mca_pml_ob1_mrecv()
[all …]
H A Dpml_ob1_iprobe.c36 recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; in mca_pml_ob1_iprobe()
37 recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_IPROBE; in mca_pml_ob1_iprobe()
42 if( REQUEST_COMPLETE( &(recvreq.req_recv.req_base.req_ompi)) ) { in mca_pml_ob1_iprobe()
52 MCA_PML_BASE_RECV_REQUEST_FINI( &recvreq.req_recv ); in mca_pml_ob1_iprobe()
66 recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; in mca_pml_ob1_probe()
67 recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_PROBE; in mca_pml_ob1_probe()
73 rc = recvreq.req_recv.req_base.req_ompi.req_status.MPI_ERROR; in mca_pml_ob1_probe()
75 *status = recvreq.req_recv.req_base.req_ompi.req_status; in mca_pml_ob1_probe()
78 MCA_PML_BASE_RECV_REQUEST_FINI( &recvreq.req_recv ); in mca_pml_ob1_probe()
102 recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_IMPROBE; in mca_pml_ob1_improbe()
[all …]
H A Dpml_ob1_recvreq.c74 assert (false == recvreq->req_recv.req_base.req_free_called); in mca_pml_ob1_recv_request_free()
76 recvreq->req_recv.req_base.req_free_called = true; in mca_pml_ob1_recv_request_free()
80 if( true == recvreq->req_recv.req_base.req_pml_complete ) { in mca_pml_ob1_recv_request_free()
123 request->req_recv.req_base.req_pml_complete = true; in mca_pml_ob1_recv_request_cancel()
137 request->req_recv.req_base.req_addr, in mca_pml_ob1_recv_request_cancel()
138 request->req_recv.req_base.req_count, in mca_pml_ob1_recv_request_cancel()
884 recvreq->req_recv.req_bytes_packed = bytes_received; in mca_pml_ob1_recv_request_progress_match()
1110 int tag = req->req_recv.req_base.req_tag; in recv_req_match_specific_proc()
1198 MCA_PML_BASE_RECV_START(&req->req_recv); in mca_pml_ob1_recv_req_start()
1228 req->req_recv.req_base.req_proc = proc->ompi_proc; in mca_pml_ob1_recv_req_start()
[all …]
H A Dpml_ob1_recvreq.h42 mca_pml_base_recv_request_t req_recv; member
133 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_recv_request_fini()
161 if(false == recvreq->req_recv.req_base.req_pml_complete){ in recv_request_pml_complete()
163 if(recvreq->req_recv.req_bytes_packed > 0) { in recv_request_pml_complete()
191 recvreq->req_recv.req_bytes_packed; in recv_request_pml_complete()
226 if( req->req_recv.req_base.req_datatype->super.size | req->req_recv.req_base.req_count ) { in prepare_recv_req_converter()
229 &(req->req_recv.req_base.req_datatype->super), in prepare_recv_req_converter()
230 req->req_recv.req_base.req_count, in prepare_recv_req_converter()
231 req->req_recv.req_base.req_addr, in prepare_recv_req_converter()
233 &req->req_recv.req_base.req_convertor); in prepare_recv_req_converter()
[all …]
H A Dpml_ob1_recvfrag.c439 match->req_recv.req_base.req_addr, in mca_pml_ob1_recv_frag_callback_match()
465 match->req_recv.req_base.req_addr, in mca_pml_ob1_recv_frag_callback_match()
555 sendreq->req_recv = hdr->hdr_ack.hdr_dst_req; in mca_pml_ob1_recv_frag_callback_ack()
716 wild_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; in match_incomming()
718 specific_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; in match_incomming()
737 req_tag = (*match)->req_recv.req_base.req_tag; in match_incomming()
741 &((*match)->req_recv.req_base), PERUSE_RECV); in match_incomming()
760 int req_tag = recv_req->req_recv.req_base.req_tag; in match_incomming_no_any_source()
765 &(recv_req->req_recv.req_base), PERUSE_RECV); in match_incomming_no_any_source()
797 match->req_recv.req_base.req_proc = proc->ompi_proc; in match_one()
[all …]
H A Dpml_ob1_cuda.c160 …mca_bml_base_endpoint_t* bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_… in mca_pml_ob1_cuda_need_buffers()
170 if ((recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) && in mca_pml_ob1_cuda_need_buffers()
172 recvreq->req_recv.req_base.req_convertor.flags &= ~CONVERTOR_CUDA; in mca_pml_ob1_cuda_need_buffers()
173 if(opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == true) { in mca_pml_ob1_cuda_need_buffers()
174 recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; in mca_pml_ob1_cuda_need_buffers()
177 recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; in mca_pml_ob1_cuda_need_buffers()
H A Dpml_ob1_sendreq.h48 opal_ptr_t req_recv; member
157 (sendreq)->req_recv.pval = NULL; \
H A Dpml_ob1_sendreq.c1041 sendreq->req_recv.lval); in mca_pml_ob1_send_request_schedule_once()
1123 if (NULL != sendreq->req_recv.pval) in mca_pml_ob1_send_request_put_frag_failed()
1231 sendreq->req_recv.pval = hdr->hdr_recv_req.pval; in mca_pml_ob1_send_request_put()
/dports/sysutils/busybox/busybox-1.26.2/networking/
H A Darping.c73 unsigned req_recv; member
89 #define req_recv (G.req_recv ) macro
146 req_recv, brd_recv); in finish()
276 req_recv++; in recv_pack()
/dports/science/berkeleygw/BGW-2.0.0/Epsilon/
H A Dgenwf_eps.f90549 integer, allocatable :: req_send(:), req_recv(:) local
614 SAFE_ALLOCATE(req_recv, (cwfn%nband))
629 ib, MPI_COMM_WORLD, req_recv(recv_cnt), mpierr )
647 call MPI_Waitall(recv_cnt, req_recv, MPI_STATUSES_IGNORE, mpierr)
699 ib, MPI_COMM_WORLD, req_recv(ib_loc), mpierr )
704 ib, MPI_COMM_WORLD, req_recv(peinf%nvownactual+ib_loc), mpierr )
733 call MPI_Waitall(recv_cnt, req_recv, MPI_STATUSES_IGNORE, mpierr)
744 SAFE_DEALLOCATE(req_recv)
/dports/net-mgmt/resource-agents/resource-agents-4.9.0/tools/
H A Dsend_arp.linux.c116 int received, brd_recv, req_recv; variable
376 if (brd_recv || req_recv) { in finish()
378 if (req_recv) in finish()
379 printf("%d request(s)", req_recv); in finish()
382 req_recv ? ", " : "", in finish()
532 req_recv++; in recv_pack()
/dports/science/cp2k/cp2k-2e995eec7fd208c8a72d9544807bd8b8ba8cd1cc/src/
H A Dmixed_cdft_methods.F3139 CALL mp_waitall(req_recv)
3140 DEALLOCATE (req_recv)
3669 ALLOCATE (req_recv(3*nbuffs))
3891 IF (ASSOCIATED(req_recv)) &
4152 index = SIZE(req_recv)
4153 req_total(1:index) = req_recv
4179 DEALLOCATE (req_send, req_recv)
4203 CALL mp_waitall(req_recv)
4204 DEALLOCATE (req_recv)
4254 IF (ASSOCIATED(req_recv)) &
[all …]
/dports/science/cp2k-data/cp2k-7.1.0/src/
H A Dmixed_cdft_methods.F3131 CALL mp_waitall(req_recv)
3132 DEALLOCATE (req_recv)
3661 ALLOCATE (req_recv(3*nbuffs))
3883 IF (ASSOCIATED(req_recv)) &
4144 index = SIZE(req_recv)
4145 req_total(1:index) = req_recv
4171 DEALLOCATE (req_send, req_recv)
4195 CALL mp_waitall(req_recv)
4196 DEALLOCATE (req_recv)
4246 IF (ASSOCIATED(req_recv)) &
[all …]
/dports/audio/re/re-0.5.8/src/http/
H A Dclient.c231 static int req_recv(struct http_req *req, struct mbuf *mb, bool *last) in req_recv() function
313 err = req_recv(req, mb, &last); in recv_handler()
366 err = req_recv(req, req->mb, &last); in recv_handler()
/dports/science/ascent/ascent-0.7.1-66-gbcf2742a/src/examples/proxies/cloverleaf3d-ref/
H A Dclover.F90746 INTEGER :: req_send, req_recv local
754 ,MPI_COMM_WORLD,req_recv,err)
1366 INTEGER :: req_send, req_recv local
1374 MPI_COMM_WORLD,req_recv,err)
1982 INTEGER :: req_send, req_recv local
2599 INTEGER :: req_send, req_recv local
2607 ,MPI_COMM_WORLD,req_recv,err)
3215 INTEGER :: req_send, req_recv local
3223 MPI_COMM_WORLD,req_recv,err)
3831 INTEGER :: req_send, req_recv local
[all …]
/dports/science/berkeleygw/BGW-2.0.0/Sigma/
H A Depscopy.f90940 integer, allocatable :: req_send(:), req_recv(:) local
1468 SAFE_ALLOCATE(req_recv, (2 * Nbuf_recv))
1608 … MPI_COMPLEX_DPC, buf_recv(imsg_recv)%proc, tag, MPI_COMM_WORLD, req_recv((imsg_recv-1)*2+1), &
1612 … MPI_INTEGER, buf_recv(imsg_recv)%proc, tag, MPI_COMM_WORLD, req_recv(imsg_recv*2), &
1644 CALL MPI_WAIT(req_recv((imsg_recv-1)*2+1), mpistatus, mpierr)
1645 CALL MPI_WAIT(req_recv(imsg_recv*2), mpistatus, mpierr)
2135 SAFE_DEALLOCATE(req_recv)
/dports/science/berkeleygw/BGW-2.0.0/Common/
H A Depsread_hdf5.f90844 integer :: req_send(npes_pool), req_recv(npes_pool) local
894 pool_rank*npes_pool + ipe, pool_comm, req_recv(ipe+1), mpierr)
905 call MPI_Waitany(npes_pool, req_recv, ipe, MPI_STATUS_IGNORE, mpierr)

12