| 246 |
#endif |
#endif |
| 247 |
|
|
| 248 |
int nfds; |
int nfds; |
|
int retry; |
|
| 249 |
int ret = 0; |
int ret = 0; |
| 250 |
|
|
| 251 |
// Retry wait / flush for at most 3 times |
// Retry wait / flush for at most 3 times |
| 252 |
retry = 3; |
for (int retry = 3; retry > 0 && !SYS_server_exit; retry--) |
|
while (retry > 0 && !SYS_server_exit) |
|
| 253 |
{ |
{ |
|
retry--; |
|
|
|
|
| 254 |
#ifdef HAVE_SYS_EPOLL_H |
#ifdef HAVE_SYS_EPOLL_H |
| 255 |
nfds = epoll_wait(stdout_epollfd, events, MAX_EVENTS, 100); // 0.1 second |
nfds = epoll_wait(stdout_epollfd, events, MAX_EVENTS, 100); // 0.1 second |
| 256 |
ret = nfds; |
ret = nfds; |
| 282 |
for (int i = 0; i < nfds; i++) |
for (int i = 0; i < nfds; i++) |
| 283 |
{ |
{ |
| 284 |
#ifdef HAVE_SYS_EPOLL_H |
#ifdef HAVE_SYS_EPOLL_H |
| 285 |
if (events[i].data.fd == STDOUT_FILENO) |
if (events[i].data.fd == STDOUT_FILENO && (events[i].events & (EPOLLRDHUP | EPOLLHUP | EPOLLERR))) |
| 286 |
|
#else |
| 287 |
|
if (pfds[i].fd == STDOUT_FILENO && (pfds[i].revents & (POLLRDHUP | POLLHUP | POLLERR))) |
| 288 |
|
#endif |
| 289 |
|
{ |
| 290 |
|
#ifdef _DEBUG |
| 291 |
|
#ifdef HAVE_SYS_EPOLL_H |
| 292 |
|
log_error("STDOUT error events (%d)\n", events[i].events); |
| 293 |
|
#else |
| 294 |
|
log_error("STDOUT error events (%d)\n", pfds[i].revents); |
| 295 |
|
#endif |
| 296 |
|
#endif |
| 297 |
|
retry = 0; |
| 298 |
|
break; |
| 299 |
|
} |
| 300 |
|
|
| 301 |
|
#ifdef HAVE_SYS_EPOLL_H |
| 302 |
|
if (events[i].data.fd == STDOUT_FILENO && (events[i].events & EPOLLOUT)) |
| 303 |
#else |
#else |
| 304 |
if (pfds[i].fd == STDOUT_FILENO && (pfds[i].revents & POLLOUT)) |
if (pfds[i].fd == STDOUT_FILENO && (pfds[i].revents & POLLOUT)) |
| 305 |
#endif |
#endif |
| 448 |
for (int i = 0; i < nfds; i++) |
for (int i = 0; i < nfds; i++) |
| 449 |
{ |
{ |
| 450 |
#ifdef HAVE_SYS_EPOLL_H |
#ifdef HAVE_SYS_EPOLL_H |
| 451 |
if (events[i].data.fd == STDIN_FILENO) |
if (events[i].data.fd == STDIN_FILENO && (events[i].events & (EPOLLRDHUP | EPOLLHUP | EPOLLERR))) |
| 452 |
|
#else |
| 453 |
|
if (pfds[i].fd == STDIN_FILENO && (pfds[i].revents & (POLLRDHUP | POLLHUP | POLLERR))) |
| 454 |
|
#endif |
| 455 |
|
{ |
| 456 |
|
#ifdef _DEBUG |
| 457 |
|
#ifdef HAVE_SYS_EPOLL_H |
| 458 |
|
log_error("STDIN error events (%d)\n", events[i].events); |
| 459 |
|
#else |
| 460 |
|
log_error("STDIN error events (%d)\n", pfds[i].revents); |
| 461 |
|
#endif |
| 462 |
|
#endif |
| 463 |
|
loop = 0; |
| 464 |
|
break; |
| 465 |
|
} |
| 466 |
|
|
| 467 |
|
#ifdef HAVE_SYS_EPOLL_H |
| 468 |
|
if (events[i].data.fd == STDIN_FILENO && (events[i].events & EPOLLIN)) |
| 469 |
#else |
#else |
| 470 |
if (pfds[i].fd == STDIN_FILENO && (pfds[i].revents & POLLIN)) |
if (pfds[i].fd == STDIN_FILENO && (pfds[i].revents & POLLIN)) |
| 471 |
#endif |
#endif |