From 991b0b0b31d8b6c907db0fafdd4fdabb1b432d4e Mon Sep 17 00:00:00 2001 From: Michael Grunder Date: Sat, 12 Nov 2022 20:18:45 -0800 Subject: Add an example that calls redisCommandArgv (#1140) See #1138 --- examples/example.c | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 51 insertions(+) diff --git a/examples/example.c b/examples/example.c index f1b8b4a..c0a9bb7 100644 --- a/examples/example.c +++ b/examples/example.c @@ -7,6 +7,54 @@ #include /* For struct timeval */ #endif +static void example_argv_command(redisContext *c, size_t n) { + char **argv, tmp[42]; + size_t *argvlen; + redisReply *reply; + + /* We're allocating two additional elements for command and key */ + argv = malloc(sizeof(*argv) * (2 + n)); + argvlen = malloc(sizeof(*argvlen) * (2 + n)); + + /* First the command */ + argv[0] = (char*)"RPUSH"; + argvlen[0] = sizeof("RPUSH") - 1; + + /* Now our key */ + argv[1] = (char*)"argvlist"; + argvlen[1] = sizeof("argvlist") - 1; + + /* Now add the entries we wish to add to the list */ + for (size_t i = 2; i < (n + 2); i++) { + argvlen[i] = snprintf(tmp, sizeof(tmp), "argv-element-%zu", i - 2); + argv[i] = strdup(tmp); + } + + /* Execute the command using redisCommandArgv. We're sending the arguments with + * two explicit arrays. One for each argument's string, and the other for its + * length. */ + reply = redisCommandArgv(c, n + 2, (const char **)argv, (const size_t*)argvlen); + + if (reply == NULL || c->err) { + fprintf(stderr, "Error: Couldn't execute redisCommandArgv\n"); + exit(1); + } + + if (reply->type == REDIS_REPLY_INTEGER) { + printf("%s reply: %lld\n", argv[0], reply->integer); + } + + freeReplyObject(reply); + + /* Clean up */ + for (size_t i = 2; i < (n + 2); i++) { + free(argv[i]); + } + + free(argv); + free(argvlen); +} + int main(int argc, char **argv) { unsigned int j, isunix = 0; redisContext *c; @@ -87,6 +135,9 @@ int main(int argc, char **argv) { } freeReplyObject(reply); + /* See function for an example of redisCommandArgv */ + example_argv_command(c, 10); + /* Disconnects and frees the context */ redisFree(c); -- cgit v1.2.3