Commit 9ab8f039 authored by Jonathan Jenkins's avatar Jonathan Jenkins

RC fix - incorrect msg size used in RDMA read case

parent 2d9622cf
......@@ -287,7 +287,8 @@ void fcfs_next_rc(
mn_sched_qitem *q = malloc(sizeof(mn_sched_qitem));
assert(q);
q->req = rc->req;
q->rem = q->req.msg_size % q->req.packet_size;
q->rem = (q->req.is_pull ? PULL_MSG_SIZE : q->req.msg_size) %
q->req.packet_size;
if (q->rem == 0){ // processed exactly a packet's worth of data
q->rem = q->req.packet_size;
}
......@@ -449,7 +450,8 @@ void rr_next_rc (
mn_sched_qitem *q = malloc(sizeof(mn_sched_qitem));
assert(q);
q->req = rc->req;
q->rem = q->req.msg_size % q->req.packet_size;
q->rem = (q->req.is_pull ? PULL_MSG_SIZE : q->req.msg_size) %
q->req.packet_size;
if (q->rem == 0){ // processed exactly a packet's worth of data
q->rem = q->req.packet_size;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment