Home
last modified time | relevance | path

Searched refs:RedisModuleBlockedClient (Results 1 – 3 of 3) sorted by relevance

/f-stack/app/redis-5.0.5/src/modules/
H A Dhelloblock.c66 RedisModuleBlockedClient *bc = targ[0]; in HelloBlock_ThreadMain()
85 void HelloBlock_Disconnected(RedisModuleCtx *ctx, RedisModuleBlockedClient *bc) { in HelloBlock_Disconnected()
111 …RedisModuleBlockedClient *bc = RedisModule_BlockClient(ctx,HelloBlock_Reply,HelloBlock_Timeout,Hel… in HelloBlock_RedisCommand()
140 RedisModuleBlockedClient *bc = arg; in HelloKeys_ThreadMain()
190 RedisModuleBlockedClient *bc = RedisModule_BlockClient(ctx,NULL,NULL,NULL,0); in HelloKeys_RedisCommand()
/f-stack/app/redis-5.0.5/src/
H A Dredismodule.h154 typedef struct RedisModuleBlockedClient RedisModuleBlockedClient; typedef
162 typedef void (*RedisModuleDisconnectFunc)(RedisModuleCtx *ctx, RedisModuleBlockedClient *bc);
320 RedisModuleBlockedClient *REDISMODULE_API_FUNC(RedisModule_BlockClient)(RedisModuleCtx *ctx, RedisM…
321 int REDISMODULE_API_FUNC(RedisModule_UnblockClient)(RedisModuleBlockedClient *bc, void *privdata);
325 RedisModuleBlockedClient *REDISMODULE_API_FUNC(RedisModule_GetBlockedClientHandle)(RedisModuleCtx *…
326 int REDISMODULE_API_FUNC(RedisModule_AbortBlock)(RedisModuleBlockedClient *bc);
327 RedisModuleCtx *REDISMODULE_API_FUNC(RedisModule_GetThreadSafeContext)(RedisModuleBlockedClient *bc…
345 void REDISMODULE_API_FUNC(RedisModule_SetDisconnectCallback)(RedisModuleBlockedClient *bc, RedisMod…
H A Dmodule.c114 struct RedisModuleBlockedClient;
120 struct RedisModuleBlockedClient *blocked_client; /* Blocked client for
176 struct RedisModuleBlockedClient;
215 typedef struct RedisModuleBlockedClient { struct
229 } RedisModuleBlockedClient; argument
3570 RedisModuleBlockedClient *bc = c->bpop.module_blocked_handle; in unblockClientFromModule()
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()
3701 RedisModuleBlockedClient *bc; in moduleHandleBlockedClients()
[all …]