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-libev.c | |
parent | d5fc7d8c53db80fc0f5cbe59c3fe371c56c2b501 (diff) |
Move libev/libevent headers to adapters directory
Diffstat (limited to 'example-libev.c')
-rw-r--r-- | example-libev.c | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/example-libev.c b/example-libev.c new file mode 100644 index 0000000..3495b2f --- /dev/null +++ b/example-libev.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/libev.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 ev_loop *loop = ev_default_loop(0); + + 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; + } + + redisLibevAttach(c,loop); + 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"); + ev_loop(loop, 0); + return 0; +} |