summaryrefslogtreecommitdiff
path: root/example-libev.c
diff options
context:
space:
mode:
authorPieter Noordhuis <pcnoordhuis@gmail.com>2010-11-01 10:42:32 +0100
committerPieter Noordhuis <pcnoordhuis@gmail.com>2010-11-01 10:42:32 +0100
commit89e06225358c9b44998107bb55e80963904a30ce (patch)
tree350ce99ee5fbf974b8437bf561f9825d7607619b /example-libev.c
parentd5fc7d8c53db80fc0f5cbe59c3fe371c56c2b501 (diff)
Move libev/libevent headers to adapters directory
Diffstat (limited to 'example-libev.c')
-rw-r--r--example-libev.c39
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;
+}