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

Function unblockClientWaitingReplicas

src/replication.cpp:4692–4696  ·  view source on GitHub ↗

This is called by unblockClient() to perform the blocking op type * specific cleanup. We just remove the client from the list of clients * waiting for replica acks. Never call it directly, call unblockClient() * instead. */

Source from the content-addressed store, hash-verified

4690 * waiting for replica acks. Never call it directly, call unblockClient()
4691 * instead. */
4692void unblockClientWaitingReplicas(client *c) {
4693 listNode *ln = listSearchKey(g_pserver->clients_waiting_acks,c);
4694 serverAssert(ln != NULL);
4695 listDelNode(g_pserver->clients_waiting_acks,ln);
4696}
4697
4698/* Check if there are clients blocked in WAIT that can be unblocked since
4699 * we received enough ACKs from slaves. */

Callers 1

unblockClientFunction · 0.85

Calls 2

listSearchKeyFunction · 0.85
listDelNodeFunction · 0.85

Tested by

no test coverage detected