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: add session event log for session state
[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
c29e059
..
8f6503d
100644
(file)
--- a/
src/vnet/session/session_node.c
+++ b/
src/vnet/session/session_node.c
@@
-486,13
+486,13
@@
session_mq_accepted_reply_handler (session_worker_t *wrk,
/* Special handling for cut-through sessions */
if (!session_has_transport (s))
{
/* Special handling for cut-through sessions */
if (!session_has_transport (s))
{
- s
->session_state = SESSION_STATE_READY
;
+ s
ession_set_state (s, SESSION_STATE_READY)
;
ct_session_connect_notify (s, SESSION_E_NONE);
return;
}
old_state = s->session_state;
ct_session_connect_notify (s, SESSION_E_NONE);
return;
}
old_state = s->session_state;
- s
->session_state = SESSION_STATE_READY
;
+ s
ession_set_state (s, SESSION_STATE_READY)
;
if (!svm_fifo_is_empty_prod (s->rx_fifo))
app_worker_lock_and_send_event (app_wrk, s, SESSION_IO_EVT_RX);
if (!svm_fifo_is_empty_prod (s->rx_fifo))
app_worker_lock_and_send_event (app_wrk, s, SESSION_IO_EVT_RX);
@@
-501,7
+501,7
@@
session_mq_accepted_reply_handler (session_worker_t *wrk,
if (old_state >= SESSION_STATE_TRANSPORT_CLOSING)
{
app_worker_close_notify (app_wrk, s);
if (old_state >= SESSION_STATE_TRANSPORT_CLOSING)
{
app_worker_close_notify (app_wrk, s);
- s
->session_state = old_state
;
+ s
ession_set_state (s, old_state)
;
return;
}
}
return;
}
}