Searched refs:btype (Results 1 – 7 of 7) sorted by relevance
102 void blockClient(client *c, int btype) { in blockClient() argument104 c->btype = btype; in blockClient()163 if (c->btype == BLOCKED_LIST || in unblockClient()164 c->btype == BLOCKED_ZSET || in unblockClient()165 c->btype == BLOCKED_STREAM) { in unblockClient()179 c->btype = BLOCKED_NONE; in unblockClient()187 if (c->btype == BLOCKED_LIST || in replyToBlockedClientTimedOut()188 c->btype == BLOCKED_ZSET || in replyToBlockedClientTimedOut()189 c->btype == BLOCKED_STREAM) { in replyToBlockedClientTimedOut()511 if (btype == BLOCKED_STREAM) { in blockForKeys()[all …]
760 int btype; /* Type of blocking op if CLIENT_BLOCKED. */ member1906 void blockClient(client *c, int btype);1914 void blockForKeys(client *c, int btype, robj **keys, int numkeys, mstime_t timeout, robj *target, s…
142 c->btype = BLOCKED_NONE; in createClient()1480 if (!(c->flags & CLIENT_BLOCKED) || c->btype != BLOCKED_MODULE) in processInputBuffer()
664 c->btype = BLOCKED_NONE; in createFakeClient()
5668 (c->btype == BLOCKED_LIST || in clusterRedirectBlockedClientIfNeeded()5669 c->btype == BLOCKED_ZSET || in clusterRedirectBlockedClientIfNeeded()5670 c->btype == BLOCKED_STREAM)) in clusterRedirectBlockedClientIfNeeded()
232 uint32 btype:1; /* Buffer Type */ member236 uint32 btype:1; /* Buffer Type */ member
620 rxd->btype = val; in vmxnet3_renew_desc()924 RTE_ASSERT(rxd->btype == VMXNET3_RXD_BTYPE_HEAD); in vmxnet3_recv_pkts()951 RTE_ASSERT(rxd->btype == VMXNET3_RXD_BTYPE_BODY); in vmxnet3_recv_pkts()