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: use safe realloc for pools
[vpp.git]
/
src
/
vnet
/
session
/
transport.c
diff --git
a/src/vnet/session/transport.c
b/src/vnet/session/transport.c
index
e4d84a3
..
540d6a6
100644
(file)
--- a/
src/vnet/session/transport.c
+++ b/
src/vnet/session/transport.c
@@
-341,7
+341,7
@@
transport_reset (transport_proto_t tp, u32 conn_index, u8 thread_index)
u32
transport_start_listen (transport_proto_t tp, u32 session_index,
u32
transport_start_listen (transport_proto_t tp, u32 session_index,
- transport_endpoint_
t *
tep)
+ transport_endpoint_
cfg_t *
tep)
{
return tp_vfts[tp].start_listen (session_index, tep);
}
{
return tp_vfts[tp].start_listen (session_index, tep);
}
@@
-668,7
+668,7
@@
spacer_max_burst (spacer_t * pacer, clib_us_time_t time_now)
pacer->bucket = clib_min (pacer->bucket + inc, (i64) pacer->max_burst);
}
pacer->bucket = clib_min (pacer->bucket + inc, (i64) pacer->max_burst);
}
- return pacer->bucket > 0 ? pacer->max_burst : 0;
+ return pacer->bucket >
=
0 ? pacer->max_burst : 0;
}
static inline void
}
static inline void
@@
-790,7
+790,7
@@
void
transport_connection_reschedule (transport_connection_t * tc)
{
tc->flags &= ~TRANSPORT_CONNECTION_F_DESCHED;
transport_connection_reschedule (transport_connection_t * tc)
{
tc->flags &= ~TRANSPORT_CONNECTION_F_DESCHED;
- transport_connection_tx_pacer_reset_bucket (tc,
TRANSPORT_PACER_MIN_BURST
);
+ transport_connection_tx_pacer_reset_bucket (tc,
0 /* bucket */
);
if (transport_max_tx_dequeue (tc))
sesssion_reschedule_tx (tc);
else
if (transport_max_tx_dequeue (tc))
sesssion_reschedule_tx (tc);
else
@@
-830,6
+830,9
@@
transport_enable_disable (vlib_main_t * vm, u8 is_en)
{
if (vft->enable)
(vft->enable) (vm, is_en);
{
if (vft->enable)
(vft->enable) (vm, is_en);
+
+ if (vft->update_time)
+ session_register_update_time_fn (vft->update_time, is_en);
}
}
}
}