aboutsummaryrefslogtreecommitdiff
path: root/src/conn.cpp
diff options
context:
space:
mode:
authorDeterminant <[email protected]>2020-02-14 15:13:47 -0500
committerDeterminant <[email protected]>2020-02-14 15:13:47 -0500
commit853a6503391a05a3f60b50bb40a7dd4f35588293 (patch)
treec25dc16a0f5170611d0aa8e3a12d63e98a036342 /src/conn.cpp
parent7dc5ec52b1c419c58c68d7359870a292ab12d7db (diff)
change queue_capacity to max_send_buff_size; adjust the C API
Diffstat (limited to 'src/conn.cpp')
-rw-r--r--src/conn.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/conn.cpp b/src/conn.cpp
index 311b1f8..ba584c1 100644
--- a/src/conn.cpp
+++ b/src/conn.cpp
@@ -319,7 +319,7 @@ void ConnPool::accept_client(int fd, int) {
NetAddr addr((struct sockaddr_in *)&client_addr);
conn_t conn = create_conn();
- conn->send_buffer.set_capacity(queue_capacity);
+ conn->send_buffer.set_capacity(max_send_buff_size);
conn->seg_buff_size = seg_buff_size;
conn->max_recv_buff_size = max_recv_buff_size;
conn->fd = client_fd;
@@ -400,7 +400,7 @@ ConnPool::conn_t ConnPool::_connect(const NetAddr &addr) {
if (fcntl(fd, F_SETFL, O_NONBLOCK) == -1)
throw ConnPoolError(SALTI_ERROR_CONNECT, errno);
conn_t conn = create_conn();
- conn->send_buffer.set_capacity(queue_capacity);
+ conn->send_buffer.set_capacity(max_send_buff_size);
conn->seg_buff_size = seg_buff_size;
conn->max_recv_buff_size = max_recv_buff_size;
conn->fd = fd;