Home
last modified time | relevance | path

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

/redis-3.2.3/src/
H A Dblocked.c101 c->flags |= CLIENT_BLOCKED; in blockClient()
124 if (!(c->flags & CLIENT_BLOCKED)) { in processUnblockedClients()
144 c->flags &= ~CLIENT_BLOCKED; in unblockClient()
182 if (c->flags & CLIENT_BLOCKED) { in disconnectAllBlockedClients()
H A Dnetworking.c798 CLIENT_BLOCKED| in freeClient()
817 if (c->flags & CLIENT_BLOCKED) unblockClient(c); in freeClient()
1268 if (c->flags & CLIENT_BLOCKED) break; in processInputBuffer()
1433 if (client->flags & CLIENT_BLOCKED) *p++ = 'b'; in catClientInfoString()
1900 if (c->flags & (CLIENT_SLAVE|CLIENT_BLOCKED)) continue; in clientsArePaused()
H A Daof.c704 serverAssert((fakeClient->flags & CLIENT_BLOCKED) == 0); in loadAppendOnlyFile()
H A Dserver.h249 #define CLIENT_BLOCKED (1<<4) /* The client is waiting in a blocking operation */ macro
H A Dserver.c930 !(c->flags & CLIENT_BLOCKED) && /* no timeout for BLPOP */ in clientsCronHandleTimeout()
937 } else if (c->flags & CLIENT_BLOCKED) { in clientsCronHandleTimeout()
H A Dcluster.c5180 if (c->flags & CLIENT_BLOCKED && c->btype == BLOCKED_LIST) { in clusterRedirectBlockedClientIfNeeded()