Commit bab45d08 authored by Jonathan Jenkins's avatar Jonathan Jenkins

fix to loggp latency calculation when using "receive queue"

parent 5c89e29c
......@@ -68,6 +68,7 @@ void model_net_method_send_msg_recv_event(
const char * category,
int net_id,
void * msg,
tw_stime offset,
tw_lp *sender);
// just need to reverse an RNG for the time being
void model_net_method_send_msg_recv_event_rc(tw_lp *sender);
......
......@@ -564,7 +564,8 @@ static void handle_msg_start_event(
#if USE_RECV_QUEUE
model_net_method_send_msg_recv_event(m->final_dest_gid, dest_id, m->src_gid,
m->net_msg_size_bytes, m->is_pull, m->pull_size,
m->event_size_bytes, &m->sched_params, m->category, LOGGP, m, lp);
m->event_size_bytes, &m->sched_params, m->category, LOGGP, m,
send_queue_time, lp);
#else
void *m_data;
// printf("\n msg start sending to %d ", dest_id);
......
......@@ -521,9 +521,10 @@ void model_net_method_send_msg_recv_event(
const char * category,
int net_id,
void * msg,
tw_stime offset,
tw_lp *sender){
tw_event *e =
tw_event_new(dest_mn_lp, codes_local_latency(sender), sender);
tw_event_new(dest_mn_lp, offset+codes_local_latency(sender), sender);
model_net_wrap_msg *m = tw_event_data(e);
msg_set_header(model_net_base_magic, MN_BASE_NEW_MSG, sender->gid, &m->h);
......
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