From 853a6503391a05a3f60b50bb40a7dd4f35588293 Mon Sep 17 00:00:00 2001 From: Determinant Date: Fri, 14 Feb 2020 15:13:47 -0500 Subject: change queue_capacity to max_send_buff_size; adjust the C API --- include/salticidae/conn.h | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) (limited to 'include/salticidae/conn.h') diff --git a/include/salticidae/conn.h b/include/salticidae/conn.h index 9afc813..b43d3c2 100644 --- a/include/salticidae/conn.h +++ b/include/salticidae/conn.h @@ -139,7 +139,7 @@ class ConnPool { /** Write data to the connection (non-blocking). The data will be sent * whenever I/O is available. */ bool write(bytearray_t &&data) { - return send_buffer.push(std::move(data), !cpool->queue_capacity); + return send_buffer.push(std::move(data), !cpool->max_send_buff_size); } }; @@ -185,7 +185,7 @@ class ConnPool { const double conn_server_timeout; const size_t seg_buff_size; const size_t max_recv_buff_size; - const size_t queue_capacity; + const size_t max_send_buff_size; tls_context_t tls_ctx; conn_callback_t conn_cb; @@ -363,8 +363,8 @@ class ConnPool { double _conn_server_timeout; size_t _seg_buff_size; size_t _max_recv_buff_size; + size_t _max_send_buff_size; size_t _nworker; - size_t _queue_capacity; bool _enable_tls; std::string _tls_cert_file; std::string _tls_key_file; @@ -379,8 +379,8 @@ class ConnPool { _conn_server_timeout(2), _seg_buff_size(4096), _max_recv_buff_size(4096), + _max_send_buff_size(0), _nworker(1), - _queue_capacity(0), _enable_tls(false), _tls_cert_file(""), _tls_key_file(""), @@ -404,18 +404,18 @@ class ConnPool { return *this; } - Config &max_recv_buff_size(size_t x) { - _max_recv_buff_size = x; + Config &nworker(size_t x) { + _nworker = std::max((size_t)1, x); return *this; } - Config &nworker(size_t x) { - _nworker = std::max((size_t)1, x); + Config &max_recv_buff_size(size_t x) { + _max_recv_buff_size = x; return *this; } - Config &queue_capacity(size_t x) { - _queue_capacity = x; + Config &max_send_buff_size(size_t x) { + _max_send_buff_size = x; return *this; } @@ -463,7 +463,7 @@ class ConnPool { conn_server_timeout(config._conn_server_timeout), seg_buff_size(config._seg_buff_size), max_recv_buff_size(config._max_recv_buff_size), - queue_capacity(config._queue_capacity), + max_send_buff_size(config._max_send_buff_size), tls_ctx(nullptr), listen_fd(-1), nworker(config._nworker) { -- cgit v1.2.3