| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/sock/src/ |
| H A D | ch3_progress.c | 424 reqFn = rreq->dev.OnDataAvail; in MPIDI_CH3I_Progress_handle_sock_event()
425 if (!reqFn) { in MPIDI_CH3I_Progress_handle_sock_event()
474 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3I_Progress_handle_sock_event()
475 if (!reqFn) { in MPIDI_CH3I_Progress_handle_sock_event()
482 mpi_errno = reqFn(conn->vc, sreq, &complete); in MPIDI_CH3I_Progress_handle_sock_event()
517 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3I_Progress_handle_sock_event()
518 if (!reqFn) { in MPIDI_CH3I_Progress_handle_sock_event()
764 int (*reqFn) (MPIDI_VC_t *, MPIR_Request *, int *); in ReadMoreData() local
767 reqFn = rreq->dev.OnDataAvail; in ReadMoreData()
768 if (!reqFn) { in ReadMoreData()
[all …]
|
| H A D | ch3_isend.c | 24 int (*reqFn) (MPIDI_VC_t *, MPIR_Request *, int *); in MPIDI_CH3_iSend() local
57 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSend()
58 if (!reqFn) { in MPIDI_CH3_iSend()
64 mpi_errno = reqFn(vc, sreq, &complete); in MPIDI_CH3_iSend()
|
| H A D | ch3_isendv.c | 36 int (*reqFn) (MPIDI_VC_t *, MPIR_Request *, int *); in MPIDI_CH3_iSendv() local
108 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSendv()
109 if (!reqFn) { in MPIDI_CH3_iSendv()
115 mpi_errno = reqFn(vc, sreq, &complete); in MPIDI_CH3_iSendv()
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/sock/src/ |
| H A D | ch3_progress.c | 478 reqFn = rreq->dev.OnDataAvail; in MPIDI_CH3I_Progress_handle_sock_event()
479 if (!reqFn) { in MPIDI_CH3I_Progress_handle_sock_event()
485 mpi_errno = reqFn( conn->vc, rreq, &complete ); in MPIDI_CH3I_Progress_handle_sock_event()
537 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3I_Progress_handle_sock_event()
538 if (!reqFn) { in MPIDI_CH3I_Progress_handle_sock_event()
581 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3I_Progress_handle_sock_event()
582 if (!reqFn) { in MPIDI_CH3I_Progress_handle_sock_event()
588 mpi_errno = reqFn( conn->vc, sreq, &complete ); in MPIDI_CH3I_Progress_handle_sock_event()
855 reqFn = rreq->dev.OnDataAvail; in ReadMoreData()
856 if (!reqFn) { in ReadMoreData()
[all …]
|
| H A D | ch3_isend.c | 35 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPIDI_CH3_iSend() local
74 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSend()
75 if (!reqFn) { in MPIDI_CH3_iSend()
81 mpi_errno = reqFn( vc, sreq, &complete ); in MPIDI_CH3_iSend()
|
| H A D | ch3_isendv.c | 48 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPIDI_CH3_iSendv() local
128 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSendv()
129 if (!reqFn) { in MPIDI_CH3_iSendv()
135 mpi_errno = reqFn( vc, sreq, &complete ); in MPIDI_CH3_iSendv()
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/src/ |
| H A D | ch3u_handle_send_req.c | 18 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPIDI_CH3U_Handle_send_req() local
25 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3U_Handle_send_req()
26 if (!reqFn) { in MPIDI_CH3U_Handle_send_req()
32 mpi_errno = reqFn( vc, sreq, complete ); in MPIDI_CH3U_Handle_send_req()
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/scif/ |
| H A D | scif_send.c | 81 int (*reqFn) (MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_scif_send_queued() local
84 reqFn = sreq->dev.OnDataAvail; in MPID_nem_scif_send_queued()
85 if (!reqFn) { in MPID_nem_scif_send_queued()
94 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_scif_send_queued()
264 reqFn = sreq->dev.OnDataAvail; in MPID_nem_scif_iSendContig()
265 if (!reqFn) { in MPID_nem_scif_iSendContig()
274 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_scif_iSendContig()
413 int (*reqFn) (MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_scif_SendNoncontig() local
415 reqFn = sreq->dev.OnDataAvail; in MPID_nem_scif_SendNoncontig()
416 if (!reqFn) { in MPID_nem_scif_SendNoncontig()
[all …]
|
| H A D | scifsm.c | 52 int (*reqFn) (MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_scif_recv_handler() local
85 reqFn = rreq->dev.OnDataAvail; in MPID_nem_scif_recv_handler()
86 if (!reqFn) { in MPID_nem_scif_recv_handler()
95 mpi_errno = reqFn(sc_vc, rreq, &complete); in MPID_nem_scif_recv_handler()
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/src/ |
| H A D | ch3_isend.c | 63 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPIDI_CH3_iSend() local
65 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSend()
66 if (!reqFn) in MPIDI_CH3_iSend()
74 mpi_errno = reqFn (vc, sreq, &complete); in MPIDI_CH3_iSend()
|
| H A D | ch3_isendv.c | 115 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPIDI_CH3_iSendv() local
117 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSendv()
118 if (!reqFn) in MPIDI_CH3_iSendv()
128 mpi_errno = reqFn (vc, sreq, &complete); in MPIDI_CH3_iSendv()
|
| H A D | mpid_nem_lmt_dma.c | 281 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in check_req_complete() local
282 reqFn = req->dev.OnDataAvail; in check_req_complete()
283 if (reqFn) { in check_req_complete()
285 mpi_errno = reqFn(vc, req, complete); in check_req_complete()
448 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_lmt_dma_done_send() local
461 reqFn = sreq->dev.OnDataAvail; in MPID_nem_lmt_dma_done_send()
462 if (!reqFn) { in MPID_nem_lmt_dma_done_send()
469 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_lmt_dma_done_send()
|
| H A D | mpid_nem_lmt_vmsplice.c | 64 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in check_req_complete() local
65 reqFn = req->dev.OnDataAvail; in check_req_complete()
66 if (reqFn) { in check_req_complete()
73 mpi_errno = reqFn(vc, req, complete); in check_req_complete()
384 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_lmt_vmsplice_start_send() local
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/ofi/ |
| H A D | ofi_progress.c | 38 req_fn reqFn; in MPID_nem_ofi_poll() local
60 reqFn = req->dev.OnDataAvail; in MPID_nem_ofi_poll()
61 if (reqFn) { in MPID_nem_ofi_poll()
66 MPIDI_CH3I_NM_OFI_RC(reqFn(vc, req, &complete)); in MPID_nem_ofi_poll()
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/src/ |
| H A D | ch3_isend.c | 59 int (*reqFn)(MPIDI_VC_t *, MPIR_Request *, int *); in MPIDI_CH3_iSend() local
61 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSend()
62 if (!reqFn) in MPIDI_CH3_iSend()
71 mpi_errno = reqFn (vc, sreq, &complete); in MPIDI_CH3_iSend()
|
| H A D | ch3_isendv.c | 117 int (*reqFn)(MPIDI_VC_t *, MPIR_Request *, int *); in MPIDI_CH3_iSendv() local
119 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSendv()
120 if (!reqFn) in MPIDI_CH3_iSendv()
131 mpi_errno = reqFn (vc, sreq, &complete); in MPIDI_CH3_iSendv()
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/ |
| H A D | ch3u_handle_send_req.c | 12 int (*reqFn) (MPIDI_VC_t *, MPIR_Request *, int *); in MPIDI_CH3U_Handle_send_req() local
19 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3U_Handle_send_req()
20 if (!reqFn) { in MPIDI_CH3U_Handle_send_req()
26 mpi_errno = reqFn(vc, sreq, complete); in MPIDI_CH3U_Handle_send_req()
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/tcp/ |
| H A D | tcp_send.c | 146 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_tcp_send_queued() local
148 reqFn = sreq->dev.OnDataAvail; in MPID_nem_tcp_send_queued()
149 if (!reqFn) in MPID_nem_tcp_send_queued()
159 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_tcp_send_queued()
564 reqFn = sreq->dev.OnDataAvail; in MPID_nem_tcp_iSendContig()
565 if (!reqFn) in MPID_nem_tcp_iSendContig()
576 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_tcp_iSendContig()
757 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_tcp_SendNoncontig() local
759 reqFn = sreq->dev.OnDataAvail; in MPID_nem_tcp_SendNoncontig()
760 if (!reqFn) in MPID_nem_tcp_SendNoncontig()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/wintcp/ |
| H A D | wintcp_send.c | 420 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_newtcp_iSendContig() local
422 reqFn = sreq->dev.OnDataAvail; in MPID_nem_newtcp_iSendContig()
423 if (!reqFn) in MPID_nem_newtcp_iSendContig()
434 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_newtcp_iSendContig()
579 int (*reqFn)(MPIDI_VC_t *, MPID_Request *, int *); in MPID_nem_newtcp_SendNoncontig() local
581 reqFn = sreq->dev.OnDataAvail; in MPID_nem_newtcp_SendNoncontig()
582 if (!reqFn) in MPID_nem_newtcp_SendNoncontig()
590 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_newtcp_SendNoncontig()
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/tcp/ |
| H A D | tcp_send.c | 135 int (*reqFn) (MPIDI_VC_t *, MPIR_Request *, int *); in MPID_nem_tcp_send_queued() local
137 reqFn = sreq->dev.OnDataAvail; in MPID_nem_tcp_send_queued()
138 if (!reqFn) { in MPID_nem_tcp_send_queued()
148 mpi_errno = reqFn(vc, sreq, &complete); in MPID_nem_tcp_send_queued()
254 int (*reqFn) (MPIDI_VC_t *, MPIR_Request *, int *); in tcp_complete_sreq() local
256 reqFn = sreq->dev.OnDataAvail; in tcp_complete_sreq()
257 if (!reqFn) { in tcp_complete_sreq()
264 mpi_errno = reqFn(vc, sreq, complete_ptr); in tcp_complete_sreq()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/aws/aws-sdk-go/private/protocol/restxml/ |
| H A D | build_bench_test.go | 126 func benchRESTXMLBuild(b *testing.B, reqFn func() *request.Request) {
130 req := reqFn()
138 func benchRESTXMLRequest(b *testing.B, reqFn func() *request.Request) {
142 err := reqFn().Send()
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/aws/aws-sdk-go/private/protocol/restxml/ |
| H A D | build_bench_test.go | 125 func benchRESTXMLBuild(b *testing.B, reqFn func() *request.Request) {
129 req := reqFn()
137 func benchRESTXMLRequest(b *testing.B, reqFn func() *request.Request) {
141 err := reqFn().Send()
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/aws/aws-sdk-go/private/protocol/restxml/ |
| H A D | build_bench_test.go | 125 func benchRESTXMLBuild(b *testing.B, reqFn func() *request.Request) {
129 req := reqFn()
137 func benchRESTXMLRequest(b *testing.B, reqFn func() *request.Request) {
141 err := reqFn().Send()
|
| /dports/security/vuls/vuls-0.13.7/vendor/github.com/aws/aws-sdk-go/private/protocol/restxml/ |
| H A D | build_bench_test.go | 125 func benchRESTXMLBuild(b *testing.B, reqFn func() *request.Request) {
129 req := reqFn()
137 func benchRESTXMLRequest(b *testing.B, reqFn func() *request.Request) {
141 err := reqFn().Send()
|
| /dports/devel/app-builder/app-builder-3.4.2/vendor/github.com/aws/aws-sdk-go/private/protocol/restxml/ |
| H A D | build_bench_test.go | 125 func benchRESTXMLBuild(b *testing.B, reqFn func() *request.Request) {
129 req := reqFn()
137 func benchRESTXMLRequest(b *testing.B, reqFn func() *request.Request) {
141 err := reqFn().Send()
|