aboutsummaryrefslogtreecommitdiffstats
path: root/src/plugins
diff options
context:
space:
mode:
Diffstat (limited to 'src/plugins')
-rw-r--r--src/plugins/hs_apps/proxy.c4
-rw-r--r--src/plugins/hs_apps/sapi/vpp_echo.c6
-rw-r--r--src/plugins/hs_apps/sapi/vpp_echo_bapi.c4
-rw-r--r--src/plugins/unittest/session_test.c2
4 files changed, 10 insertions, 6 deletions
diff --git a/src/plugins/hs_apps/proxy.c b/src/plugins/hs_apps/proxy.c
index 7407bcb9f0d..f6b7f52d80c 100644
--- a/src/plugins/hs_apps/proxy.c
+++ b/src/plugins/hs_apps/proxy.c
@@ -830,7 +830,7 @@ active_open_alloc_session_fifos (session_t *s)
* will receive data, etc.
*/
txf->shr->master_session_index = s->session_index;
- txf->master_thread_index = s->thread_index;
+ txf->vpp_sh = s->handle;
/*
* Account for the active-open session's use of the fifos
@@ -1101,7 +1101,7 @@ active_open_rx_callback (session_t * s)
if (svm_fifo_set_event (proxy_tx_fifo))
{
u8 thread_index = proxy_tx_fifo->master_thread_index;
- u32 session_index = proxy_tx_fifo->shr->master_session_index;
+ u32 session_index = proxy_tx_fifo->vpp_session_index;
return session_send_io_evt_to_thread_custom (&session_index,
thread_index,
SESSION_IO_EVT_TX);
diff --git a/src/plugins/hs_apps/sapi/vpp_echo.c b/src/plugins/hs_apps/sapi/vpp_echo.c
index 08fd4e175e9..9ae95e6e8e9 100644
--- a/src/plugins/hs_apps/sapi/vpp_echo.c
+++ b/src/plugins/hs_apps/sapi/vpp_echo.c
@@ -69,9 +69,9 @@ echo_session_dequeue_notify (echo_session_t * s)
int rv;
if (!svm_fifo_set_event (s->rx_fifo))
return;
- if ((rv = app_send_io_evt_to_vpp (s->vpp_evt_q,
- s->rx_fifo->shr->master_session_index,
- SESSION_IO_EVT_RX, SVM_Q_WAIT)))
+ if ((rv =
+ app_send_io_evt_to_vpp (s->vpp_evt_q, s->rx_fifo->vpp_session_index,
+ SESSION_IO_EVT_RX, SVM_Q_WAIT)))
ECHO_FAIL (ECHO_FAIL_SEND_IO_EVT, "app_send_io_evt_to_vpp errored %d",
rv);
svm_fifo_clear_deq_ntf (s->rx_fifo);
diff --git a/src/plugins/hs_apps/sapi/vpp_echo_bapi.c b/src/plugins/hs_apps/sapi/vpp_echo_bapi.c
index 868cc3a0591..12be20503a3 100644
--- a/src/plugins/hs_apps/sapi/vpp_echo_bapi.c
+++ b/src/plugins/hs_apps/sapi/vpp_echo_bapi.c
@@ -332,6 +332,10 @@ echo_attach_session (uword segment_handle, uword rxf_offset, uword txf_offset,
s->tx_fifo = fifo_segment_alloc_fifo_w_offset (fs, txf_offset);
s->rx_fifo->segment_index = fs_index;
s->tx_fifo->segment_index = fs_index;
+ s->rx_fifo->vpp_session_index = s->rx_fifo->shr->master_session_index;
+ s->tx_fifo->vpp_session_index = s->tx_fifo->shr->master_session_index;
+ s->rx_fifo->app_session_index = s->session_index;
+ s->tx_fifo->app_session_index = s->session_index;
s->rx_fifo->shr->client_session_index = s->session_index;
s->tx_fifo->shr->client_session_index = s->session_index;
diff --git a/src/plugins/unittest/session_test.c b/src/plugins/unittest/session_test.c
index fe4664bda4a..993f1be41a9 100644
--- a/src/plugins/unittest/session_test.c
+++ b/src/plugins/unittest/session_test.c
@@ -1864,7 +1864,7 @@ test_app_send_io_evt_rx (app_worker_t *app_wrk, session_t *s)
if (svm_fifo_has_event (s->rx_fifo))
return 0;
- app_session = s->rx_fifo->shr->client_session_index;
+ app_session = s->rx_fifo->app_session_index;
mq = app_wrk->event_queue;
rv = test_mq_try_lock_and_alloc_msg (mq, SESSION_MQ_IO_EVT_RING, mq_msg);