Lines Matching refs:RedisModuleBlockedClient

114 struct RedisModuleBlockedClient;
120     struct RedisModuleBlockedClient *blocked_client; /* Blocked client for
176 struct RedisModuleBlockedClient;
178 typedef void (*RedisModuleDisconnectFunc) (RedisModuleCtx *ctx, struct RedisModuleBlockedClient *bc…
215 typedef struct RedisModuleBlockedClient {  struct
229 } RedisModuleBlockedClient;  argument
3570     RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle;  in unblockClientFromModule()
3606 RedisModuleBlockedClient *RM_BlockClient(RedisModuleCtx *ctx, RedisModuleCmdFunc reply_callback, Re…  in RM_BlockClient()
3611     c->bpop.module_blocked_handle = zmalloc(sizeof(RedisModuleBlockedClient));  in RM_BlockClient()
3612     RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle;  in RM_BlockClient()
3652 int RM_UnblockClient(RedisModuleBlockedClient *bc, void *privdata) {  in RM_UnblockClient()
3665 int RM_AbortBlock(RedisModuleBlockedClient *bc) {  in RM_AbortBlock()
3687 void RM_SetDisconnectCallback(RedisModuleBlockedClient *bc, RedisModuleDisconnectFunc callback) {  in RM_SetDisconnectCallback()
3701     RedisModuleBlockedClient *bc;  in moduleHandleBlockedClients()
3784     RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle;  in moduleBlockedClientTimedOut()
3819 RedisModuleBlockedClient *RM_GetBlockedClientHandle(RedisModuleCtx *ctx) {  in RM_GetBlockedClientHandle()
3853 RedisModuleCtx *RM_GetThreadSafeContext(RedisModuleBlockedClient *bc) {  in RM_GetThreadSafeContext()