aboutsummaryrefslogtreecommitdiffstats
path: root/src/plugins/hs_apps/echo_client.c
diff options
context:
space:
mode:
authorFlorin Coras <fcoras@cisco.com>2025-01-21 16:07:28 -0500
committerDave Barach <vpp@barachs.net>2025-01-22 20:38:06 +0000
commit96b568a495114baccc391ca5030ad159cd082b74 (patch)
tree4e0c4826e3cadc83f3eb50a71e1cff8b42025089 /src/plugins/hs_apps/echo_client.c
parentb0761fd464936870a65f8d49eca8daa8215efdf2 (diff)
session: cleanup io event functions
Program session events using session handles instead of fifos. Type: improvement Change-Id: I69063190598c2b4dc1104f2938f27c6cd057341a Signed-off-by: Florin Coras <fcoras@cisco.com>
Diffstat (limited to 'src/plugins/hs_apps/echo_client.c')
-rw-r--r--src/plugins/hs_apps/echo_client.c8
1 files changed, 3 insertions, 5 deletions
diff --git a/src/plugins/hs_apps/echo_client.c b/src/plugins/hs_apps/echo_client.c
index d5edffbd02e..ff5a3bd6b3c 100644
--- a/src/plugins/hs_apps/echo_client.c
+++ b/src/plugins/hs_apps/echo_client.c
@@ -96,8 +96,7 @@ send_data_chunk (ec_main_t *ecm, ec_session_t *es)
svm_fifo_t *f = es->tx_fifo;
rv = clib_min (svm_fifo_max_enqueue_prod (f), bytes_this_chunk);
svm_fifo_enqueue_nocopy (f, rv);
- session_send_io_evt_to_thread_custom (
- &es->vpp_session_index, es->thread_index, SESSION_IO_EVT_TX);
+ session_program_tx_io_evt (es->tx_fifo->vpp_sh, SESSION_IO_EVT_TX);
}
else
rv =
@@ -132,8 +131,7 @@ send_data_chunk (ec_main_t *ecm, ec_session_t *es)
hdr.lcl_port = at->lcl_port;
svm_fifo_enqueue (f, sizeof (hdr), (u8 *) & hdr);
svm_fifo_enqueue_nocopy (f, rv);
- session_send_io_evt_to_thread_custom (
- &es->vpp_session_index, es->thread_index, SESSION_IO_EVT_TX);
+ session_program_tx_io_evt (es->tx_fifo->vpp_sh, SESSION_IO_EVT_TX);
}
else
{
@@ -543,7 +541,7 @@ ec_ctrl_send (hs_test_cmd_t cmd)
rv = svm_fifo_enqueue (s->tx_fifo, sizeof (ecm->cfg), (u8 *) &ecm->cfg);
ASSERT (rv == sizeof (ecm->cfg));
- session_send_io_evt_to_thread (s->tx_fifo, SESSION_IO_EVT_TX);
+ session_program_tx_io_evt (s->handle, SESSION_IO_EVT_TX);
return 0;
}