pdxx
/
libfastcommon
mirror of https://github.com/happyfish100/libfastcommon.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

check poll result for POLLHUP and POLLERR

pull/37/head
YuQing 2020-10-25 20:42:53 +08:00
parent bb33b2e09f
commit d54007f79b
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/sockopt.c
View File

@ -177,11 +177,11 @@ int tcprecvdata_ex(int sock, void *data, const int size, \
}
#else
res = poll(&pollfds, 1, 1000 * timeout);
if (pollfds.revents & POLLHUP)
{
ret_code = ENOTCONN;
break;
}
if (res > 0 && (pollfds.revents & (POLLHUP | POLLERR)))
{
ret_code = ENOTCONN;
break;
}
#endif
if (res < 0)
@ -265,7 +265,7 @@ int tcpsenddata(int sock, void* data, const int size, const int timeout)
}
#else
result = poll(&pollfds, 1, 1000 * timeout);
if (pollfds.revents & POLLHUP)
if (result > 0 && (pollfds.revents & (POLLHUP | POLLERR)))
{
return ENOTCONN;
}
@ -371,7 +371,7 @@ int tcprecvdata_nb_ms(int sock, void *data, const int size, \
}
#else
res = poll(&pollfds, 1, timeout_ms);
if (pollfds.revents & POLLHUP)
if (res > 0 && (pollfds.revents & (POLLHUP | POLLERR)))
{
ret_code = ENOTCONN;
break;
@ -455,7 +455,7 @@ int tcpsenddata_nb(int sock, void* data, const int size, const int timeout)
}
#else
result = poll(&pollfds, 1, 1000 * timeout);
if (pollfds.revents & POLLHUP)
if (result > 0 && (pollfds.revents & (POLLHUP | POLLERR)))
{
return ENOTCONN;
}