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. */
| 4690 | * waiting for replica acks. Never call it directly, call unblockClient() |
| 4691 | * instead. */ |
| 4692 | void 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. */ |
no test coverage detected