aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGabriel Oginski <gabrielx.oginski@intel.com>2023-07-07 11:58:26 +0000
committerFan Zhang <fanzhang.oss@gmail.com>2023-07-24 08:15:21 +0000
commitc3f505fe7b7fbecb35494863a6c9de3cad6e6d2d (patch)
tree630aa85fcfa1a59622c14b502481650cf31f0819
parentaf9b7156c8fd16c671ce9332613faaf864b075b3 (diff)
vpp-swan: fix handler API messages
In the current implementation there is a bug related to the incorrect message handling due to the wrong id. The fix changes logic responsible for handling incoming API messages by correcting their ids. Type: fix Signed-off-by: Gabriel Oginski <gabrielx.oginski@intel.com> Change-Id: Iea29506053c9fd2e1d01bce83e7f4a6e1de39321
-rw-r--r--extras/strongswan/vpp_sswan/kernel_vpp_shared.c45
1 files changed, 26 insertions, 19 deletions
diff --git a/extras/strongswan/vpp_sswan/kernel_vpp_shared.c b/extras/strongswan/vpp_sswan/kernel_vpp_shared.c
index 9eabb6879d1..e958866b853 100644
--- a/extras/strongswan/vpp_sswan/kernel_vpp_shared.c
+++ b/extras/strongswan/vpp_sswan/kernel_vpp_shared.c
@@ -296,41 +296,50 @@ vac_rx_thread_fn (private_vac_t *this)
q = am->vl_input_queue;
+ const u16 msg_id_rx_thread_exit =
+ vl_msg_api_get_msg_index ((u8 *) "rx_thread_exit_c3a3a452");
+ const u16 msg_id_memclnt_rx_thread_suspend =
+ vl_msg_api_get_msg_index ((u8 *) "memclnt_rx_thread_suspend_c3a3a452");
+ const u16 msg_id_memclnt_read_timeout =
+ vl_msg_api_get_msg_index ((u8 *) "memclnt_read_timeout_c3a3a452");
+ const u16 msg_id_memclnt_keepalive =
+ vl_msg_api_get_msg_index ((u8 *) "memclnt_keepalive_51077d14");
+
while (TRUE)
{
while (!svm_queue_sub (q, (u8 *) &msg, SVM_Q_WAIT, 0))
{
u16 id = ntohs (*((u16 *) msg));
- switch (id)
+
+ if (msg_id_rx_thread_exit == id)
{
- case VL_API_RX_THREAD_EXIT:
vl_msg_api_free ((void *) msg);
this->queue_lock->lock (this->queue_lock);
this->terminate_cv->signal (this->terminate_cv);
this->queue_lock->unlock (this->queue_lock);
DBG3 (DBG_KNL, "vac received rx thread exit [%d]",
- VL_API_RX_THREAD_EXIT);
+ msg_id_rx_thread_exit);
thread_exit (NULL);
return NULL;
- break;
-
- case VL_API_MEMCLNT_RX_THREAD_SUSPEND:
+ }
+ else if (msg_id_memclnt_rx_thread_suspend == id)
+ {
vl_msg_api_free ((void *) msg);
this->queue_lock->lock (this->queue_lock);
this->suspend_cv->signal (this->suspend_cv);
this->resume_cv->wait (this->resume_cv, this->queue_lock);
this->queue_lock->unlock (this->queue_lock);
DBG3 (DBG_KNL, "vac received rx thread suspend [%d]",
- VL_API_MEMCLNT_RX_THREAD_SUSPEND);
- break;
-
- case VL_API_MEMCLNT_READ_TIMEOUT:
+ msg_id_memclnt_rx_thread_suspend);
+ }
+ else if (msg_id_memclnt_read_timeout == id)
+ {
DBG3 (DBG_KNL, "vac received read timeout [%d]",
- VL_API_MEMCLNT_READ_TIMEOUT);
+ msg_id_memclnt_read_timeout);
vl_msg_api_free ((void *) msg);
- break;
-
- case VL_API_MEMCLNT_KEEPALIVE:
+ }
+ else if (msg_id_memclnt_keepalive == id)
+ {
mp = (void *) msg;
rmp = vl_msg_api_alloc (sizeof (*rmp));
memset (rmp, 0, sizeof (*rmp));
@@ -342,12 +351,10 @@ vac_rx_thread_fn (private_vac_t *this)
vl_msg_api_send_shmem (shmem_hdr->vl_input_queue, (u8 *) &rmp);
vl_msg_api_free ((void *) msg);
DBG3 (DBG_KNL, "vac received keepalive %d",
- VL_API_MEMCLNT_KEEPALIVE);
- break;
-
- default:
- vac_api_handler (this, (void *) msg);
+ msg_id_memclnt_keepalive);
}
+ else
+ vac_api_handler (this, (void *) msg);
}
}