Commit 971c4675 authored by Matthieu Dorier's avatar Matthieu Dorier

removed irecv for now

parent 78d42ca0
......@@ -18,6 +18,7 @@ typedef void (*cortex_send_handler)(void* ctx, int size, int dest, int tag);
typedef void (*cortex_recv_handler)(void* ctx, int size, int src, int tag, const codes_mpi_future* future);
typedef void (*cortex_irecv_handler)(void* ctx, int size, int src, int tag, int req, const codes_mpi_future* future);
typedef void (*cortex_wtime_handler)(void* ctx, const codes_mpi_future* future);
//typedef void (*cortex_wait_handler)(void* ctx, int req);
//typedef void (*cortex_finalize_handler)(void* ctx);
typedef struct {
......@@ -26,6 +27,7 @@ typedef struct {
cortex_recv_handler do_recv;
cortex_irecv_handler do_irecv;
cortex_wtime_handler do_wtime;
// cortex_wait_handler do_wait;
// cortex_finalize_handler do_finalize;
} cortex_comm_handler;
......
......@@ -212,6 +212,19 @@ void handleCortexWtime(void* ctx, const codes_mpi_future* future) {
cortex_insert_next_op(myctx->cortex_mpi_array, &wrkld_per_rank);
}
/*
void handleCortexWait(void* ctx, int req) {
rank_mpi_context* myctx = (rank_mpi_context*)ctx;
struct codes_workload_op wrkld_per_rank;
wrkld_per_rank.op_type = CODES_WK_WAIT;
wrkld_per_rank.u.wait.req_id = req;
cortex_insert_next_op(myctx->cortex_mpi_array, &wrkld_per_rank);
}
*/
static int hash_rank_compare(void *key, struct qhash_head *link)
{
rank_mpi_compare *in = key;
......@@ -262,6 +275,7 @@ int cortex_trace_nw_workload_load(const char* params, int app_id, int rank)
.do_recv = handleCortexRecv,
.do_irecv = handleCortexIRecv,
.do_wtime = handleCortexWtime,
//.do_wait = handleCortexWait
//.do_finalize = cortex_finalize_mpi_op_data
};
/* now execute the collective algorithm */
......
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