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

Function unpauseClients

app/redis-6.2.6/src/networking.c:3361–3375  ·  view source on GitHub ↗

Unpause clients and queue them for reprocessing. */

Source from the content-addressed store, hash-verified

3359
3360/* Unpause clients and queue them for reprocessing. */
3361void unpauseClients(void) {
3362 listNode *ln;
3363 listIter li;
3364 client *c;
3365
3366 server.client_pause_type = CLIENT_PAUSE_OFF;
3367 server.client_pause_end_time = 0;
3368
3369 /* Unblock all of the clients so they are reprocessed. */
3370 listRewind(server.paused_clients,&li);
3371 while ((ln = listNext(&li)) != NULL) {
3372 c = listNodeValue(ln);
3373 unblockClient(c);
3374 }
3375}
3376
3377/* Returns true if clients are paused and false otherwise. */
3378int areClientsPaused(void) {

Callers 3

clearFailoverStateFunction · 0.85
clientCommandFunction · 0.85

Calls 3

listRewindFunction · 0.85
listNextFunction · 0.85
unblockClientFunction · 0.85

Tested by

no test coverage detected