Return true if the specified client has pending reply buffers to write to * the socket. */
| 1147 | /* Return true if the specified client has pending reply buffers to write to |
| 1148 | * the socket. */ |
| 1149 | int clientHasPendingReplies(client *c) { |
| 1150 | return (c->bufpos || listLength(c->reply) || c->FPendingReplicaWrite()); |
| 1151 | } |
| 1152 | |
| 1153 | static std::atomic<int> rgacceptsInFlight[MAX_EVENT_LOOPS]; |
| 1154 | int chooseBestThreadForAccept() |
no test coverage detected