From: Florin Coras <fcoras@cisco.com>
Date: Tue, 4 Apr 2023 18:51:37 +0000 (-0700)
Subject: session: fix ct connect session flush assert
X-Git-Tag: v23.10-rc0~98
X-Git-Url: https://gerrit.fd.io/r/gitweb?a=commitdiff_plain;h=1315d14d4c022d6fcfe43e6223b8ff557508b31f;p=vpp.git

session: fix ct connect session flush assert

Type: fix

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

diff --git a/src/vnet/session/application_local.c b/src/vnet/session/application_local.c
index ef46e99811f..6ac4da2c655 100644
--- a/src/vnet/session/application_local.c
+++ b/src/vnet/session/application_local.c
@@ -794,12 +794,14 @@ ct_fwrk_flush_connects (void *rpc_args)
   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 */