Merge branch 'master' of git.mcs.anl.gov:radix/codes-net

codes/model-net-lp.h

@@ -69,6 +69,8 @@ void model_net_method_send_msg_recv_event(
         int net_id,
         void * msg,
         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);
 
 // Issue an event from the underlying model (e.g., simplenet, loggp) to tell the
 // scheduler when next to issue a packet event. As different models update their

src/models/networks/model-net/loggp.c

@@ -357,6 +357,10 @@ static void handle_msg_ready_rev_event(
     stat->recv_bytes -= m->net_msg_size_bytes;
     stat->recv_time -= m->recv_time_saved;
 
+#if USE_RECV_QUEUE
+    codes_local_latency_reverse(lp);
+#endif
+
     if (m->event_size_bytes && m->is_pull){
         int net_id = model_net_get_id(LP_METHOD_NM);
         model_net_event_rc(net_id, lp, m->pull_size);
@@ -465,6 +469,10 @@ static void handle_msg_start_rev_event(
 
     ns->net_send_next_idle = m->net_send_next_idle_saved;
 
+#if USE_RECV_QUEUE
+    model_net_method_send_msg_recv_event_rc(lp);
+#endif
+
     codes_local_latency_reverse(lp);
 
     if(m->local_event_size_bytes > 0)

src/models/networks/model-net/model-net-lp.c

@@ -557,6 +557,10 @@ void model_net_method_send_msg_recv_event(
     tw_event_send(e);
 }
 
+void model_net_method_send_msg_recv_event_rc(tw_lp *sender){
+    codes_local_latency_reverse(sender);
+}
+
 
 void model_net_method_idle_event(tw_stime offset_ts, int is_recv_queue,
         tw_lp * lp){