Commit 5be6a254 authored by Xin's avatar Xin

for experiments

parent d147259f
......@@ -57,7 +57,7 @@ static uint64_t EAGER_THRESHOLD = 8192;
static int alloc_spec = 0;
static tw_stime self_overhead = 10.0;
static tw_stime mean_interval = 100000;
static tw_stime mean_interval = 10000;
static int payload_sz = 1024;
/* Doing LP IO*/
......
......@@ -48,6 +48,8 @@ static struct qhash_table *rank_tbl = NULL;
static int rank_tbl_pop = 0;
static unsigned int max_threshold = INT_MAX;
//static unsigned int max_threshold = 4000;
/* context of the MPI workload */
typedef struct rank_mpi_context
{
......@@ -57,6 +59,7 @@ typedef struct rank_mpi_context
int is_init;
int num_reqs;
unsigned int num_ops;
unsigned int num_allreduce;
int64_t my_rank;
double last_op_time;
double init_time;
......@@ -712,8 +715,8 @@ int handleDUMPIAllreduce(const dumpi_allreduce *prm, uint16_t thread,
wrkld_per_rank.op_type = CODES_WK_ALLREDUCE;
wrkld_per_rank.u.collective.num_bytes = prm->count * get_num_bytes(myctx,prm->datatype);
assert(wrkld_per_rank.u.collective.num_bytes > 0);
assert(wrkld_per_rank.u.collective.num_bytes > 0);
myctx->num_allreduce += 1;
update_times_and_insert(&wrkld_per_rank, wall, myctx);
return 0;
}
......@@ -795,6 +798,7 @@ int dumpi_trace_nw_workload_load(const char* params, int app_id, int rank)
my_ctx->num_reqs = 0;
my_ctx->dumpi_mpi_array = dumpi_init_op_data();
my_ctx->num_ops = 0;
my_ctx->num_allreduce = 0;
if(rank < 10)
sprintf(file_name, "%s000%d.bin", dumpi_params->file_name, rank);
......@@ -943,7 +947,7 @@ int dumpi_trace_nw_workload_load(const char* params, int app_id, int rank)
num_calls++;
my_ctx->num_ops++;
#ifdef ENABLE_CORTEX
if(my_ctx->num_ops < max_threshold)
if(my_ctx->num_allreduce < max_threshold)
active = cortex_undumpi_read_single_call(profile, callarr, transarr, (void*)my_ctx, &finalize_reached);
else
{
......
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