summaryrefslogtreecommitdiff
path: root/test.c
diff options
context:
space:
mode:
authorPieter Noordhuis <pcnoordhuis@gmail.com>2010-09-21 11:39:18 +0200
committerPieter Noordhuis <pcnoordhuis@gmail.com>2010-09-21 11:39:18 +0200
commitaf8ba74cbfdbecf5ebdf99c506e264bed2d0efb2 (patch)
tree5bfb0b3845ba228c92c58face28cc8ee7ffb63d6 /test.c
parentb1bedf5c6df6290249850f73912d9fc566782b64 (diff)
Rename functions to be more consistent, split feed from get reply
Diffstat (limited to 'test.c')
-rw-r--r--test.c18
1 files changed, 10 insertions, 8 deletions
diff --git a/test.c b/test.c
index 020d125..640cabd 100644
--- a/test.c
+++ b/test.c
@@ -124,24 +124,26 @@ int main(void) {
freeReplyObject(reply);
test("Error handling in reply parser: ");
- reader = redisCreateReplyReader(NULL);
- reply = redisFeedReplyReader(reader,(char*)"@foo\r\n",6);
+ reader = redisReplyReaderCreate(NULL);
+ redisReplyReaderFeed(reader,(char*)"@foo\r\n",6);
+ reply = redisReplyReaderGetReply(reader);
test_cond(reply->type == REDIS_PROTOCOL_ERROR &&
strcasecmp(reply->reply,"protocol error, got \"@\" as reply type byte") == 0);
freeReplyObject(reply);
- redisFreeReplyReader(reader);
+ redisReplyReaderFree(reader);
/* when the reply already contains multiple items, they must be free'd
* on an error. valgrind will bark when this doesn't happen. */
test("Memory cleanup in reply parser: ");
- reader = redisCreateReplyReader(NULL);
- redisFeedReplyReader(reader,(char*)"*2\r\n",4);
- redisFeedReplyReader(reader,(char*)"$5\r\nhello\r\n",11);
- reply = redisFeedReplyReader(reader,(char*)"@foo\r\n",6);
+ reader = redisReplyReaderCreate(NULL);
+ redisReplyReaderFeed(reader,(char*)"*2\r\n",4);
+ redisReplyReaderFeed(reader,(char*)"$5\r\nhello\r\n",11);
+ redisReplyReaderFeed(reader,(char*)"@foo\r\n",6);
+ reply = redisReplyReaderGetReply(reader);
test_cond(reply->type == REDIS_PROTOCOL_ERROR &&
strcasecmp(reply->reply,"protocol error, got \"@\" as reply type byte") == 0);
freeReplyObject(reply);
- redisFreeReplyReader(reader);
+ redisReplyReaderFree(reader);
test("Throughput:\n");
for (i = 0; i < 500; i++)