Type: improvement
Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: I6cf0c141ab4a4f5a46feb6119fa142148366f0a6
int off = 0, ret, i = 0, read = 0, len;
const int n_segs = 4, max_len = 32768;
svm_fifo_t *tcp_rx_fifo, *app_rx_fifo;
int off = 0, ret, i = 0, read = 0, len;
const int n_segs = 4, max_len = 32768;
svm_fifo_t *tcp_rx_fifo, *app_rx_fifo;
+ picotls_main_t *pm = &picotls_main;
svm_fifo_seg_t fs[n_segs];
session_t *app_session;
svm_fifo_seg_t fs[n_segs];
session_t *app_session;
uword deq_now;
if (PREDICT_FALSE (!ptls_handshake_is_complete (ptls_ctx->tls)))
uword deq_now;
if (PREDICT_FALSE (!ptls_handshake_is_complete (ptls_ctx->tls)))
if (len <= 0)
goto final_checks;
if (len <= 0)
goto final_checks;
- ptls_buffer_init (buf, "", 0);
+ thread_index = ptls_ctx->ctx.c_thread_index;
+ vec_validate (pm->rx_bufs[thread_index], 2 * max_len);
+ ptls_buffer_init (buf, pm->rx_bufs[thread_index], 2 * max_len);
ptls_ctx->read_buffer_offset = 0;
while (read < len && i < n_segs)
ptls_ctx->read_buffer_offset = 0;
while (read < len && i < n_segs)
- ptls_buffer_dispose (buf);
+ buf->off = 0;
+ ptls_ctx->read_buffer_offset = 0;
}
if (app_session->session_state >= SESSION_STATE_READY)
}
if (app_session->session_state >= SESSION_STATE_READY)
num_threads = 1 + vtm->n_threads;
vec_validate (pm->ctx_pool, num_threads - 1);
num_threads = 1 + vtm->n_threads;
vec_validate (pm->ctx_pool, num_threads - 1);
+ vec_validate (pm->rx_bufs, num_threads - 1);
clib_rwlock_init (&picotls_main.crypto_keys_rw_lock);
tls_register_engine (&picotls_engine, CRYPTO_ENGINE_PICOTLS);
clib_rwlock_init (&picotls_main.crypto_keys_rw_lock);
tls_register_engine (&picotls_engine, CRYPTO_ENGINE_PICOTLS);
typedef struct picotls_main_
{
picotls_ctx_t ***ctx_pool;
typedef struct picotls_main_
{
picotls_ctx_t ***ctx_pool;
picotls_listen_ctx_t *lctx_pool;
ptls_context_t *client_ptls_ctx;
clib_rwlock_t crypto_keys_rw_lock;
picotls_listen_ctx_t *lctx_pool;
ptls_context_t *client_ptls_ctx;
clib_rwlock_t crypto_keys_rw_lock;