diff options
Diffstat (limited to 'examples/example-libsdevent.c')
-rw-r--r-- | examples/example-libsdevent.c | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/examples/example-libsdevent.c b/examples/example-libsdevent.c index 8599b76..6e544fc 100644 --- a/examples/example-libsdevent.c +++ b/examples/example-libsdevent.c @@ -13,20 +13,20 @@ #include <async.h> #include <adapters/libsdevent.h> -void debugCallback(redisAsyncContext *c, void *r, void *privdata) { +void debugCallback(redictAsyncContext *c, void *r, void *privdata) { (void)privdata; - redisReply *reply = r; + redictReply *reply = r; if (reply == NULL) { /* The DEBUG SLEEP command will almost always fail, because we have set a 1 second timeout */ printf("`DEBUG SLEEP` error: %s\n", c->errstr ? c->errstr : "unknown error"); return; } /* Disconnect after receiving the reply of DEBUG SLEEP (which will not)*/ - redisAsyncDisconnect(c); + redictAsyncDisconnect(c); } -void getCallback(redisAsyncContext *c, void *r, void *privdata) { - redisReply *reply = r; +void getCallback(redictAsyncContext *c, void *r, void *privdata) { + redictReply *reply = r; if (reply == NULL) { printf("`GET key` error: %s\n", c->errstr ? c->errstr : "unknown error"); return; @@ -34,19 +34,19 @@ void getCallback(redisAsyncContext *c, void *r, void *privdata) { printf("`GET key` result: argv[%s]: %s\n", (char*)privdata, reply->str); /* start another request that demonstrate timeout */ - redisAsyncCommand(c, debugCallback, NULL, "DEBUG SLEEP %f", 1.5); + redictAsyncCommand(c, debugCallback, NULL, "DEBUG SLEEP %f", 1.5); } -void connectCallback(const redisAsyncContext *c, int status) { - if (status != REDIS_OK) { +void connectCallback(const redictAsyncContext *c, int status) { + if (status != REDICT_OK) { printf("connect error: %s\n", c->errstr); return; } printf("Connected...\n"); } -void disconnectCallback(const redisAsyncContext *c, int status) { - if (status != REDIS_OK) { +void disconnectCallback(const redictAsyncContext *c, int status) { + if (status != REDICT_OK) { printf("disconnect because of error: %s\n", c->errstr); return; } @@ -59,17 +59,17 @@ int main (int argc, char **argv) { struct sd_event *event; sd_event_default(&event); - redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); + redictAsyncContext *c = redictAsyncConnect("127.0.0.1", 6379); if (c->err) { printf("Error: %s\n", c->errstr); - redisAsyncFree(c); + redictAsyncFree(c); return 1; } - redisLibsdeventAttach(c,event); - redisAsyncSetConnectCallback(c,connectCallback); - redisAsyncSetDisconnectCallback(c,disconnectCallback); - redisAsyncSetTimeout(c, (struct timeval){ .tv_sec = 1, .tv_usec = 0}); + redictLibsdeventAttach(c,event); + redictAsyncSetConnectCallback(c,connectCallback); + redictAsyncSetDisconnectCallback(c,disconnectCallback); + redictAsyncSetTimeout(c, (struct timeval){ .tv_sec = 1, .tv_usec = 0}); /* In this demo, we first `set key`, then `get key` to demonstrate the basic usage of libsdevent adapter. @@ -78,8 +78,8 @@ int main (int argc, char **argv) { timeout error, which is shown in the `debugCallback`. */ - redisAsyncCommand(c, NULL, NULL, "SET key %b", argv[argc-1], strlen(argv[argc-1])); - redisAsyncCommand(c, getCallback, (char*)"end-1", "GET key"); + redictAsyncCommand(c, NULL, NULL, "SET key %b", argv[argc-1], strlen(argv[argc-1])); + redictAsyncCommand(c, getCallback, (char*)"end-1", "GET key"); /* sd-event does not quit when there are no handlers registered. Manually exit after 1.5 seconds */ sd_event_source *s; |