Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dblocked.c430 receiver->bpop.xread_consumer->ptr, in handleClientsBlockedOnKeys()
572 decrRefCount(c->bpop.xread_consumer); in unblockClientWaitingData()
574 c->bpop.xread_consumer = NULL; in unblockClientWaitingData()
H A Dt_stream.c1562 c->bpop.xread_consumer = consumername; in xreadCommand()
1566 c->bpop.xread_consumer = NULL; in xreadCommand()
H A Dnetworking.c147 c->bpop.xread_consumer = NULL; in createClient()
H A Dserver.h683 robj *xread_consumer; /* XREADGROUP consumer name. */ member