Lines Matching refs:bc
66 RedisModuleBlockedClient *bc = targ[0]; in HelloBlock_ThreadMain() local
73 RedisModule_UnblockClient(bc,r); in HelloBlock_ThreadMain()
85 void HelloBlock_Disconnected(RedisModuleCtx *ctx, RedisModuleBlockedClient *bc) { in HelloBlock_Disconnected() argument
87 (void*)bc); in HelloBlock_Disconnected()
111 …RedisModuleBlockedClient *bc = RedisModule_BlockClient(ctx,HelloBlock_Reply,HelloBlock_Timeout,Hel… in HelloBlock_RedisCommand() local
116 RedisModule_SetDisconnectCallback(bc,HelloBlock_Disconnected); in HelloBlock_RedisCommand()
122 targ[0] = bc; in HelloBlock_RedisCommand()
126 RedisModule_AbortBlock(bc); in HelloBlock_RedisCommand()
140 RedisModuleBlockedClient *bc = arg; in HelloKeys_ThreadMain() local
141 RedisModuleCtx *ctx = RedisModule_GetThreadSafeContext(bc); in HelloKeys_ThreadMain()
173 RedisModule_UnblockClient(bc,NULL); in HelloKeys_ThreadMain()
190 RedisModuleBlockedClient *bc = RedisModule_BlockClient(ctx,NULL,NULL,NULL,0); in HelloKeys_RedisCommand() local
195 if (pthread_create(&tid,NULL,HelloKeys_ThreadMain,bc) != 0) { in HelloKeys_RedisCommand()
196 RedisModule_AbortBlock(bc); in HelloKeys_RedisCommand()