Skip to content

Commit d9dcf83

Browse files
author
Nadezhda Kogteva
committed
oob ud: fixed a bug that prevented the work with QoS framework (oob_stress_channel test)
1 parent 27f1884 commit d9dcf83

File tree

3 files changed

+6
-0
lines changed

3 files changed

+6
-0
lines changed

orte/mca/oob/ud/oob_ud_recv.c

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -492,6 +492,8 @@ int mca_oob_ud_recv_match_send (mca_oob_ud_port_t *port, mca_oob_ud_peer_t *peer
492492
req->req_origin = msg_hdr->msg_origin;
493493
req->req_target = msg_hdr->msg_target;
494494
req->req_rem_data_len = msg_hdr->msg_data.req.data_len;
495+
req->req_channel = msg_hdr->msg_channel;
496+
req->req_seq_num = msg_hdr->msg_seq_num;
495497

496498
do {
497499
rc = mca_oob_ud_recv_alloc (req);

orte/mca/oob/ud/oob_ud_req.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,8 @@ struct mca_oob_ud_msg_hdr_t {
7171

7272
orte_process_name_t msg_origin;
7373
orte_process_name_t msg_target;
74+
int msg_channel;
75+
int msg_seq_num;
7476

7577
uint64_t msg_id;
7678

orte/mca/oob/ud/oob_ud_send.c

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,8 @@ int mca_oob_ud_process_send_nb(int fd, short args, void *cbdata)
234234

235235
req_msg->hdr->msg_origin = op->msg->origin;
236236
req_msg->hdr->msg_target = op->msg->dst;
237+
req_msg->hdr->msg_channel = op->msg->dst_channel;
238+
req_msg->hdr->msg_seq_num = op->msg->seq_num;
237239

238240
req_msg->hdr->msg_data.req.data_len = size;
239241
req_msg->hdr->msg_data.req.mtu = port->mtu;

0 commit comments

Comments
 (0)