Loading src/event/iocp.cpp +4 −2 Original line number Diff line number Diff line Loading @@ -614,7 +614,7 @@ namespace netplus { args->event->ConnectEvent(lpPerSocketContext->CurCon, tid, args); std::copy(buffRecv.buf,buffRecv.buf+buffRecv.len,std::back_inserter(lpPerSocketContext->CurCon->RecvData)); std::copy(buffRecv.buf,buffRecv.buf+nRet,std::back_inserter(lpPerSocketContext->CurCon->RecvData)); args->event->RequestEvent(lpPerSocketContext->CurCon, tid, args); Loading Loading @@ -664,7 +664,9 @@ namespace netplus { case poll::ClientIoWrite: std::copy(lpPerSocketContext->CurCon->SendData.begin(), lpPerSocketContext->CurCon->SendData.begin() + BLOCKSIZE, buffSend.buf); size_t ssize = BLOCKSIZE < lpPerSocketContext->CurCon->SendData.size() ? BLOCKSIZE : lpPerSocketContext->CurCon->SendData.size(); std::copy(lpPerSocketContext->CurCon->SendData.begin(), lpPerSocketContext->CurCon->SendData.begin() + ssize, buffSend.buf); // // a write operation has completed, determine if all the data intended to be Loading Loading
src/event/iocp.cpp +4 −2 Original line number Diff line number Diff line Loading @@ -614,7 +614,7 @@ namespace netplus { args->event->ConnectEvent(lpPerSocketContext->CurCon, tid, args); std::copy(buffRecv.buf,buffRecv.buf+buffRecv.len,std::back_inserter(lpPerSocketContext->CurCon->RecvData)); std::copy(buffRecv.buf,buffRecv.buf+nRet,std::back_inserter(lpPerSocketContext->CurCon->RecvData)); args->event->RequestEvent(lpPerSocketContext->CurCon, tid, args); Loading Loading @@ -664,7 +664,9 @@ namespace netplus { case poll::ClientIoWrite: std::copy(lpPerSocketContext->CurCon->SendData.begin(), lpPerSocketContext->CurCon->SendData.begin() + BLOCKSIZE, buffSend.buf); size_t ssize = BLOCKSIZE < lpPerSocketContext->CurCon->SendData.size() ? BLOCKSIZE : lpPerSocketContext->CurCon->SendData.size(); std::copy(lpPerSocketContext->CurCon->SendData.begin(), lpPerSocketContext->CurCon->SendData.begin() + ssize, buffSend.buf); // // a write operation has completed, determine if all the data intended to be Loading