diff options
author | Aaron Bedra <aaron@aaronbedra.com> | 2013-04-19 15:39:26 -0500 |
---|---|---|
committer | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2013-07-10 22:16:53 -0700 |
commit | c552ca6904f55c5eee40e309e31cf2d4325a84b6 (patch) | |
tree | 3a08471079c9976c63603e802b4c436fc7c1924c /examples/example-libevent.c | |
parent | 49de2cf99056bb5c33502ab86d9c397998d379ed (diff) |
Move examples into their own folder
Closes #166.
Diffstat (limited to 'examples/example-libevent.c')
-rw-r--r-- | examples/example-libevent.c | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/examples/example-libevent.c b/examples/example-libevent.c new file mode 100644 index 0000000..d333c22 --- /dev/null +++ b/examples/example-libevent.c @@ -0,0 +1,53 @@ +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <signal.h> + +#include <hiredis.h> +#include <async.h> +#include <adapters/libevent.h> + +void getCallback(redisAsyncContext *c, void *r, void *privdata) { + redisReply *reply = r; + if (reply == NULL) return; + printf("argv[%s]: %s\n", (char*)privdata, reply->str); + + /* Disconnect after receiving the reply to GET */ + redisAsyncDisconnect(c); +} + +void connectCallback(const redisAsyncContext *c, int status) { + if (status != REDIS_OK) { + printf("Error: %s\n", c->errstr); + return; + } + printf("Connected...\n"); +} + +void disconnectCallback(const redisAsyncContext *c, int status) { + if (status != REDIS_OK) { + printf("Error: %s\n", c->errstr); + return; + } + printf("Disconnected...\n"); +} + +int main (int argc, char **argv) { + signal(SIGPIPE, SIG_IGN); + struct event_base *base = event_base_new(); + + redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); + if (c->err) { + /* Let *c leak for now... */ + printf("Error: %s\n", c->errstr); + return 1; + } + + redisLibeventAttach(c,base); + redisAsyncSetConnectCallback(c,connectCallback); + redisAsyncSetDisconnectCallback(c,disconnectCallback); + redisAsyncCommand(c, NULL, NULL, "SET key %b", argv[argc-1], strlen(argv[argc-1])); + redisAsyncCommand(c, getCallback, (char*)"end-1", "GET key"); + event_base_dispatch(base); + return 0; +} |