Commit 1b47544d authored by Jonathan Jenkins's avatar Jonathan Jenkins

RNG RC bug in loggp

Introduced back when I added a "last-hop" queue to allow prioritized
messages to go to the front of the set of msgs loggp is to receive. Haven't yet
put it in other models (simple*), so RNG bug doesn't affect there yet.
parent e2ded66e
......@@ -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
......
......@@ -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)
......
......@@ -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){
......
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