diff options
| author |   Florin Coras <fcoras@cisco.com> | 2018-07-12 14:48:06 -0700 |
|---|---|---|
| committer |   Damjan Marion <dmarion@me.com> | 2018-07-17 09:02:17 +0000 |
| commit | 52207f1b7b60cb0784d5241f0a4d40eef531c67e (patch) | |
| tree | b83a1f01bd08872a2ae27e17f2fd0ddeb3f571b6 /src/vnet/session/session.c | |
| parent | 3c2fed5145d9e40a9ecd178c2866c813eddc6203 (diff) | |
session: send ctrl msg over mq
Change-Id: I242056bc46ddb671064665916b2687860292dcb2
Signed-off-by: Florin Coras <fcoras@cisco.com>
Diffstat (limited to 'src/vnet/session/session.c')
| -rw-r--r-- | src/vnet/session/session.c | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/vnet/session/session.c b/src/vnet/session/session.c index 38a0521af94..897cb1a5a1e 100644 --- a/src/vnet/session/session.c +++ b/src/vnet/session/session.c @@ -31,7 +31,7 @@ static inline int session_send_evt_to_thread (void *data, void *args, u32 thread_index, session_evt_type_t evt_type) { - session_fifo_event_t *evt; + session_event_t *evt; svm_msg_q_msg_t msg; svm_msg_q_t *mq; u32 tries = 0, max_tries; @@ -57,7 +57,7 @@ session_send_evt_to_thread (void *data, void *args, u32 thread_index, svm_msg_q_unlock (mq); return -2; } - evt = (session_fifo_event_t *) svm_msg_q_msg_data (mq, &msg); + evt = (session_event_t *) svm_msg_q_msg_data (mq, &msg); evt->event_type = evt_type; switch (evt_type) { @@ -78,8 +78,7 @@ session_send_evt_to_thread (void *data, void *args, u32 thread_index, return -1; } - svm_msg_q_add_w_lock (mq, &msg); - svm_msg_q_unlock (mq); + svm_msg_q_add_and_unlock (mq, &msg); return 0; } @@ -1095,7 +1094,7 @@ stream_session_disconnect (stream_session_t * s) { u32 thread_index = vlib_get_thread_index (); session_manager_main_t *smm = &session_manager_main; - session_fifo_event_t *evt; + session_event_t *evt; if (!s) return; @@ -1197,7 +1196,7 @@ session_tx_is_dgram (stream_session_t * s) void session_vpp_event_queues_allocate (session_manager_main_t * smm) { - u32 evt_q_length = 2048, evt_size = sizeof (session_fifo_event_t); + u32 evt_q_length = 2048, evt_size = sizeof (session_event_t); ssvm_private_t *eqs = &smm->evt_qs_segment; api_main_t *am = &api_main; u64 eqs_size = 64 << 20; |