root
/
redis
mirror of https://github.com/redis/redis.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

fix valgrind issues with recently added test in modules/blockonbackground (#9192) 

fixes test issue introduced in #9167

1. invalid reads due to accessing non-retained string (passed as unblock context).
2. leaking module blocked client context, see #6922 for info.
This commit is contained in:
Oran Agra 2021-07-04 14:21:53 +03:00 committed by GitHub
parent 8f59f131e5
commit a8518cce95
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/modules/blockonbackground.c
View File

@ -206,6 +206,7 @@ int Block_RedisCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc)
RedisModuleString *r = RedisModule_GetBlockedClientPrivateData(ctx); RedisModuleString *r = RedisModule_GetBlockedClientPrivateData(ctx);
return RedisModule_ReplyWithString(ctx, r); return RedisModule_ReplyWithString(ctx, r);
} else if (RedisModule_IsBlockedTimeoutRequest(ctx)) { } else if (RedisModule_IsBlockedTimeoutRequest(ctx)) {
RedisModule_UnblockClient(blocked_client, NULL); /* Must be called to avoid leaks. */
blocked_client = NULL; blocked_client = NULL;
return RedisModule_ReplyWithSimpleString(ctx, "Timed out"); return RedisModule_ReplyWithSimpleString(ctx, "Timed out");
} }
@ -245,7 +246,9 @@ int Release_RedisCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc
return RedisModule_ReplyWithError(ctx, "ERR No blocked client"); return RedisModule_ReplyWithError(ctx, "ERR No blocked client");
} }
RedisModule_UnblockClient(blocked_client, argv[1]); RedisModuleString *replystr = argv[1];
RedisModule_RetainString(ctx, replystr);
int err = RedisModule_UnblockClient(blocked_client, replystr);
blocked_client = NULL; blocked_client = NULL;
RedisModule_ReplyWithSimpleString(ctx, "OK"); RedisModule_ReplyWithSimpleString(ctx, "OK");