X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fplugins%2Ftlsmbedtls%2Ftls_mbedtls.c;h=52d124eb84eeeba488dfcbab69a5d9412485ccfa;hb=41684c2d78d5cefa94dcb4e19bcd8eb7feb00bd0;hp=aaad99f0fdb3c21113d3e7734d4890425420d8b5;hpb=58d36f02b45c5af38b7df81fb7976129cad3e05b;p=vpp.git diff --git a/src/plugins/tlsmbedtls/tls_mbedtls.c b/src/plugins/tlsmbedtls/tls_mbedtls.c index aaad99f0fdb..52d124eb84e 100644 --- a/src/plugins/tlsmbedtls/tls_mbedtls.c +++ b/src/plugins/tlsmbedtls/tls_mbedtls.c @@ -55,7 +55,7 @@ mbedtls_calloc_fn (size_t n, size_t size) { void *ptr; ptr = clib_mem_alloc (n * size); - memset (ptr, 0, sizeof (*ptr)); + clib_memset (ptr, 0, sizeof (*ptr)); return ptr; } @@ -78,7 +78,7 @@ mbedtls_ctx_alloc (void) if (!(*ctx)) *ctx = clib_mem_alloc (sizeof (mbedtls_ctx_t)); - memset (*ctx, 0, sizeof (mbedtls_ctx_t)); + clib_memset (*ctx, 0, sizeof (mbedtls_ctx_t)); (*ctx)->ctx.c_thread_index = thread_index; (*ctx)->ctx.tls_ctx_engine = TLS_ENGINE_MBEDTLS; (*ctx)->mbedtls_ctx_index = ctx - tm->ctx_pool[thread_index]; @@ -169,7 +169,7 @@ tls_net_send (void *ctx_indexp, const unsigned char *buf, size_t len) rv = svm_fifo_enqueue_nowait (tls_session->server_tx_fifo, len, buf); if (rv < 0) return MBEDTLS_ERR_SSL_WANT_WRITE; - tls_add_vpp_q_evt (tls_session->server_tx_fifo, FIFO_EVENT_APP_TX); + tls_add_vpp_q_tx_evt (tls_session); return rv; } @@ -258,6 +258,18 @@ mbedtls_ctx_init_client (tls_ctx_t * ctx) return 0; } +static int +mbedtls_start_listen (tls_ctx_t * lctx) +{ + return 0; +} + +static int +mbedtls_stop_listen (tls_ctx_t * lctx) +{ + return 0; +} + static int mbedtls_ctx_init_server (tls_ctx_t * ctx) { @@ -436,7 +448,7 @@ mbedtls_ctx_write (tls_ctx_t * ctx, stream_session_t * app_session) if (PREDICT_FALSE (enq_max == 0)) { - tls_add_vpp_q_evt (app_session->server_tx_fifo, FIFO_EVENT_APP_TX); + tls_add_vpp_q_builtin_tx_evt (app_session); return 0; } @@ -447,16 +459,16 @@ mbedtls_ctx_write (tls_ctx_t * ctx, stream_session_t * app_session) wrote = mbedtls_ssl_write (&mc->ssl, mm->tx_bufs[thread_index], deq_now); if (wrote <= 0) { - tls_add_vpp_q_evt (app_session->server_tx_fifo, FIFO_EVENT_APP_TX); + tls_add_vpp_q_builtin_tx_evt (app_session); return 0; } svm_fifo_dequeue_drop (app_session->server_tx_fifo, wrote); vec_reset_length (mm->tx_bufs[thread_index]); - tls_add_vpp_q_evt (tls_session->server_tx_fifo, FIFO_EVENT_APP_TX); + tls_add_vpp_q_tx_evt (tls_session); if (deq_now < deq_max) - tls_add_vpp_q_evt (app_session->server_tx_fifo, FIFO_EVENT_APP_TX); + tls_add_vpp_q_builtin_tx_evt (app_session); return 0; } @@ -487,7 +499,7 @@ mbedtls_ctx_read (tls_ctx_t * ctx, stream_session_t * tls_session) if (PREDICT_FALSE (enq_now == 0)) { - tls_add_vpp_q_evt (tls_session->server_rx_fifo, FIFO_EVENT_BUILTIN_RX); + tls_add_vpp_q_builtin_rx_evt (tls_session); return 0; } @@ -495,7 +507,7 @@ mbedtls_ctx_read (tls_ctx_t * ctx, stream_session_t * tls_session) read = mbedtls_ssl_read (&mc->ssl, mm->rx_bufs[thread_index], enq_now); if (read <= 0) { - tls_add_vpp_q_evt (tls_session->server_rx_fifo, FIFO_EVENT_BUILTIN_RX); + tls_add_vpp_q_builtin_rx_evt (tls_session); return 0; } @@ -505,7 +517,7 @@ mbedtls_ctx_read (tls_ctx_t * ctx, stream_session_t * tls_session) vec_reset_length (mm->rx_bufs[thread_index]); if (svm_fifo_max_dequeue (tls_session->server_rx_fifo)) - tls_add_vpp_q_evt (tls_session->server_rx_fifo, FIFO_EVENT_BUILTIN_RX); + tls_add_vpp_q_builtin_rx_evt (tls_session); if (enq > 0) tls_notify_app_enqueue (ctx, app_session); @@ -530,6 +542,8 @@ const static tls_engine_vft_t mbedtls_engine = { .ctx_write = mbedtls_ctx_write, .ctx_read = mbedtls_ctx_read, .ctx_handshake_is_over = mbedtls_handshake_is_over, + .ctx_start_listen = mbedtls_start_listen, + .ctx_stop_listen = mbedtls_stop_listen, }; int