| /dports/net/mpich2/mpich2-1.5/src/mpid/pamid/src/pt2pt/ |
| H A D | mpidi_sendmsg.c | 105 .cookie = sreq, in MPIDI_SendMsg_eager()
190 sreq,sndbuf, in MPIDI_SendMsg_rzv()
224 MPIDI_Out_cntr[dest].S[(sreq->mpid.idx)].bufaddr=sreq->mpid.envelope.data; in MPIDI_SendMsg_rzv()
228 MPIDI_Out_cntr[dest].S[(sreq->mpid.idx)].memRegion=sreq->mpid.envelope.memregion_used; in MPIDI_SendMsg_rzv()
375 MPIDI_Request_setPeerRank_pami(sreq, MPID_VCR_GET_LPID(sreq->comm->vcr, rank)); in MPIDI_SendMsg()
413 sreq->mpid.partner_id=dest; in MPIDI_SendMsg()
418 sreq->mpid.shm=0; in MPIDI_SendMsg()
589 MPID_assert(sreq != NULL); in MPIDI_Send_handoff()
601 MPID_assert(sreq != NULL); in MPIDI_Ssend_handoff()
627 MPID_assert(sreq != NULL); in MPIDI_Isend_handoff()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/sock/src/ |
| H A D | ch3_istartmsg.c | 10 MPIR_Request *sreq; in create_request() local
17 if (sreq == NULL) in create_request()
24 sreq->dev.iov[0].iov_base = (void *) ((char *) &sreq->dev.pending_pkt + nb); in create_request()
26 sreq->dev.iov_count = 1; in create_request()
30 return sreq; in create_request()
131 if (!sreq) { in MPIDI_CH3_iStartMsg()
141 if (!sreq) { in MPIDI_CH3_iStartMsg()
150 if (!sreq) { in MPIDI_CH3_iStartMsg()
161 if (!sreq) { in MPIDI_CH3_iStartMsg()
171 if (!sreq) { in MPIDI_CH3_iStartMsg()
[all …]
|
| H A D | ch3_istartmsgv.c | 10 MPIR_Request *sreq; in create_request() local
18 if (sreq == NULL) in create_request()
21 MPIR_Object_set_ref(sreq, 2); in create_request()
29 sreq->dev.iov[0].iov_base = (void *) & sreq->dev.pending_pkt; in create_request()
35 sreq->dev.OnDataAvail = 0; in create_request()
38 return sreq; in create_request()
168 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
177 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
188 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
198 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
[all …]
|
| H A D | ch3_isend.c | 15 sreq->dev.iov[0].iov_base = (void *) ((char *) &sreq->dev.pending_pkt + nb); in update_request()
16 sreq->dev.iov[0].iov_len = hdr_sz - nb; in update_request()
17 sreq->dev.iov_count = 1; in update_request()
131 MPID_Request_complete(sreq); in MPIDI_CH3_iSend()
144 update_request(sreq, hdr, hdr_sz, 0); in MPIDI_CH3_iSend()
145 MPIDI_CH3I_SendQ_enqueue(vcch, sreq); in MPIDI_CH3_iSend()
149 update_request(sreq, hdr, hdr_sz, 0); in MPIDI_CH3_iSend()
150 MPIDI_CH3I_SendQ_enqueue(vcch, sreq); in MPIDI_CH3_iSend()
156 update_request(sreq, hdr, hdr_sz, 0); in MPIDI_CH3_iSend()
157 MPIDI_CH3I_SendQ_enqueue(vcch, sreq); in MPIDI_CH3_iSend()
[all …]
|
| H A D | ch3_isendv.c | 17 sreq->dev.iov[i] = iov[i]; in update_request()
22 sreq->dev.iov[0].iov_base = (void *) & sreq->dev.pending_pkt; in update_request()
24 sreq->dev.iov[iov_offset].iov_base = in update_request()
26 sreq->dev.iov[iov_offset].iov_len -= nb; in update_request()
27 sreq->dev.iov_count = iov_count; in update_request()
159 MPID_Request_complete(sreq); in MPIDI_CH3_iSendv()
172 update_request(sreq, iov, n_iov, 0, 0); in MPIDI_CH3_iSendv()
173 MPIDI_CH3I_SendQ_enqueue(vcch, sreq); in MPIDI_CH3_iSendv()
178 MPIDI_CH3I_SendQ_enqueue(vcch, sreq); in MPIDI_CH3_iSendv()
185 MPIDI_CH3I_SendQ_enqueue(vcch, sreq); in MPIDI_CH3_iSendv()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/sock/src/ |
| H A D | ch3_istartmsg.c | 23 if (sreq == NULL) in create_request()
37 return sreq; in create_request()
103 if (!sreq) { in MPIDI_CH3_iStartMsg()
130 if (!sreq) { in MPIDI_CH3_iStartMsg()
134 sreq->cc = 0; in MPIDI_CH3_iStartMsg()
149 if (!sreq) { in MPIDI_CH3_iStartMsg()
162 if (!sreq) { in MPIDI_CH3_iStartMsg()
174 if (!sreq) { in MPIDI_CH3_iStartMsg()
187 if (!sreq) { in MPIDI_CH3_iStartMsg()
198 if (!sreq) { in MPIDI_CH3_iStartMsg()
[all …]
|
| H A D | ch3_istartmsgv.c | 16 MPID_Request * sreq; in create_request() local
24 if (sreq == NULL) in create_request()
38 sreq->dev.iov[0].MPID_IOV_BUF = (MPID_IOV_BUF_CAST) &sreq->dev.pending_pkt; in create_request()
46 return sreq; in create_request()
162 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
166 sreq->cc = 0; in MPIDI_CH3_iStartMsgv()
194 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
206 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
219 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
230 if (sreq == NULL) { in MPIDI_CH3_iStartMsgv()
[all …]
|
| H A D | ch3_isend.c | 21 sreq->dev.iov[0].MPID_IOV_BUF = (MPID_IOV_BUF_CAST)((char *) &sreq->dev.pending_pkt + nb); in update_request()
23 sreq->dev.iov_count = 1; in update_request()
74 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSend()
77 MPIDI_CH3U_Request_complete(sreq); in MPIDI_CH3_iSend()
90 vcch->conn->sock, sreq->dev.iov, in MPIDI_CH3_iSend()
91 sreq->dev.iov_count, NULL); in MPIDI_CH3_iSend()
97 sreq, vcch->conn, vc); in MPIDI_CH3_iSend()
111 vcch->conn->send_active = sreq; in MPIDI_CH3_iSend()
121 sreq, vcch->conn, vc); in MPIDI_CH3_iSend()
147 MPIDI_CH3U_Request_complete(sreq); in MPIDI_CH3_iSend()
[all …]
|
| H A D | ch3_isendv.c | 23 sreq->dev.iov[i] = iov[i]; in update_request()
29 sreq->dev.iov[0].MPID_IOV_BUF = (MPID_IOV_BUF_CAST) &sreq->dev.pending_pkt; in update_request()
34 sreq->dev.iov_count = iov_count; in update_request()
107 vcch->conn->send_active = sreq; in MPIDI_CH3_iSendv()
109 sreq->dev.iov + offset, in MPIDI_CH3_iSendv()
116 sreq, vcch->conn, vc); in MPIDI_CH3_iSendv()
128 reqFn = sreq->dev.OnDataAvail; in MPIDI_CH3_iSendv()
144 sreq->dev.iov_count, NULL); in MPIDI_CH3_iSendv()
150 sreq, vcch->conn, vc); in MPIDI_CH3_iSendv()
179 MPIDI_CH3U_Request_complete(sreq); in MPIDI_CH3_iSendv()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/scif/ |
| H A D | scif_send.c | 21 MPID_Request *sreq; in MPID_nem_scif_send_queued() local
49 iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_scif_send_queued()
58 for (iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_scif_send_queued()
59 iov < &sreq->dev.iov[sreq->dev.iov_offset + sreq->dev.iov_count]; ++iov) { in MPID_nem_scif_send_queued()
64 sreq->dev.iov_count -= ((iov - sreq->dev.iov) - sreq->dev.iov_offset); in MPID_nem_scif_send_queued()
65 sreq->dev.iov_offset = iov - sreq->dev.iov; in MPID_nem_scif_send_queued()
172 sreq->ch.vc = vc; in MPID_nem_scif_iStartContigMsg()
211 *sreq_ptr = sreq; in MPID_nem_scif_iStartContigMsg()
316 sreq->ch.vc = vc; in MPID_nem_scif_iSendContig()
397 sreq->dev.iov[sreq->dev.iov_count].MPID_IOV_BUF = in MPID_nem_scif_SendNoncontig()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/src/ |
| H A D | ch3i_eagernoncontig.c | 46 sreq->ch.noncontig = TRUE; in MPIDI_CH3I_SendNoncontig()
48 sreq->ch.vc = vc; in MPIDI_CH3I_SendNoncontig()
57 MPID_nem_mpich_send_seg_header(sreq->dev.user_buf, sreq->dev.user_count, sreq->dev.datatype, in MPIDI_CH3I_SendNoncontig()
58 &sreq->dev.msg_offset, sreq->dev.msgsize, in MPIDI_CH3I_SendNoncontig()
60 while(!again && sreq->dev.msg_offset < sreq->dev.msgsize) in MPIDI_CH3I_SendNoncontig()
61 MPID_nem_mpich_send_seg(sreq->dev.user_buf, sreq->dev.user_count, sreq->dev.datatype, in MPIDI_CH3I_SendNoncontig()
62 &sreq->dev.msg_offset, sreq->dev.msgsize, vc, &again); in MPIDI_CH3I_SendNoncontig()
67 sreq->ch.noncontig = TRUE; in MPIDI_CH3I_SendNoncontig()
68 sreq->ch.vc = vc; in MPIDI_CH3I_SendNoncontig()
85 if (!sreq->dev.OnDataAvail) in MPIDI_CH3I_SendNoncontig()
[all …]
|
| H A D | ch3_isendv.c | 30 MPID_Request_complete(sreq); in MPIDI_CH3_iSendv()
84 sreq->dev.pending_pkt = in MPIDI_CH3_iSendv()
86 sreq->dev.iov[0].iov_base = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iSendv()
101 sreq->dev.iov_offset = 0; in MPIDI_CH3_iSendv()
104 sreq->ch.vc = vc; in MPIDI_CH3_iSendv()
158 sreq->dev.iov[0].iov_base = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iSendv()
163 sreq->dev.iov[i] = iov[i]; in MPIDI_CH3_iSendv()
166 sreq->dev.iov_count = n_iov; in MPIDI_CH3_iSendv()
167 sreq->dev.iov_offset = 0; in MPIDI_CH3_iSendv()
168 sreq->ch.noncontig = FALSE; in MPIDI_CH3_iSendv()
[all …]
|
| H A D | ch3_istartmsgv.c | 55 *sreq_ptr = sreq; in MPIDI_CH3_iStartMsgv()
122 sreq->dev.iov_offset = 0; in MPIDI_CH3_iStartMsgv()
126 sreq->ch.vc = vc; in MPIDI_CH3_iStartMsgv()
131 sreq->dev.iov[0].iov_base = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iStartMsgv()
146 MPIR_Assert(sreq != NULL); in MPIDI_CH3_iStartMsgv()
151 sreq->dev.iov[0].iov_base = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iStartMsgv()
160 sreq->dev.iov_offset = 0; in MPIDI_CH3_iStartMsgv()
161 sreq->dev.iov_count = n_iov; in MPIDI_CH3_iStartMsgv()
162 sreq->dev.OnDataAvail = 0; in MPIDI_CH3_iStartMsgv()
164 sreq->ch.vc = vc; in MPIDI_CH3_iStartMsgv()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/newmad/ |
| H A D | newmad_send.c | 52 newmad_iov, num_iov, &(REQ_FIELD(sreq,newmad_req)),(void *)sreq); in MPID_nem_newmad_iSendContig()
54 sreq->ch.vc = vc; in MPID_nem_newmad_iSendContig()
107 sreq->ch.vc = vc; in MPID_nem_newmad_iStartContigMsg()
110 *sreq_ptr = sreq; in MPID_nem_newmad_iStartContigMsg()
154 sreq->dev.tmpbuf = MPIU_Malloc((size_t)sreq->dev.segment_size); in MPID_nem_newmad_SendNoncontig()
156 …MPID_Segment_pack(sreq->dev.segment_ptr,sreq->dev.segment_first, &last,(char *)(sreq->dev.tmpbuf)); in MPID_nem_newmad_SendNoncontig()
217 sreq->ch.vc = vc; in MPID_nem_newmad_directSend()
253 NULL, 0, &(REQ_FIELD(sreq,newmad_req)),(void*)sreq); in MPID_nem_newmad_directSend()
260 *sreq_p = sreq; in MPID_nem_newmad_directSend()
293 sreq->ch.vc = vc; in MPID_nem_newmad_directSsend()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/tcp/ |
| H A D | tcp_send.c | 85 iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_tcp_send_queued()
117 for (iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_tcp_send_queued()
118 iov < &sreq->dev.iov[sreq->dev.iov_offset + sreq->dev.iov_count]; ++iov) { in MPID_nem_tcp_send_queued()
123 sreq->dev.iov_count -= ((iov - sreq->dev.iov) - sreq->dev.iov_offset); in MPID_nem_tcp_send_queued()
124 sreq->dev.iov_offset = iov - sreq->dev.iov; in MPID_nem_tcp_send_queued()
536 sreq->dev.iov[sreq->dev.iov_count].iov_base = (char *) &sreq->dev.pending_pkt + offset; in MPID_nem_tcp_iSendContig()
541 sreq->dev.iov[sreq->dev.iov_count].iov_base = data; in MPID_nem_tcp_iSendContig()
546 sreq->dev.iov[sreq->dev.iov_count].iov_base = in MPID_nem_tcp_iSendContig()
548 sreq->dev.iov[sreq->dev.iov_count].iov_len = in MPID_nem_tcp_iSendContig()
643 sreq->dev.iov[sreq->dev.iov_count].iov_base = in MPID_nem_tcp_iSendIov()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/portals4/ |
| H A D | ptl_send.c | 179 sreq->dev.iov[index].MPID_IOV_BUF = &sreq->dev.pending_pkt; in save_iov()
352 sreq->ch.vc = vc; in enqueue_request()
466 *sreq_ptr = sreq; in MPID_nem_ptl_iStartContigMsg()
557 for (i = sreq->dev.iov_offset; i < sreq->dev.iov_count + sreq->dev.iov_offset; ++i) { in send_queued()
601 mpi_errno = reqFn(sreq->ch.vc, sreq, &complete); in send_queued()
744 …MPI_nem_ptl_pack_byte(sreq->dev.segment_ptr, sreq->dev.segment_first, sreq->dev.segment_first + PT…
868 …MPID_Segment_pack_vector(sreq->dev.segment_ptr, sreq->dev.segment_first, &last, sreq->dev.iov, &sr… in send_msg()
892 …MPID_Segment_pack(sreq->dev.segment_ptr, sreq->dev.segment_first, &last, REQ_PTL(sreq)->chunk_buff… in send_msg()
939 …MPID_Segment_pack_vector(sreq->dev.segment_ptr, sreq->dev.segment_first, &last, sreq->dev.iov, &sr… in send_msg()
1039 …MPI_nem_ptl_pack_byte(sreq->dev.segment_ptr, sreq->dev.segment_first, sreq->dev.segment_first + PT… in send_msg()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/comm/ |
| H A D | comm_idup_iallreduce.c | 40 MPI_Request sreq[ITERS * 2]; in main() local
57 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
81 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
85 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
105 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
109 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
123 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
142 MPI_Comm_idup(ic, &newcomm, &sreq[1]); in main()
144 MPI_Waitall(2, sreq, MPI_STATUS_IGNORE); in main()
156 MPI_Comm_idup(ic, &newcomm, &sreq[1]); in main()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/tcp/ |
| H A D | tcp_send.c | 73 MPID_Request *sreq; in MPID_nem_tcp_send_queued() local
93 iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_tcp_send_queued()
124 …for (iov = &sreq->dev.iov[sreq->dev.iov_offset]; iov < &sreq->dev.iov[sreq->dev.iov_offset + sreq-… in MPID_nem_tcp_send_queued()
131 sreq->dev.iov_count -= ((iov - sreq->dev.iov) - sreq->dev.iov_offset); in MPID_nem_tcp_send_queued()
132 sreq->dev.iov_offset = iov - sreq->dev.iov; in MPID_nem_tcp_send_queued()
312 sreq->ch.vc = vc; in MPID_nem_tcp_iStartContigMsg()
357 *sreq_ptr = sreq; in MPID_nem_tcp_iStartContigMsg()
451 sreq->ch.vc = vc; in MPID_nem_tcp_iStartContigMsg_paused()
492 *sreq_ptr = sreq; in MPID_nem_tcp_iStartContigMsg_paused()
628 sreq->ch.vc = vc; in MPID_nem_tcp_iSendContig()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/ |
| H A D | ofi_am_impl.h | 86 MPIDI_OFI_AMREQUEST(sreq, req_hdr) = NULL; in MPIDI_OFI_am_clear_request()
215 lmt_info->sreq_ptr = sreq; in MPIDI_OFI_am_isend_long()
241 iov = MPIDI_OFI_AMREQUEST_HDR(sreq, iov); in MPIDI_OFI_am_isend_long()
297 MPIR_cc_incr(sreq->cc_ptr, &c); in MPIDI_OFI_am_isend_short()
337 MPIR_cc_incr(sreq->cc_ptr, &c); in MPIDI_OFI_am_isend_pipeline()
466 MPIDI_OFI_AMREQUEST(sreq, deferred_req)->sreq = sreq; in MPIDI_OFI_do_am_isend_eager()
478 MPIR_Request *sreq; in MPIDI_OFI_do_emulated_inject() local
629 send_req->sreq = sreq; in MPIDI_OFI_do_am_isend_pipeline()
636 send_req->sreq = sreq; in MPIDI_OFI_do_am_isend_pipeline()
679 MPIDI_OFI_AMREQUEST(sreq, deferred_req)->sreq = sreq; in MPIDI_OFI_do_am_isend_pipeline()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/src/ |
| H A D | ch3i_eagernoncontig.c | 41 sreq->ch.noncontig = TRUE; in MPIDI_CH3I_SendNoncontig()
42 sreq->ch.header_sz = hdr_sz; in MPIDI_CH3I_SendNoncontig()
43 sreq->ch.vc = vc; in MPIDI_CH3I_SendNoncontig()
52 …MPID_nem_mpich2_send_seg_header(sreq->dev.segment_ptr, &sreq->dev.segment_first, sreq->dev.segment… in MPIDI_CH3I_SendNoncontig()
53 while(!again && sreq->dev.segment_first < sreq->dev.segment_size) in MPIDI_CH3I_SendNoncontig()
54 …MPID_nem_mpich2_send_seg(sreq->dev.segment_ptr, &sreq->dev.segment_first, sreq->dev.segment_size, … in MPIDI_CH3I_SendNoncontig()
59 sreq->ch.noncontig = TRUE; in MPIDI_CH3I_SendNoncontig()
60 sreq->ch.vc = vc; in MPIDI_CH3I_SendNoncontig()
77 if (!sreq->dev.OnDataAvail) in MPIDI_CH3I_SendNoncontig()
80 MPIDI_CH3U_Request_complete(sreq); in MPIDI_CH3I_SendNoncontig()
[all …]
|
| H A D | ch3_isendv.c | 87 sreq->dev.pending_pkt = in MPIDI_CH3_iSendv()
89 sreq->dev.iov[0].MPID_IOV_BUF = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iSendv()
104 sreq->dev.iov_offset = 0; in MPIDI_CH3_iSendv()
107 sreq->ch.vc = vc; in MPIDI_CH3_iSendv()
135 sreq->ch.vc = vc; in MPIDI_CH3_iSendv()
155 sreq->dev.iov[0].MPID_IOV_BUF = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iSendv()
160 sreq->dev.iov[i] = iov[i]; in MPIDI_CH3_iSendv()
163 sreq->dev.iov_count = n_iov; in MPIDI_CH3_iSendv()
164 sreq->dev.iov_offset = 0; in MPIDI_CH3_iSendv()
165 sreq->ch.noncontig = FALSE; in MPIDI_CH3_iSendv()
[all …]
|
| H A D | ch3_istartmsgv.c | 35 MPID_Request * sreq = NULL; in MPIDI_CH3_iStartMsgv() local
60 *sreq_ptr = sreq; in MPIDI_CH3_iStartMsgv()
131 sreq->ch.vc = vc; in MPIDI_CH3_iStartMsgv()
136 sreq->dev.iov[0].MPID_IOV_BUF = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iStartMsgv()
151 MPIU_Assert(sreq != NULL); in MPIDI_CH3_iStartMsgv()
156 sreq->dev.iov[0].MPID_IOV_BUF = (char *) &sreq->dev.pending_pkt; in MPIDI_CH3_iStartMsgv()
165 sreq->dev.iov_offset = 0; in MPIDI_CH3_iStartMsgv()
166 sreq->dev.iov_count = n_iov; in MPIDI_CH3_iStartMsgv()
167 sreq->dev.OnDataAvail = 0; in MPIDI_CH3_iStartMsgv()
169 sreq->ch.vc = vc; in MPIDI_CH3_iStartMsgv()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/wintcp/ |
| H A D | wintcp_send.c | 143 iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_newtcp_module_send_queued()
160 …for (iov = &sreq->dev.iov[sreq->dev.iov_offset]; iov < &sreq->dev.iov[sreq->dev.iov_offset + sreq-… in MPID_nem_newtcp_module_send_queued()
167 sreq->dev.iov_count -= ((iov - sreq->dev.iov) - sreq->dev.iov_offset); in MPID_nem_newtcp_module_send_queued()
168 sreq->dev.iov_offset = iov - sreq->dev.iov; in MPID_nem_newtcp_module_send_queued()
176 MPID_IOV *iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_newtcp_module_send_queued()
317 sreq->ch.vc = vc; in MPID_nem_newtcp_iStartContigMsg()
354 sreq->dev.iov, sreq->dev.iov_count); in MPID_nem_newtcp_iStartContigMsg()
360 *sreq_ptr = sreq; in MPID_nem_newtcp_iStartContigMsg()
483 sreq->ch.vc = vc; in MPID_nem_newtcp_iSendContig()
489 sreq->dev.iov, sreq->dev.iov_count); in MPID_nem_newtcp_iSendContig()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/ofi/ |
| H A D | ofi_msg.c | 226 MPID_nem_ofi_init_req(sreq); in MPID_nem_ofi_iSendContig()
233 REQ_OFI(sreq)->iov[0].iov_base = REQ_OFI(sreq)->real_hdr; in MPID_nem_ofi_iSendContig()
267 MPID_nem_ofi_init_req(sreq); in MPID_nem_ofi_iSendIov()
311 data_sz = sreq->dev.msgsize - sreq->dev.msg_offset; in MPID_nem_ofi_SendNoncontig()
334 MPIR_Typerep_pack(sreq->dev.user_buf, sreq->dev.user_count, sreq->dev.datatype, in MPID_nem_ofi_SendNoncontig()
336 sreq->dev.msgsize - sreq->dev.msg_offset, &actual_pack_bytes); in MPID_nem_ofi_SendNoncontig()
337 MPIR_Assert(actual_pack_bytes == sreq->dev.msgsize - sreq->dev.msg_offset); in MPID_nem_ofi_SendNoncontig()
354 MPIR_Request *sreq; in MPID_nem_ofi_iStartContigMsg() local
366 sreq->dev.next = NULL; in MPID_nem_ofi_iStartContigMsg()
371 REQ_OFI(sreq)->iov[0].iov_base = REQ_OFI(sreq)->real_hdr; in MPID_nem_ofi_iStartContigMsg()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/mx/ |
| H A D | mx_send.c | 59 sreq->ch.vc = vc; in MPID_nem_mx_iSendContig()
121 *sreq_ptr = sreq; in MPID_nem_mx_iStartContigMsg()
167 sreq->dev.tmpbuf = MPIU_Malloc((size_t)sreq->dev.segment_size); in MPID_nem_mx_SendNoncontig()
168 …MPID_Segment_pack(sreq->dev.segment_ptr,sreq->dev.segment_first, &last,(char *)(sreq->dev.tmpbuf)); in MPID_nem_mx_SendNoncontig()
210 sreq->ch.vc = vc; in MPID_nem_mx_SendNoncontig()
256 sreq->ch.vc = vc; in MPID_nem_mx_directSend()
294 MPID_Segment_pack(sreq->dev.segment_ptr, 0, &last, sreq->dev.tmpbuf); in MPID_nem_mx_directSend()
307 mx_matching,(void *)sreq,&(REQ_FIELD(sreq,mx_request))); in MPID_nem_mx_directSend()
312 *request = sreq; in MPID_nem_mx_directSend()
397 mx_matching,(void *)sreq,&(REQ_FIELD(sreq,mx_request))); in MPID_nem_mx_directSsend()
[all …]
|