From d28948b14303fdf00b331090ef177cc6cca54fe1 Mon Sep 17 00:00:00 2001 From: antirez Date: Mon, 13 Jan 2020 12:54:39 +0100 Subject: Port PR #6110 to new connection object code. --- src/networking.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/networking.c b/src/networking.c index 96ab8e592..73dc4afca 100644 --- a/src/networking.c +++ b/src/networking.c @@ -2822,7 +2822,7 @@ int handleClientsWithPendingWritesUsingThreads(void) { listRewind(io_threads_list[server.io_threads_num],&li); while((ln = listNext(&li))) { client *c = listNodeValue(ln); - writeToClient(c->fd,c,0); + writeToClient(c,0); } listEmpty(io_threads_list[server.io_threads_num]); @@ -2907,7 +2907,7 @@ int handleClientsWithPendingReadsUsingThreads(void) { listRewind(io_threads_list[server.io_threads_num],&li); while((ln = listNext(&li))) { client *c = listNodeValue(ln); - readQueryFromClient(NULL,c->fd,c,0); + readQueryFromClient(c->conn); } listEmpty(io_threads_list[server.io_threads_num]); -- cgit v1.2.1