Searched refs:bpop (Results 1 – 9 of 9) sorted by relevance
502 c->bpop.timeout = timeout; in blockForKeys()503 c->bpop.target = target; in blockForKeys()549 di = dictGetIterator(c->bpop.keys); in unblockClientWaitingData()565 dictEmpty(c->bpop.keys,NULL); in unblockClientWaitingData()566 if (c->bpop.target) { in unblockClientWaitingData()567 decrRefCount(c->bpop.target); in unblockClientWaitingData()568 c->bpop.target = NULL; in unblockClientWaitingData()570 if (c->bpop.xread_group) { in unblockClientWaitingData()571 decrRefCount(c->bpop.xread_group); in unblockClientWaitingData()573 c->bpop.xread_group = NULL; in unblockClientWaitingData()[all …]
143 c->bpop.timeout = 0; in createClient()144 c->bpop.keys = dictCreate(&objectKeyHeapPointerValueDictType,NULL); in createClient()145 c->bpop.target = NULL; in createClient()146 c->bpop.xread_group = NULL; in createClient()147 c->bpop.xread_consumer = NULL; in createClient()148 c->bpop.xread_group_noack = 0; in createClient()149 c->bpop.numreplicas = 0; in createClient()150 c->bpop.reploffset = 0; in createClient()886 dictRelease(c->bpop.keys); in freeClient()
2461 c->bpop.timeout = timeout; in waitCommand()2462 c->bpop.reploffset = offset; in waitCommand()2463 c->bpop.numreplicas = numreplicas; in waitCommand()2499 if (last_offset && last_offset > c->bpop.reploffset && in processClientsWaitingReplicas()2500 last_numreplicas > c->bpop.numreplicas) in processClientsWaitingReplicas()2505 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas()2507 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()2508 last_offset = c->bpop.reploffset; in processClientsWaitingReplicas()
1552 c->bpop.xread_count = count ? count : XREAD_BLOCKED_DEFAULT_COUNT; in xreadCommand()1561 c->bpop.xread_group = groupname; in xreadCommand()1562 c->bpop.xread_consumer = consumername; in xreadCommand()1563 c->bpop.xread_group_noack = noack; in xreadCommand()1565 c->bpop.xread_group = NULL; in xreadCommand()1566 c->bpop.xread_consumer = NULL; in xreadCommand()
3570 RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle; in unblockClientFromModule()3611 c->bpop.module_blocked_handle = zmalloc(sizeof(RedisModuleBlockedClient)); in RM_BlockClient()3612 RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle; in RM_BlockClient()3628 c->bpop.timeout = timeout_ms ? (mstime()+timeout_ms) : 0; in RM_BlockClient()3631 c->bpop.module_blocked_handle = NULL; in RM_BlockClient()3784 RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle; in moduleBlockedClientTimedOut()
838 if (c->bpop.timeout != 0 && c->bpop.timeout < now_ms) { in clientsCronHandleTimeout()
761 blockingState bpop; /* blocking state */ member
5682 di = dictGetIterator(c->bpop.keys); in clusterRedirectBlockedClientIfNeeded()
1165 bpobj_phys_t *bpop = data; in dump_bpobj() local1174 if (bpop == NULL) in dump_bpobj()1177 zdb_nicenum(bpop->bpo_bytes, bytes, sizeof (bytes)); in dump_bpobj()1178 zdb_nicenum(bpop->bpo_comp, comp, sizeof (comp)); in dump_bpobj()1179 zdb_nicenum(bpop->bpo_uncomp, uncomp, sizeof (uncomp)); in dump_bpobj()1182 (u_longlong_t)bpop->bpo_num_blkptrs); in dump_bpobj()1190 (u_longlong_t)bpop->bpo_subobjs); in dump_bpobj()1192 (u_longlong_t)bpop->bpo_num_subobjs); in dump_bpobj()1194 if (size >= sizeof (*bpop)) { in dump_bpobj()1196 (u_longlong_t)bpop->bpo_num_freed); in dump_bpobj()[all …]