drygdryg/zapret
1
0
Fork 0
mirror of https://github.com/bol-van/zapret.git synced 2025-03-15 04:41:37 +03:00
Code Issues Packages Projects Releases Wiki Activity

Revert "Revert "nfqws,tpws: fflush stdin,stdout""

Browse Source 
This reverts commit 56d06456fb1eb010a46b7bb50508daa1ac6cbf31.
This commit is contained in:
bol-van 2025-03-12 12:48:32 +03:00
parent 56d06456fb
commit 123eb057ae
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
nfq/nfqws.c
View File

@ -294,6 +294,7 @@ static int nfq_main(void)
fd = nfq_fd(h); fd = nfq_fd(h);
do do
{ {
fflush(stdout); fflush(stderr);
while ((rd = recv(fd, buf, sizeof(buf), 0)) >= 0) while ((rd = recv(fd, buf, sizeof(buf), 0)) >= 0)
{ {
ReloadCheck(); ReloadCheck();
@ -304,6 +305,7 @@ static int nfq_main(void)
} }
else else
DLOG("recv from nfq returned 0 !\n"); DLOG("recv from nfq returned 0 !\n");
fflush(stdout); fflush(stderr);
} }
e=errno; e=errno;
DLOG_ERR("recv: recv=%zd errno %d\n",rd,e); DLOG_ERR("recv: recv=%zd errno %d\n",rd,e);
@ -389,6 +391,8 @@ static int dvt_main(void)
for(;;) for(;;)
{ {
fflush(stdout); fflush(stderr);
FD_ZERO(&fdset); FD_ZERO(&fdset);
for(i=0;i<fdct;i++) FD_SET(fd[i], &fdset); for(i=0;i<fdct;i++) FD_SET(fd[i], &fdset);
r = select(fdmax,&fdset,NULL,NULL,NULL); r = select(fdmax,&fdset,NULL,NULL,NULL);
@ -509,8 +513,7 @@ static int win_main(const char *windivert_filter)
DLOG_CONDUP("windivert initialized. capture is started.\n"); DLOG_CONDUP("windivert initialized. capture is started.\n");
// cygwin auto flush fails when piping // cygwin auto flush fails when piping
fflush(stdout); fflush(stdout); fflush(stderr);
fflush(stderr);
for (id=0;;id++) for (id=0;;id++)
{ {
@ -576,8 +579,7 @@ static int win_main(const char *windivert_filter)
} }
// cygwin auto flush fails when piping // cygwin auto flush fails when piping
fflush(stdout); fflush(stdout); fflush(stderr);
fflush(stderr);
} }
} }
win_dark_deinit(); win_dark_deinit();

4
tpws/tpws_conn.c
View File

@ -1548,6 +1548,8 @@ int event_loop(const int *listen_fd, size_t listen_fd_ct)
DBGPRINT("epoll_wait\n"); DBGPRINT("epoll_wait\n");
fflush(stdout); fflush(stderr);
if ((num_events = epoll_wait(efd, events, MAX_EPOLL_EVENTS, -1)) == -1) if ((num_events = epoll_wait(efd, events, MAX_EPOLL_EVENTS, -1)) == -1)
{ {
if (errno == EINTR) continue; // system call was interrupted if (errno == EINTR) continue; // system call was interrupted
@ -1755,8 +1757,6 @@ int event_loop(const int *listen_fd, size_t listen_fd_ct)
// at least one leg was removed. recount legs // at least one leg was removed. recount legs
print_legs(); print_legs();
} }
fflush(stderr); fflush(stdout); // for console messages
} }
ex: ex: