_(EVENT_FIFO_FULL, "Events not sent for lack of event fifo space") \
_(API_QUEUE_FULL, "Sessions not created for lack of API queue space") \
_(NEW_SEG_NO_SPACE, "Created segment, couldn't allocate a fifo pair") \
-_(NO_SPACE, "Couldn't allocate a fifo pair")
+_(NO_SPACE, "Couldn't allocate a fifo pair") \
+_(SEG_CREATE, "Couldn't create a new segment")
typedef enum
{
/** Per worker thread session pools */
stream_session_t **sessions;
- /** Per worker-thread count of threads peeking into the session pool */
- u32 *session_peekers;
-
- /** Per worker-thread rw peekers locks */
- clib_spinlock_t *peekers_readers_locks;
- clib_spinlock_t *peekers_write_locks;
+ /** Per worker-thread session pool peekers rw locks */
+ clib_rwlock_t *peekers_rw_locks;
/** Pool of listen sessions. Same type as stream sessions to ease lookups */
stream_session_t **listen_sessions;
/** Session ssvm segment configs*/
uword session_baseva;
- u32 segment_timeout;
+ uword session_va_space_size;
u32 evt_qs_segment_size;
u8 evt_qs_use_memfd_seg;
session_manager_main_t *smm = &session_manager_main;
if (thread_index == vlib_get_thread_index ())
return;
- clib_spinlock_lock_if_init (&smm->peekers_readers_locks[thread_index]);
- smm->session_peekers[thread_index] += 1;
- if (smm->session_peekers[thread_index] == 1)
- clib_spinlock_lock_if_init (&smm->peekers_write_locks[thread_index]);
- clib_spinlock_unlock_if_init (&smm->peekers_readers_locks[thread_index]);
+ clib_rwlock_reader_lock (&smm->peekers_rw_locks[thread_index]);
}
always_inline void
session_manager_main_t *smm = &session_manager_main;
if (thread_index == vlib_get_thread_index ())
return;
- ASSERT (session_manager_main.session_peekers[thread_index] > 0);
- clib_spinlock_lock_if_init (&smm->peekers_readers_locks[thread_index]);
- smm->session_peekers[thread_index] -= 1;
- if (smm->session_peekers[thread_index] == 0)
- clib_spinlock_unlock_if_init (&smm->peekers_write_locks[thread_index]);
- clib_spinlock_unlock_if_init (&smm->peekers_readers_locks[thread_index]);
+ clib_rwlock_reader_unlock (&smm->peekers_rw_locks[thread_index]);
}
/**
int stream_session_listen (stream_session_t * s, session_endpoint_t * tep);
int stream_session_stop_listen (stream_session_t * s);
void stream_session_disconnect (stream_session_t * s);
+void stream_session_disconnect_transport (stream_session_t * s);
void stream_session_cleanup (stream_session_t * s);
void session_send_session_evt_to_thread (u64 session_handle,
fifo_event_type_t evt_type,