commit 1315d14d4c022d6fcfe43e6223b8ff557508b31f
author Florin Coras <fcoras@cisco.com> Tue Apr 04 11:51:37 2023 -0700
committer Florin Coras <florin.coras@gmail.com> Tue Apr 04 20:36:29 2023 +0000
tree d73b8898fd81114c2bb8decc3f7ac5de69366c21
parent 156d452750ab37a51984938bf4a8ab0e16650d82

session: fix ct connect session flush assert

Type: fix

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

src/vnet/session/application_local.c

diff --git a/src/vnet/session/application_local.c b/src/vnet/session/application_local.c
index ef46e99..6ac4da2 100644
--- a/src/vnet/session/application_local.c
+++ b/src/vnet/session/application_local.c
@@ -794,12 +794,14 @@
   ct_worker_t *wrk;
   u8 need_rpc;
 
-  fwrk_index = pointer_to_uword (rpc_args);
-  ASSERT (fwrk_index == cm->fwrk_thread);
+  fwrk_index = cm->fwrk_thread;
   n_workers = vec_len (cm->fwrk_pending_connects);
 
   for (thread_index = fwrk_index; thread_index < n_workers; thread_index++)
     {
+      if (!vec_len (cm->fwrk_pending_connects[thread_index]))
+	continue;
+
       wrk = ct_worker_get (thread_index);
 
       /* Connects can be done without worker barrier, grab dst worker lock */