diff options
author | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2010-09-24 18:48:07 +0200 |
---|---|---|
committer | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2010-09-24 18:48:07 +0200 |
commit | d156550886663c6bedcda3975ef614bf65126432 (patch) | |
tree | 3c7f4c5c7187a0c6a8b9e14935fa41c51db70127 | |
parent | 817d26b81df7028ff8bcb8690dae0cec1319b63a (diff) |
Rename fd to the more appropriate c
-rw-r--r-- | example.c | 26 | ||||
-rw-r--r-- | test.c | 50 |
2 files changed, 38 insertions, 38 deletions
@@ -5,57 +5,57 @@ #include "hiredis.h" int main(void) { - redisContext *fd; unsigned int j; + redisContext *c; redisReply *reply; - fd = redisConnect((char*)"127.0.0.1", 6379, NULL); - if (fd->error != NULL) { - printf("Connection error: %s", ((redisReply*)fd->error)->reply); + c = redisConnect((char*)"127.0.0.1", 6379, NULL); + if (c->error != NULL) { + printf("Connection error: %s", ((redisReply*)c->error)->reply); exit(1); } /* PING server */ - reply = redisCommand(fd,"PING"); + reply = redisCommand(c,"PING"); printf("PONG: %s\n", reply->reply); freeReplyObject(reply); /* Set a key */ - reply = redisCommand(fd,"SET %s %s", "foo", "hello world"); + reply = redisCommand(c,"SET %s %s", "foo", "hello world"); printf("SET: %s\n", reply->reply); freeReplyObject(reply); /* Set a key using binary safe API */ - reply = redisCommand(fd,"SET %b %b", "bar", 3, "hello", 5); + reply = redisCommand(c,"SET %b %b", "bar", 3, "hello", 5); printf("SET (binary API): %s\n", reply->reply); freeReplyObject(reply); /* Try a GET and two INCR */ - reply = redisCommand(fd,"GET foo"); + reply = redisCommand(c,"GET foo"); printf("GET foo: %s\n", reply->reply); freeReplyObject(reply); - reply = redisCommand(fd,"INCR counter"); + reply = redisCommand(c,"INCR counter"); printf("INCR counter: %lld\n", reply->integer); freeReplyObject(reply); /* again ... */ - reply = redisCommand(fd,"INCR counter"); + reply = redisCommand(c,"INCR counter"); printf("INCR counter: %lld\n", reply->integer); freeReplyObject(reply); /* Create a list of numbers, from 0 to 9 */ - reply = redisCommand(fd,"DEL mylist"); + reply = redisCommand(c,"DEL mylist"); freeReplyObject(reply); for (j = 0; j < 10; j++) { char buf[64]; snprintf(buf,64,"%d",j); - reply = redisCommand(fd,"LPUSH mylist element-%s", buf); + reply = redisCommand(c,"LPUSH mylist element-%s", buf); freeReplyObject(reply); } /* Let's check what we have inside the list */ - reply = redisCommand(fd,"LRANGE mylist 0 -1"); + reply = redisCommand(c,"LRANGE mylist 0 -1"); if (reply->type == REDIS_REPLY_ARRAY) { for (j = 0; j < reply->elements; j++) { printf("%u) %s\n", j, reply->element[j]->reply); @@ -25,32 +25,32 @@ static void __connect(redisContext **c) { } int main(void) { - redisContext *fd; int i, tests = 0, fails = 0; long long t1, t2; + redisContext *c; redisReply *reply; void *reader; - __connect(&fd); + __connect(&c); test("Returns I/O error when the connection is lost: "); - reply = redisCommand(fd,"QUIT"); + reply = redisCommand(c,"QUIT"); test_cond(reply->type == REDIS_ERROR && strcmp(reply->reply,"Server closed the connection") == 0); freeReplyObject(reply); - __connect(&fd); /* reconnect */ + __connect(&c); /* reconnect */ test("Is able to deliver commands: "); - reply = redisCommand(fd,"PING"); + reply = redisCommand(c,"PING"); test_cond(reply->type == REDIS_REPLY_STRING && strcasecmp(reply->reply,"pong") == 0) freeReplyObject(reply); /* Switch to DB 9 for testing, now that we know we can chat. */ - reply = redisCommand(fd,"SELECT 9"); + reply = redisCommand(c,"SELECT 9"); freeReplyObject(reply); /* Make sure the DB is emtpy */ - reply = redisCommand(fd,"DBSIZE"); + reply = redisCommand(c,"DBSIZE"); if (reply->type != REDIS_REPLY_INTEGER || reply->integer != 0) { printf("Sorry DB 9 is not empty, test can not continue\n"); @@ -61,23 +61,23 @@ int main(void) { freeReplyObject(reply); test("Is a able to send commands verbatim: "); - reply = redisCommand(fd,"SET foo bar"); + reply = redisCommand(c,"SET foo bar"); test_cond (reply->type == REDIS_REPLY_STRING && strcasecmp(reply->reply,"ok") == 0) freeReplyObject(reply); test("%%s String interpolation works: "); - reply = redisCommand(fd,"SET %s %s","foo","hello world"); + reply = redisCommand(c,"SET %s %s","foo","hello world"); freeReplyObject(reply); - reply = redisCommand(fd,"GET foo"); + reply = redisCommand(c,"GET foo"); test_cond(reply->type == REDIS_REPLY_STRING && strcmp(reply->reply,"hello world") == 0); freeReplyObject(reply); test("%%b String interpolation works: "); - reply = redisCommand(fd,"SET %b %b","foo",3,"hello\x00world",11); + reply = redisCommand(c,"SET %b %b","foo",3,"hello\x00world",11); freeReplyObject(reply); - reply = redisCommand(fd,"GET foo"); + reply = redisCommand(c,"GET foo"); test_cond(reply->type == REDIS_REPLY_STRING && memcmp(reply->reply,"hello\x00world",11) == 0) @@ -86,20 +86,20 @@ int main(void) { freeReplyObject(reply); test("Can parse nil replies: "); - reply = redisCommand(fd,"GET nokey"); + reply = redisCommand(c,"GET nokey"); test_cond(reply->type == REDIS_REPLY_NIL) freeReplyObject(reply); /* test 7 */ test("Can parse integer replies: "); - reply = redisCommand(fd,"INCR mycounter"); + reply = redisCommand(c,"INCR mycounter"); test_cond(reply->type == REDIS_REPLY_INTEGER && reply->integer == 1) freeReplyObject(reply); test("Can parse multi bulk replies: "); - freeReplyObject(redisCommand(fd,"LPUSH mylist foo")); - freeReplyObject(redisCommand(fd,"LPUSH mylist bar")); - reply = redisCommand(fd,"LRANGE mylist 0 -1"); + freeReplyObject(redisCommand(c,"LPUSH mylist foo")); + freeReplyObject(redisCommand(c,"LPUSH mylist bar")); + reply = redisCommand(c,"LRANGE mylist 0 -1"); test_cond(reply->type == REDIS_REPLY_ARRAY && reply->elements == 2 && !memcmp(reply->element[0]->reply,"bar",3) && @@ -109,10 +109,10 @@ int main(void) { /* m/e with multi bulk reply *before* other reply. * specifically test ordering of reply items to parse. */ test("Can handle nested multi bulk replies: "); - freeReplyObject(redisCommand(fd,"MULTI")); - freeReplyObject(redisCommand(fd,"LRANGE mylist 0 -1")); - freeReplyObject(redisCommand(fd,"PING")); - reply = (redisCommand(fd,"EXEC")); + freeReplyObject(redisCommand(c,"MULTI")); + freeReplyObject(redisCommand(c,"LRANGE mylist 0 -1")); + freeReplyObject(redisCommand(c,"PING")); + reply = (redisCommand(c,"EXEC")); test_cond(reply->type == REDIS_REPLY_ARRAY && reply->elements == 2 && reply->element[0]->type == REDIS_REPLY_ARRAY && @@ -147,22 +147,22 @@ int main(void) { test("Throughput:\n"); for (i = 0; i < 500; i++) - freeReplyObject(redisCommand(fd,"LPUSH mylist foo")); + freeReplyObject(redisCommand(c,"LPUSH mylist foo")); t1 = usec(); for (i = 0; i < 1000; i++) - freeReplyObject(redisCommand(fd,"PING")); + freeReplyObject(redisCommand(c,"PING")); t2 = usec(); printf("\t(1000x PING: %.2fs)\n", (t2-t1)/1000000.0); t1 = usec(); for (i = 0; i < 1000; i++) - freeReplyObject(redisCommand(fd,"LRANGE mylist 0 499")); + freeReplyObject(redisCommand(c,"LRANGE mylist 0 499")); t2 = usec(); printf("\t(1000x LRANGE with 500 elements: %.2fs)\n", (t2-t1)/1000000.0); /* Clean DB 9 */ - reply = redisCommand(fd,"FLUSHDB"); + reply = redisCommand(c,"FLUSHDB"); freeReplyObject(reply); if (fails == 0) { |