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