/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/pml/ob1/ |
H A D | pml_ob1_irecv.c | 70 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 D | pml_ob1_iprobe.c | 36 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 D | pml_ob1_recvreq.h | 42 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 D | pml_ob1_recvreq.c | 73 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 D | pml_ob1_recvfrag.c | 437 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 D | pml_ob1_cuda.c | 160 …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 D | pml_ob1_sendreq.h | 48 opal_ptr_t req_recv; member 157 (sendreq)->req_recv.pval = NULL; \
|
H A D | pml_ob1_sendreq.c | 1023 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 D | pml_ob1_irecv.c | 70 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 D | pml_ob1_iprobe.c | 36 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 D | pml_ob1_recvreq.c | 74 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 D | pml_ob1_recvreq.h | 42 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 D | pml_ob1_recvfrag.c | 439 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 D | pml_ob1_cuda.c | 160 …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 D | pml_ob1_sendreq.h | 48 opal_ptr_t req_recv; member 157 (sendreq)->req_recv.pval = NULL; \
|
H A D | pml_ob1_sendreq.c | 1041 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 D | arping.c | 73 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 D | genwf_eps.f90 | 549 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 D | send_arp.linux.c | 116 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 D | mixed_cdft_methods.F | 3139 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 D | mixed_cdft_methods.F | 3131 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 D | client.c | 231 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 D | clover.F90 | 746 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 D | epscopy.f90 | 940 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 D | epsread_hdf5.f90 | 844 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)
|