State should not be reset after protocol error

This commit is contained in:
Pieter Noordhuis 2011-04-21 10:54:54 +02:00
parent 26588f5007
commit fc790ebea6

4
test.c
View File

@ -325,14 +325,14 @@ static void test_reply_reader(void) {
test_cond(ret == REDIS_OK && reply == (void*)REDIS_REPLY_STATUS); test_cond(ret == REDIS_OK && reply == (void*)REDIS_REPLY_STATUS);
redisReplyReaderFree(reader); redisReplyReaderFree(reader);
test("Properly reset state after protocol error: "); test("Don't reset state after protocol error: ");
reader = redisReplyReaderCreate(); reader = redisReplyReaderCreate();
redisReplyReaderSetReplyObjectFunctions(reader,NULL); redisReplyReaderSetReplyObjectFunctions(reader,NULL);
redisReplyReaderFeed(reader,(char*)"x",1); redisReplyReaderFeed(reader,(char*)"x",1);
ret = redisReplyReaderGetReply(reader,&reply); ret = redisReplyReaderGetReply(reader,&reply);
assert(ret == REDIS_ERR); assert(ret == REDIS_ERR);
ret = redisReplyReaderGetReply(reader,&reply); ret = redisReplyReaderGetReply(reader,&reply);
test_cond(ret == REDIS_OK && reply == NULL) test_cond(ret == REDIS_ERR && reply == NULL);
} }
static void test_throughput(void) { static void test_throughput(void) {