commit 539663c401b087e4576e41af35144e73e1907c9d
author Florin Coras <fcoras@cisco.com> Fri Sep 28 14:59:37 2018 -0700
committer Damjan Marion <dmarion@me.com> Sat Sep 29 07:17:02 2018 +0000
tree e915b2c17f083daab1765be2072b1e4f7237e516
parent 537b17ef954b68d09b6f559dc05672cf7acfbe7c

vcl: handle old events before blocking in epoll

Change-Id: I3e62c787882d93c3bfb398ed0d04ef56b3a60b2b
Signed-off-by: Florin Coras <fcoras@cisco.com>

src/vcl/vppcom.c

diff --git a/src/vcl/vppcom.c b/src/vcl/vppcom.c
index 7274749..5423bb6 100644
--- a/src/vcl/vppcom.c
+++ b/src/vcl/vppcom.c
@@ -2421,6 +2421,9 @@
   session_event_t *e;
   int i;
 
+  if (vec_len (wrk->mq_msg_vector) && svm_msg_q_is_empty (mq))
+    goto handle_dequeued;
+
   svm_msg_q_lock (mq);
   if (svm_msg_q_is_empty (mq))
     {
@@ -2445,6 +2448,7 @@
   vcl_mq_dequeue_batch (wrk, mq);
   svm_msg_q_unlock (mq);
 
+handle_dequeued:
   for (i = 0; i < vec_len (wrk->mq_msg_vector); i++)
     {
       msg = vec_elt_at_index (wrk->mq_msg_vector, i);
@@ -2457,7 +2461,6 @@
 	  break;
 	}
     }
-
   vec_delete (wrk->mq_msg_vector, i, 0);
 
   return *num_ev;