MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / clientHasPendingReplies

Function clientHasPendingReplies

src/networking.cpp:1149–1151  ·  view source on GitHub ↗

Return true if the specified client has pending reply buffers to write to * the socket. */

Source from the content-addressed store, hash-verified

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

Callers 10

syncCommandFunction · 0.85
replicationCronFunction · 0.85
prepareClientToWriteFunction · 0.85
writeToClientFunction · 0.85
unprotectClientFunction · 0.85
flushSlavesOutputBuffersFunction · 0.85
scriptCommandFunction · 0.85

Calls 1

FPendingReplicaWriteMethod · 0.80

Tested by

no test coverage detected