diff options
author | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2010-11-01 10:42:32 +0100 |
---|---|---|
committer | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2010-11-01 10:42:32 +0100 |
commit | 89e06225358c9b44998107bb55e80963904a30ce (patch) | |
tree | 350ce99ee5fbf974b8437bf561f9825d7607619b /example-libevent.c | |
parent | d5fc7d8c53db80fc0f5cbe59c3fe371c56c2b501 (diff) |
Move libev/libevent headers to adapters directory
Diffstat (limited to 'example-libevent.c')
-rw-r--r-- | example-libevent.c | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/example-libevent.c b/example-libevent.c new file mode 100644 index 0000000..101fa71 --- /dev/null +++ b/example-libevent.c @@ -0,0 +1,39 @@ +#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, redisReply *reply, void *privdata) { + printf("argv[%s]: %s\n", (char*)privdata, reply->str); + + /* Disconnect after receiving the reply to GET */ + redisAsyncDisconnect(c); +} + +void disconnectCallback(const redisAsyncContext *c, int status) { + if (status != REDIS_OK) { + printf("Error: %s\n", c->error); + } +} + +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->error != NULL) { + /* Let *c leak for now... */ + printf("Error: %s\n", c->error); + return 1; + } + + redisLibeventAttach(c,base); + 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; +} |