Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dblocked.c404 if (receiver->bpop.xread_group) { in handleClientsBlockedOnKeys()
406 receiver->bpop.xread_group->ptr); in handleClientsBlockedOnKeys()
445 receiver->bpop.xread_group in handleClientsBlockedOnKeys()
570 if (c->bpop.xread_group) { in unblockClientWaitingData()
571 decrRefCount(c->bpop.xread_group); in unblockClientWaitingData()
573 c->bpop.xread_group = NULL; in unblockClientWaitingData()
H A Dt_stream.c1561 c->bpop.xread_group = groupname; in xreadCommand()
1565 c->bpop.xread_group = NULL; in xreadCommand()
H A Dnetworking.c146 c->bpop.xread_group = NULL; in createClient()
H A Dserver.h682 robj *xread_group; /* XREADGROUP group name. */ member