gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Threaded IO: put fflush() inside tio_debug conditional.

Browse Source
This commit is contained in:
antirez 2019-04-29 12:46:23 +02:00
parent 6ab6a97fe6
commit 90d720e7a5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/networking.c
View File

@ -2608,7 +2608,7 @@ void initThreadedIO(void) {
} }
void startThreadedIO(void) { void startThreadedIO(void) {
if (tio_debug) printf("S"); fflush(stdout); if (tio_debug) { printf("S"); fflush(stdout); }
if (tio_debug) printf("--- STARTING THREADED IO ---\n"); if (tio_debug) printf("--- STARTING THREADED IO ---\n");
serverAssert(io_threads_active == 0); serverAssert(io_threads_active == 0);
for (int j = 0; j < server.io_threads_num; j++) for (int j = 0; j < server.io_threads_num; j++)
@ -2620,7 +2620,7 @@ void stopThreadedIO(void) {
/* We may have still clients with pending reads when this function /* We may have still clients with pending reads when this function
* is called: handle them before stopping the threads. */ * is called: handle them before stopping the threads. */
handleClientsWithPendingReadsUsingThreads(); handleClientsWithPendingReadsUsingThreads();
if (tio_debug) printf("E"); fflush(stdout); if (tio_debug) { printf("E"); fflush(stdout); }
if (tio_debug) printf("--- STOPPING THREADED IO [R%d] [W%d] ---\n", if (tio_debug) printf("--- STOPPING THREADED IO [R%d] [W%d] ---\n",
(int) listLength(server.clients_pending_read), (int) listLength(server.clients_pending_read),
(int) listLength(server.clients_pending_write)); (int) listLength(server.clients_pending_write));