Commit b1fa529c authored by Pieter Noordhuis's avatar Pieter Noordhuis
Browse files

Add function to check if the reply reader is empty

parent e944ea36
......@@ -326,6 +326,15 @@ void redisFreeReplyReader(void *reader) {
free(r);
}
int redisIsReplyReaderEmpty(void *reader) {
redisReader *r = reader;
if (r->buf != NULL && sdslen(r->buf) > 0)
return 0;
if (r->rlist != NULL && r->rpos < r->rlen)
return 0;
return 1;
}
static void redisSetReplyReaderError(redisReader *r, redisReply *error) {
/* Clear remaining buffer when we see a protocol error. */
if (r->buf != NULL) {
......
......@@ -54,6 +54,7 @@ void freeReplyObject(redisReply *r);
redisReply *redisCommand(int fd, const char *format, ...);
void *redisCreateReplyReader();
void redisFreeReplyReader(void *ptr);
int redisIsReplyReaderEmpty(void *ptr);
void *redisFeedReplyReader(void *reader, char *buf, int len);
#endif
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment