Code Review
/
vpp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
session: segment handle in accept/connect notifications
[vpp.git]
/
src
/
vnet
/
session
/
session_node.c
diff --git
a/src/vnet/session/session_node.c
b/src/vnet/session/session_node.c
index
64c873c
..
cf2d576
100644
(file)
--- a/
src/vnet/session/session_node.c
+++ b/
src/vnet/session/session_node.c
@@
-99,7
+99,7
@@
session_mq_reset_reply_handler (void *data)
s = session_get_if_valid (index, thread_index);
if (!s)
{
s = session_get_if_valid (index, thread_index);
if (!s)
{
-
clib_warning
("Invalid session!");
+
SESSION_DBG
("Invalid session!");
return;
}
app_wrk = app_worker_get (s->app_wrk_index);
return;
}
app_wrk = app_worker_get (s->app_wrk_index);
@@
-751,7
+751,7
@@
static void
session_update_dispatch_period (session_manager_worker_t * wrk, f64 now,
u32 thread_index)
{
session_update_dispatch_period (session_manager_worker_t * wrk, f64 now,
u32 thread_index)
{
- if (wrk->last_tx_packets
> 1
)
+ if (wrk->last_tx_packets)
{
f64 sample = now - wrk->last_vlib_time;
wrk->dispatch_period = (wrk->dispatch_period + sample) * 0.5;
{
f64 sample = now - wrk->last_vlib_time;
wrk->dispatch_period = (wrk->dispatch_period + sample) * 0.5;
@@
-800,7
+800,7
@@
session_queue_node_fn (vlib_main_t * vm, vlib_node_runtime_t * node,
{
vec_add2 (fifo_events, e, 1);
svm_msg_q_sub_w_lock (mq, msg);
{
vec_add2 (fifo_events, e, 1);
svm_msg_q_sub_w_lock (mq, msg);
- clib_memcpy (e, svm_msg_q_msg_data (mq, msg), sizeof (*e));
+ clib_memcpy
_fast
(e, svm_msg_q_msg_data (mq, msg), sizeof (*e));
svm_msg_q_free_msg (mq, msg);
}
svm_msg_q_unlock (mq);
svm_msg_q_free_msg (mq, msg);
}
svm_msg_q_unlock (mq);
@@
-961,7
+961,7
@@
dump_thread_0_event_queue (void)
{
msg = (svm_msg_q_msg_t *) (&mq->q->data[0] + mq->q->elsize * index);
ring = svm_msg_q_ring (mq, msg->ring_index);
{
msg = (svm_msg_q_msg_t *) (&mq->q->data[0] + mq->q->elsize * index);
ring = svm_msg_q_ring (mq, msg->ring_index);
- clib_memcpy (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
+ clib_memcpy
_fast
(e, svm_msg_q_msg_data (mq, msg), ring->elsize);
switch (e->event_type)
{
switch (e->event_type)
{
@@
-1053,7
+1053,7
@@
session_node_lookup_fifo_event (svm_fifo_t * f, session_event_t * e)
{
msg = (svm_msg_q_msg_t *) (&mq->q->data[0] + mq->q->elsize * index);
ring = svm_msg_q_ring (mq, msg->ring_index);
{
msg = (svm_msg_q_msg_t *) (&mq->q->data[0] + mq->q->elsize * index);
ring = svm_msg_q_ring (mq, msg->ring_index);
- clib_memcpy (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
+ clib_memcpy
_fast
(e, svm_msg_q_msg_data (mq, msg), ring->elsize);
found = session_node_cmp_event (e, f);
if (found)
return 1;
found = session_node_cmp_event (e, f);
if (found)
return 1;
@@
-1069,7
+1069,7
@@
session_node_lookup_fifo_event (svm_fifo_t * f, session_event_t * e)
found = session_node_cmp_event (evt, f);
if (found)
{
found = session_node_cmp_event (evt, f);
if (found)
{
- clib_memcpy (e, evt, sizeof (*evt));
+ clib_memcpy
_fast
(e, evt, sizeof (*evt));
break;
}
}
break;
}
}