From b7802b3b06511f067719cb845dfd03a223f0e18f Mon Sep 17 00:00:00 2001
From: Determinant <ted.sybil@gmail.com>
Date: Wed, 3 Apr 2019 14:55:26 -0400
Subject: improve non-blocking API

---
 src/conn.cpp | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'src')

diff --git a/src/conn.cpp b/src/conn.cpp
index 4ab3040..5fc59f3 100644
--- a/src/conn.cpp
+++ b/src/conn.cpp
@@ -185,6 +185,7 @@ void ConnPool::accept_client(int fd, int) {
         NetAddr addr((struct sockaddr_in *)&client_addr);
         conn_t conn = create_conn();
         conn->self_ref = conn;
+        conn->send_buffer.set_capacity(queue_capacity);
         conn->seg_buff_size = seg_buff_size;
         conn->fd = client_fd;
         conn->cpool = this;
@@ -264,6 +265,7 @@ ConnPool::conn_t ConnPool::_connect(const NetAddr &addr) {
         throw ConnPoolError(std::string("unable to set nonblocking socket"));
     conn_t conn = create_conn();
     conn->self_ref = conn;
+    conn->send_buffer.set_capacity(queue_capacity);
     conn->seg_buff_size = seg_buff_size;
     conn->fd = fd;
     conn->cpool = this;
-- 
cgit v1.2.3