cml/libcw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cwSocket.cpp : Added extended socket status checking in _poll().

Browse Source
This commit is contained in:
kpl 2020-03-18 17:20:38 -04:00
parent f4e11db89a
commit 46a84600a6
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
cwSocket.cpp
View File

@ -231,7 +231,7 @@ namespace cw
goto errLabel; goto errLabel;
if( s->cbFunc != nullptr ) if( s->cbFunc != nullptr )
s->cbFunc( s->cbArg, kConnectCbId, s->userId, s->connId, nullptr, 0, (const struct sockaddr_in*)&remoteAddr ); s->cbFunc( s->cbArg, kConnectCbId, s->userId, cs->connId, nullptr, 0, (const struct sockaddr_in*)&remoteAddr );
errLabel: errLabel:
@ -359,6 +359,22 @@ namespace cw
// interate through the ports looking for the ones which have data waiting ... // interate through the ports looking for the ones which have data waiting ...
for(unsigned i=0; i<p->sockN; ++i) for(unsigned i=0; i<p->sockN; ++i)
{
if( p->sockA[i].pollfd->revents & POLLERR )
{
printf("ERROR\n");
}
if( p->sockA[i].pollfd->revents & POLLHUP )
{
printf("HUP\n");
}
if( p->sockA[i].pollfd->revents & POLLNVAL )
{
printf("NVAL\n");
}
if( p->sockA[i].pollfd->revents & POLLIN ) if( p->sockA[i].pollfd->revents & POLLIN )
{ {
unsigned actualReadN = 0; unsigned actualReadN = 0;
@ -384,7 +400,8 @@ namespace cw
readN_Ref += actualReadN; readN_Ref += actualReadN;
} }
}
p->sockN += newSockN; p->sockN += newSockN;
} }