From 40a5da8e96a910287001e9db119d1f0134fc9fb8 Mon Sep 17 00:00:00 2001 From: Florin Coras Date: Fri, 18 Dec 2020 09:19:18 -0800 Subject: tls: use fifo segments instead of chunks Type: refactor Signed-off-by: Florin Coras Change-Id: Id67cf8a3e1c5c9b4160689fde5de9ce7ed8a2ee3 --- src/plugins/tlsopenssl/tls_openssl.c | 59 ++++++++++++++++-------------------- 1 file changed, 26 insertions(+), 33 deletions(-) (limited to 'src/plugins/tlsopenssl') diff --git a/src/plugins/tlsopenssl/tls_openssl.c b/src/plugins/tlsopenssl/tls_openssl.c index 5e49dbfe6c9..789c64d88d3 100644 --- a/src/plugins/tlsopenssl/tls_openssl.c +++ b/src/plugins/tlsopenssl/tls_openssl.c @@ -113,32 +113,27 @@ openssl_lctx_get (u32 lctx_index) static int openssl_read_from_ssl_into_fifo (svm_fifo_t * f, SSL * ssl) { - u32 enq_now, enq_max; - svm_fifo_chunk_t *c; - int read, rv; - - enq_max = svm_fifo_max_enqueue_prod (f); - if (!enq_max) + int read, rv, n_fs, i; + const int n_segs = 2; + svm_fifo_seg_t fs[n_segs]; + u32 max_enq; + + max_enq = svm_fifo_max_enqueue_prod (f); + n_fs = svm_fifo_provision_chunks (f, fs, n_segs, max_enq); + if (n_fs < 0) return 0; - svm_fifo_fill_chunk_list (f); - - enq_now = clib_min (svm_fifo_max_write_chunk (f), enq_max); - if (!enq_now) - return 0; - - read = SSL_read (ssl, svm_fifo_tail (f), enq_now); + /* Return early if we can't read anything */ + read = SSL_read (ssl, fs[0].data, fs[0].len); if (read <= 0) return 0; - c = svm_fifo_tail_chunk (f); - while ((c = c->next) && read < enq_max) + for (i = 1; i < n_fs; i++) { - enq_now = clib_min (c->length, enq_max - read); - rv = SSL_read (ssl, c->data, enq_now); + rv = SSL_read (ssl, fs[i].data, fs[i].len); read += rv > 0 ? rv : 0; - if (rv < enq_now) + if (rv < fs[i].len) break; } @@ -148,29 +143,27 @@ openssl_read_from_ssl_into_fifo (svm_fifo_t * f, SSL * ssl) } static int -openssl_write_from_fifo_into_ssl (svm_fifo_t * f, SSL * ssl, u32 len) +openssl_write_from_fifo_into_ssl (svm_fifo_t *f, SSL *ssl, u32 max_len) { - svm_fifo_chunk_t *c; - int wrote = 0, rv; - u32 deq_now; + int wrote = 0, rv, i = 0, len; + const int n_segs = 2; + svm_fifo_seg_t fs[n_segs]; - deq_now = clib_min (svm_fifo_max_read_chunk (f), len); - wrote = SSL_write (ssl, svm_fifo_head (f), deq_now); - if (wrote <= 0) + len = svm_fifo_segments (f, 0, fs, n_segs, max_len); + if (len <= 0) return 0; - c = svm_fifo_head_chunk (f); - while ((c = c->next) && wrote < len) + while (wrote < len && i < n_segs) { - deq_now = clib_min (c->length, len - wrote); - rv = SSL_write (ssl, c->data, deq_now); - wrote += rv > 0 ? rv : 0; - - if (rv < deq_now) + rv = SSL_write (ssl, fs[i].data, fs[i].len); + wrote += (rv > 0) ? rv : 0; + if (rv < fs[i].len) break; + i++; } - svm_fifo_dequeue_drop (f, wrote); + if (wrote) + svm_fifo_dequeue_drop (f, wrote); return wrote; } -- cgit 1.2.3-korg