Commit 2ecb637f authored by louiz’'s avatar louiz’

Read a variable number of bytes, 4096 by default

parent e35472a6
......@@ -61,11 +61,11 @@ void SocketHandler::set_poller(Poller* poller)
this->poller = poller;
}
void SocketHandler::on_recv()
void SocketHandler::on_recv(const size_t nb)
{
char buf[4096];
ssize_t size = ::recv(this->socket, buf, 4096, 0);
ssize_t size = ::recv(this->socket, buf, nb, 0);
if (0 == size)
{
this->on_connection_close();
......
......@@ -30,7 +30,7 @@ public:
* Reads data in our in_buf and the call parse_in_buf, for the implementor
* to handle the data received so far.
*/
void on_recv();
void on_recv(const size_t nb = 4096);
/**
* Write as much data from out_buf as possible, in the socket.
*/
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment