breeze/CppNet
1
0
Fork 0
mirror of https://github.com/caozhiyi/CppNet.git synced 2026-01-26 16:30:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

disconnect whitout any data on windows don't notify.

Browse Source
This commit is contained in:
caozhiyi
2021-06-08 10:30:52 +08:00
parent b280382498
commit 8b6fcdeb83
1 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
cppnet/socket/win/win_connect_socket.cpp
View File

@@ -131,6 +131,14 @@ void WinConnectSocket::OnAccept(Event* event) {
AcceptExSockAddrs(accept_event->GetBuf(), __iocp_buff_size - ((sizeof(SOCKADDR_STORAGE) + 16) * 2),
sizeof(SOCKADDR_STORAGE) + 16, sizeof(SOCKADDR_STORAGE) + 16, (LPSOCKADDR*)&LocalAddr, &localLen, (LPSOCKADDR*)&client_addr, &remote_len);
// peer disconnect without any data
if (accept_event->GetBufOffset() == 0) {
OsHandle::Close(accept_event->GetClientSocket());
// post accept again
Accept(accept_event->GetIndex());
return;
}
// does this call have any effect ?
setsockopt(accept_event->GetClientSocket(), SOL_SOCKET, SO_UPDATE_ACCEPT_CONTEXT,
(char *)&_sock, sizeof(_sock));
@@ -179,22 +187,17 @@ void WinConnectSocket::OnAccept(Event* event) {
// add socket global cache.
__all_socket_map[accept_event->GetClientSocket()] = sock;
// call accept call back function
// call accept callback function
cppnet_base->OnAccept(sock);
// peer disconnect
if (accept_event->GetBufOffset() == 0) {
sock->SetShutdown();
cppnet_base->OnDisConnect(sock, CEC_CLOSED);
} else {
cppnet_base->OnRead(sock, buffer, accept_event->GetBufOffset());
}
// call read callback function
cppnet_base->OnRead(sock, buffer, accept_event->GetBufOffset());
// post accept again
Accept(accept_event->GetIndex());
// post accept again
Accept(accept_event->GetIndex());
// wait for read
sock->Read();
// wait for read
sock->Read();
}
}