Commit 343ba7c0 authored by Misbah Mubarak's avatar Misbah Mubarak
Browse files

bug fix in codes-workload-dump and dumpi trace workload method

parent 5163f041
...@@ -187,7 +187,7 @@ struct codes_workload_op ...@@ -187,7 +187,7 @@ struct codes_workload_op
int data_type; /* MPI data type to be matched with the recv */ int data_type; /* MPI data type to be matched with the recv */
int count; /* number of elements to be received */ int count; /* number of elements to be received */
int tag; /* tag of the message */ int tag; /* tag of the message */
int16_t req_id; int32_t req_id;
} send; } send;
struct { struct {
/* TODO: not sure why source rank is here */ /* TODO: not sure why source rank is here */
...@@ -197,7 +197,7 @@ struct codes_workload_op ...@@ -197,7 +197,7 @@ struct codes_workload_op
int data_type; /* MPI data type to be matched with the send */ int data_type; /* MPI data type to be matched with the send */
int count; /* number of elements to be sent */ int count; /* number of elements to be sent */
int tag; /* tag of the message */ int tag; /* tag of the message */
int16_t req_id; int32_t req_id;
} recv; } recv;
/* TODO: non-stub for other collectives */ /* TODO: non-stub for other collectives */
struct { struct {
...@@ -205,10 +205,10 @@ struct codes_workload_op ...@@ -205,10 +205,10 @@ struct codes_workload_op
} collective; } collective;
struct { struct {
int count; int count;
int16_t* req_ids; int32_t* req_ids;
} waits; } waits;
struct { struct {
int16_t req_id; int32_t req_id;
} wait; } wait;
}u; }u;
}; };
......
...@@ -341,8 +341,8 @@ int main(int argc, char *argv[]) ...@@ -341,8 +341,8 @@ int main(int argc, char *argv[])
recv_size += op.u.recv.num_bytes; recv_size += op.u.recv.num_bytes;
break; break;
case CODES_WK_ISEND: case CODES_WK_ISEND:
num_irecvs++; num_isends++;
irecv_size += op.u.send.num_bytes; isend_size += op.u.send.num_bytes;
break; break;
case CODES_WK_IRECV: case CODES_WK_IRECV:
num_irecvs++; num_irecvs++;
......
...@@ -375,6 +375,7 @@ int handleDUMPISend(const dumpi_send *prm, uint16_t thread, ...@@ -375,6 +375,7 @@ int handleDUMPISend(const dumpi_send *prm, uint16_t thread,
assert(wrkld_per_rank.u.send.num_bytes > 0); assert(wrkld_per_rank.u.send.num_bytes > 0);
wrkld_per_rank.u.send.dest_rank = prm->dest; wrkld_per_rank.u.send.dest_rank = prm->dest;
wrkld_per_rank.u.send.source_rank = myctx->my_rank; wrkld_per_rank.u.send.source_rank = myctx->my_rank;
wrkld_per_rank.u.send.req_id = -1;
update_times_and_insert(&wrkld_per_rank, wall, myctx); update_times_and_insert(&wrkld_per_rank, wall, myctx);
return 0; return 0;
......
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