aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/vnet/session/application_local.c6
1 files 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 */