Home
last modified time | relevance | path

Searched refs:BLOCKED_STREAM (Results 1 – 4 of 4) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dblocked.c165 c->btype == BLOCKED_STREAM) { in unblockClient()
189 c->btype == BLOCKED_STREAM) { in replyToBlockedClientTimedOut()
390 if (receiver->btype != BLOCKED_STREAM) continue; in handleClientsBlockedOnKeys()
511 if (btype == BLOCKED_STREAM) { in blockForKeys()
H A Dt_stream.c1256 if (server.blocked_clients_by_type[BLOCKED_STREAM]) in xaddCommand()
1547 blockForKeys(c, BLOCKED_STREAM, c->argv+streams_arg, streams_count, in xreadCommand()
H A Dserver.h268 #define BLOCKED_STREAM 4 /* XREAD. */ macro
H A Dcluster.c5670 c->btype == BLOCKED_STREAM)) in clusterRedirectBlockedClientIfNeeded()