oob ud: fixed a bug that prevented the work with QoS framework (oob_stress_channel test)
Этот коммит содержится в:
родитель
27f1884cf8
Коммит
d9dcf8352e
@ -492,6 +492,8 @@ int mca_oob_ud_recv_match_send (mca_oob_ud_port_t *port, mca_oob_ud_peer_t *peer
|
|||||||
req->req_origin = msg_hdr->msg_origin;
|
req->req_origin = msg_hdr->msg_origin;
|
||||||
req->req_target = msg_hdr->msg_target;
|
req->req_target = msg_hdr->msg_target;
|
||||||
req->req_rem_data_len = msg_hdr->msg_data.req.data_len;
|
req->req_rem_data_len = msg_hdr->msg_data.req.data_len;
|
||||||
|
req->req_channel = msg_hdr->msg_channel;
|
||||||
|
req->req_seq_num = msg_hdr->msg_seq_num;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
rc = mca_oob_ud_recv_alloc (req);
|
rc = mca_oob_ud_recv_alloc (req);
|
||||||
|
@ -71,6 +71,8 @@ struct mca_oob_ud_msg_hdr_t {
|
|||||||
|
|
||||||
orte_process_name_t msg_origin;
|
orte_process_name_t msg_origin;
|
||||||
orte_process_name_t msg_target;
|
orte_process_name_t msg_target;
|
||||||
|
int msg_channel;
|
||||||
|
int msg_seq_num;
|
||||||
|
|
||||||
uint64_t msg_id;
|
uint64_t msg_id;
|
||||||
|
|
||||||
|
@ -234,6 +234,8 @@ int mca_oob_ud_process_send_nb(int fd, short args, void *cbdata)
|
|||||||
|
|
||||||
req_msg->hdr->msg_origin = op->msg->origin;
|
req_msg->hdr->msg_origin = op->msg->origin;
|
||||||
req_msg->hdr->msg_target = op->msg->dst;
|
req_msg->hdr->msg_target = op->msg->dst;
|
||||||
|
req_msg->hdr->msg_channel = op->msg->dst_channel;
|
||||||
|
req_msg->hdr->msg_seq_num = op->msg->seq_num;
|
||||||
|
|
||||||
req_msg->hdr->msg_data.req.data_len = size;
|
req_msg->hdr->msg_data.req.data_len = size;
|
||||||
req_msg->hdr->msg_data.req.mtu = port->mtu;
|
req_msg->hdr->msg_data.req.mtu = port->mtu;
|
||||||
|
Загрузка…
Ссылка в новой задаче
Block a user