Commit d28948b1 authored by antirez's avatar antirez
Browse files

Port PR #6110 to new connection object code.

parent a8c912ea
......@@ -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]);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment