Home
last modified time | relevance | path

Searched refs:CLIENT_BLOCKED (Results 1 – 6 of 6) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dblocked.c103 c->flags |= CLIENT_BLOCKED; in blockClient()
127 if (!(c->flags & CLIENT_BLOCKED)) { in processUnblockedClients()
178 c->flags &= ~CLIENT_BLOCKED; in unblockClient()
215 if (c->flags & CLIENT_BLOCKED) { in disconnectAllBlockedClients()
H A Dnetworking.c866 CLIENT_BLOCKED))) in freeClient()
885 if (c->flags & CLIENT_BLOCKED) unblockClient(c); in freeClient()
1433 if (c->flags & CLIENT_BLOCKED) break; in processInputBuffer()
1480 if (!(c->flags & CLIENT_BLOCKED) || c->btype != BLOCKED_MODULE) in processInputBuffer()
1660 if (client->flags & CLIENT_BLOCKED) *p++ = 'b'; in catClientInfoString()
1877 if (target && target->flags & CLIENT_BLOCKED) { in clientCommand()
2207 if (c->flags & (CLIENT_SLAVE|CLIENT_BLOCKED)) continue; in clientsArePaused()
H A Daof.c830 serverAssert((fakeClient->flags & CLIENT_BLOCKED) == 0); in loadAppendOnlyFile()
H A Dserver.c826 !(c->flags & CLIENT_BLOCKED) && /* no timeout for BLPOP */ in clientsCronHandleTimeout()
833 } else if (c->flags & CLIENT_BLOCKED) { in clientsCronHandleTimeout()
H A Dserver.h233 #define CLIENT_BLOCKED (1<<4) /* The client is waiting in a blocking operation */ macro
H A Dcluster.c5667 if (c->flags & CLIENT_BLOCKED && in clusterRedirectBlockedClientIfNeeded()