Switch from buffered to vectored async_writes.

graydon · Feb 8, 2020 · cba7c0e · cba7c0e
1 parent b0139db
commit cba7c0e
Show file tree

Hide file tree

Showing 4 changed files with 227 additions and 144 deletions.
diff --git a/src/overlay/Peer.h b/src/overlay/Peer.h
@@ -253,7 +253,8 @@ class Peer : public std::enable_shared_from_this<Peer>,
     virtual void connectHandler(asio::error_code const& ec);
 
     virtual void
-    writeHandler(asio::error_code const& error, size_t bytes_transferred)
+    writeHandler(asio::error_code const& error, size_t bytes_transferred,
+                 size_t messages_transferred)
     {
     }
 
@@ -263,7 +264,8 @@ class Peer : public std::enable_shared_from_this<Peer>,
     }
 
     virtual void
-    readBodyHandler(asio::error_code const& error, size_t bytes_transferred)
+    readBodyHandler(asio::error_code const& error, size_t bytes_transferred,
+                    size_t expected_length)
     {
     }
 

diff --git a/src/overlay/PeerDoor.cpp b/src/overlay/PeerDoor.cpp
@@ -57,8 +57,8 @@ PeerDoor::acceptNextPeer()
     }
 
     CLOG(DEBUG, "Overlay") << "PeerDoor acceptNextPeer()";
-    auto sock = make_shared<TCPPeer::SocketType>(
-        mApp.getClock().getIOContext(), TCPPeer::BUFSZ, TCPPeer::BUFSZ);
+    auto sock = make_shared<TCPPeer::SocketType>(mApp.getClock().getIOContext(),
+                                                 TCPPeer::BUFSZ);
     mAcceptor.async_accept(sock->next_layer(),
                            [this, sock](asio::error_code const& ec) {
                                if (ec)