Loading src/event/epoll.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -201,7 +201,7 @@ namespace netplus { con *rcon = (con*)_Events[pos].data.ptr; try{ std::shared_ptr<char[]> buf( new char[BLOCKSIZE], []( char *p ){ delete [] p; }); size_t rcvsize = _ServerSocket->recvData(rcon->csock, buf.get(), BLOCKSIZE); size_t rcvsize = rcon->csock->recvData(buf.get(), BLOCKSIZE); rcon->lasteventime = time(nullptr); Loading Loading @@ -249,7 +249,7 @@ namespace netplus { wcon->state=EVOUT; sended = _ServerSocket->sendData(wcon->csock,wcon->SendData.data(),ssize); sended = wcon->csock->sendData(wcon->SendData.data(),ssize); wcon->SendData.resize(sended); wcon->lasteventime = time(nullptr); Loading Loading
src/event/epoll.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -201,7 +201,7 @@ namespace netplus { con *rcon = (con*)_Events[pos].data.ptr; try{ std::shared_ptr<char[]> buf( new char[BLOCKSIZE], []( char *p ){ delete [] p; }); size_t rcvsize = _ServerSocket->recvData(rcon->csock, buf.get(), BLOCKSIZE); size_t rcvsize = rcon->csock->recvData(buf.get(), BLOCKSIZE); rcon->lasteventime = time(nullptr); Loading Loading @@ -249,7 +249,7 @@ namespace netplus { wcon->state=EVOUT; sended = _ServerSocket->sendData(wcon->csock,wcon->SendData.data(),ssize); sended = wcon->csock->sendData(wcon->SendData.data(),ssize); wcon->SendData.resize(sended); wcon->lasteventime = time(nullptr); Loading