MCPcopy Create free account
hub / github.com/F-Stack/f-stack / unblockClientWaitingReplicas

Function unblockClientWaitingReplicas

app/redis-6.2.6/src/replication.c:3225–3229  ·  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

3223 * waiting for replica acks. Never call it directly, call unblockClient()
3224 * instead. */
3225void unblockClientWaitingReplicas(client *c) {
3226 listNode *ln = listSearchKey(server.clients_waiting_acks,c);
3227 serverAssert(ln != NULL);
3228 listDelNode(server.clients_waiting_acks,ln);
3229}
3230
3231/* Check if there are clients blocked in WAIT that can be unblocked since
3232 * 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