From 89e06225358c9b44998107bb55e80963904a30ce Mon Sep 17 00:00:00 2001 From: Pieter Noordhuis Date: Mon, 1 Nov 2010 10:42:32 +0100 Subject: Move libev/libevent headers to adapters directory --- example-libevent.c | 39 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 example-libevent.c (limited to 'example-libevent.c') 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 +#include +#include +#include +#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; +} -- cgit v1.2.3