From 1315d14d4c022d6fcfe43e6223b8ff557508b31f Mon Sep 17 00:00:00 2001 From: Florin Coras Date: Tue, 4 Apr 2023 11:51:37 -0700 Subject: [PATCH] session: fix ct connect session flush assert Type: fix Signed-off-by: Florin Coras Change-Id: I90eaeed07dc4864adfed3bc4cef1e3edacf4bf8f --- src/vnet/session/application_local.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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 */ -- 2.16.6