fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-03 00:01:04 +00:00
Code Issues Projects Releases Wiki Activity

RESP3: module.c updated.

Browse Source
This commit is contained in:
antirez 2018-11-30 17:12:32 +01:00
parent 920611a419
commit baf5b3f93a
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/module.c
View File

@ -1123,10 +1123,10 @@ int RM_ReplyWithArray(RedisModuleCtx *ctx, long len) {
ctx->postponed_arrays = zrealloc(ctx->postponed_arrays,sizeof(void*)* ctx->postponed_arrays = zrealloc(ctx->postponed_arrays,sizeof(void*)*
(ctx->postponed_arrays_count+1)); (ctx->postponed_arrays_count+1));
ctx->postponed_arrays[ctx->postponed_arrays_count] = ctx->postponed_arrays[ctx->postponed_arrays_count] =
addDeferredMultiBulkLength(c); addReplyDeferredLen(c);
ctx->postponed_arrays_count++; ctx->postponed_arrays_count++;
} else { } else {
addReplyMultiBulkLen(c,len); addReplyArrayLen(c,len);
} }
return REDISMODULE_OK; return REDISMODULE_OK;
} }
@ -1169,7 +1169,7 @@ void RM_ReplySetArrayLength(RedisModuleCtx *ctx, long len) {
return; return;
} }
ctx->postponed_arrays_count--; ctx->postponed_arrays_count--;
setDeferredMultiBulkLength(c, setDeferredArrayLen(c,
ctx->postponed_arrays[ctx->postponed_arrays_count], ctx->postponed_arrays[ctx->postponed_arrays_count],
len); len);
if (ctx->postponed_arrays_count == 0) { if (ctx->postponed_arrays_count == 0) {
@ -1205,7 +1205,7 @@ int RM_ReplyWithString(RedisModuleCtx *ctx, RedisModuleString *str) {
int RM_ReplyWithNull(RedisModuleCtx *ctx) { int RM_ReplyWithNull(RedisModuleCtx *ctx) {
client *c = moduleGetReplyClient(ctx); client *c = moduleGetReplyClient(ctx);
if (c == NULL) return REDISMODULE_OK; if (c == NULL) return REDISMODULE_OK;
addReply(c,shared.nullbulk); addReplyNull(c);
return REDISMODULE_OK; return REDISMODULE_OK;
} }
@ -4868,11 +4868,11 @@ NULL
dictIterator *di = dictGetIterator(modules); dictIterator *di = dictGetIterator(modules);
dictEntry *de; dictEntry *de;
addReplyMultiBulkLen(c,dictSize(modules)); addReplyArrayLen(c,dictSize(modules));
while ((de = dictNext(di)) != NULL) { while ((de = dictNext(di)) != NULL) {
sds name = dictGetKey(de); sds name = dictGetKey(de);
struct RedisModule *module = dictGetVal(de); struct RedisModule *module = dictGetVal(de);
addReplyMultiBulkLen(c,4); addReplyMapLen(c,2);
addReplyBulkCString(c,"name"); addReplyBulkCString(c,"name");
addReplyBulkCBuffer(c,name,sdslen(name)); addReplyBulkCBuffer(c,name,sdslen(name));
addReplyBulkCString(c,"ver"); addReplyBulkCString(c,"ver");