diff --git a/src/modules/helloblock.c b/src/modules/helloblock.c index f76b3beb..71ec9b12 100644 --- a/src/modules/helloblock.c +++ b/src/modules/helloblock.c @@ -99,7 +99,7 @@ int HelloBlock_RedisCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int a targ[1] = (void*)(unsigned long) delay; if (pthread_create(&tid,NULL,HelloBlock_ThreadMain,targ) != 0) { - /* RedisModule_BlockedClientAbort(bc); */ + RedisModule_AbortBlock(bc); return RedisModule_ReplyWithError(ctx,"-ERR Can't start thread"); } return REDISMODULE_OK;