Commit 47bfa384 authored by Misbah Mubarak's avatar Misbah Mubarak

Fixing reverse handler of cortex workload

parent d913778c
...@@ -723,7 +723,7 @@ static void codes_exec_mpi_recv_rc( ...@@ -723,7 +723,7 @@ static void codes_exec_mpi_recv_rc(
{ {
update_completed_queue_rc(ns, bf, m, lp); update_completed_queue_rc(ns, bf, m, lp);
} }
codes_issue_next_event_rc(lp); codes_issue_next_event_rc(lp);
} }
else if(m->fwd.found_match < 0) else if(m->fwd.found_match < 0)
{ {
...@@ -1008,6 +1008,9 @@ static void update_arrival_queue_rc(nw_state* s, ...@@ -1008,6 +1008,9 @@ static void update_arrival_queue_rc(nw_state* s,
} }
if(qi->op_type == CODES_WK_IRECV) if(qi->op_type == CODES_WK_IRECV)
update_completed_queue_rc(s, bf, m, lp); update_completed_queue_rc(s, bf, m, lp);
else if(qi->op_type == CODES_WK_RECV)
codes_issue_next_event_rc(lp);
} }
else if(m->fwd.found_match < 0) else if(m->fwd.found_match < 0)
{ {
...@@ -1067,7 +1070,6 @@ static void update_arrival_queue(nw_state* s, tw_bf * bf, nw_message * m, tw_lp ...@@ -1067,7 +1070,6 @@ static void update_arrival_queue(nw_state* s, tw_bf * bf, nw_message * m, tw_lp
{ {
m->fwd.found_match = found_matching_recv; m->fwd.found_match = found_matching_recv;
free(arrived_op); free(arrived_op);
} }
} }
static void update_message_time( static void update_message_time(
......
...@@ -120,7 +120,6 @@ static void cortex_roll_back_prev_op(void * mpi_op_array) ...@@ -120,7 +120,6 @@ static void cortex_roll_back_prev_op(void * mpi_op_array)
{ {
cortex_op_data_array *array = (cortex_op_data_array*)mpi_op_array; cortex_op_data_array *array = (cortex_op_data_array*)mpi_op_array;
array->op_arr_ndx--; array->op_arr_ndx--;
assert(array->op_arr_ndx >= 0);
} }
/* removes the next operation from the array */ /* removes the next operation from the array */
static void cortex_remove_next_op(void *mpi_op_array, struct codes_workload_op *mpi_op) static void cortex_remove_next_op(void *mpi_op_array, struct codes_workload_op *mpi_op)
...@@ -134,8 +133,9 @@ static void cortex_remove_next_op(void *mpi_op_array, struct codes_workload_op * ...@@ -134,8 +133,9 @@ static void cortex_remove_next_op(void *mpi_op_array, struct codes_workload_op *
{ {
struct codes_workload_op *tmp = &(array->op_array[array->op_arr_ndx]); struct codes_workload_op *tmp = &(array->op_array[array->op_arr_ndx]);
*mpi_op = *tmp; *mpi_op = *tmp;
array->op_arr_ndx++;
} }
array->op_arr_ndx++;
} }
int handleCortexSend(int app_id, int rank, int size, int dest, int tag, void* uarg) int handleCortexSend(int app_id, int rank, int size, int dest, int tag, void* uarg)
......
...@@ -179,7 +179,7 @@ static void dumpi_remove_next_op(void *mpi_op_array, struct codes_workload_op *m ...@@ -179,7 +179,7 @@ static void dumpi_remove_next_op(void *mpi_op_array, struct codes_workload_op *m
{ {
struct codes_workload_op *tmp = &(array->op_array[array->op_arr_ndx]); struct codes_workload_op *tmp = &(array->op_array[array->op_arr_ndx]);
*mpi_op = *tmp; *mpi_op = *tmp;
array->op_arr_ndx--; array->op_arr_ndx++;
} }
/*if(mpi_op->op_type == CODES_WK_END) /*if(mpi_op->op_type == CODES_WK_END)
{ {
......
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