...
 
Commits (2)
......@@ -133,6 +133,9 @@ typedef struct model_net_request {
int remote_event_size;
int self_event_size;
char category[CATEGORY_NAME_MAX];
//Xin: passing app id to routers
int app_id;
} model_net_request;
/* data structure for tracking network statistics */
......
......@@ -87,6 +87,11 @@ struct terminal_custom_message
tw_stime msg_start_time;
tw_stime saved_busy_time_ross;
tw_stime saved_fin_chunks_ross;
//Yao: for counting msg app id
int app_id;
tw_stime last_received_time;
tw_stime last_sent_time;
};
#ifdef __cplusplus
......
......@@ -95,6 +95,11 @@ struct terminal_dally_message
tw_stime msg_start_time;
tw_stime saved_busy_time_ross;
tw_stime saved_fin_chunks_ross;
//Yao: for counting msg app id
int app_id;
tw_stime last_received_time;
tw_stime last_sent_time;
};
#ifdef __cplusplus
......
......@@ -109,6 +109,12 @@ struct terminal_plus_message
tw_stime msg_start_time;
tw_stime saved_busy_time_ross;
tw_stime saved_fin_chunks_ross;
//Yao: for counting msg app id
int app_id;
tw_stime last_received_time;
tw_stime last_sent_time;
};
#ifdef __cplusplus
......
This diff is collapsed.
This diff is collapsed.
......@@ -368,6 +368,12 @@ static model_net_event_return model_net_event_impl_base(
strncpy(r->category, category, CATEGORY_NAME_MAX-1);
r->category[CATEGORY_NAME_MAX-1]='\0';
//Xin: passing app_id to the request struct
int ptroffset;
configuration_get_value_int(&config, "PARAMS", "offset", NULL, &ptroffset);
const int *id_ptr = remote_event+ptroffset;
r->app_id = *id_ptr;
if (is_msg_params_set[MN_MSG_PARAM_START_TIME])
r->msg_start_time = start_time_param;
else
......
......@@ -68,7 +68,7 @@ static int parse_line(
buf[pos]='\0';
}
int list_cap = 8;
int list_cap = 20;
int *lst = malloc(list_cap * sizeof(*lst));
assert(lst);
int rank;
......@@ -114,7 +114,7 @@ static int jobmap_list_configure(void const * params, void ** ctx)
// job storage
lst->num_jobs = 0;
int job_cap = 8;
int job_cap = 20;
lst->rank_counts = calloc(job_cap, sizeof(*lst->rank_counts));
assert(lst->rank_counts);
lst->global_ids = calloc(job_cap, sizeof(*lst->global_ids));
......
......@@ -34,6 +34,8 @@
#define DBG_COMM 0
#define MIN(a,b) ((a) < (b)) ? (a) : (b)
using namespace std;
static struct qhash_table *rank_tbl = NULL;
......@@ -136,6 +138,7 @@ void COWG_MPI_Finalize()
// num_sends, num_recvs, num_isends, num_irecvs, num_allreduce, num_barriers, num_waitalls);
// printf("Rank %d yield to CODES thread: %p\n", sctx->my_rank, global_prod_thread);
}
ABT_thread_yield_to(global_prod_thread);
}
......