Revert "Add function to retrieve formatted reply"

This reverts commit 77540aa31694aa1e14d41f60a0452e49a2fed86a. The change
in buffer strategy is too large to put in a minor release. It is put in
a separate branch in the meantime, so it can be refined and released
together with a minor version bump.

1 files changed, 11 insertions, 39 deletions

diff --git a/hiredis.c b/hiredis.c
index 3aa3164..9ea998a 100644
--- a/hiredis.c
+++ b/hiredis.c
@@ -358,12 +358,7 @@ static int processLineItem(redisReader *r) {
     char *p;
     int len;
 
-    cur->poff = (r->pos-r->roff)-1;
-    cur->coff = cur->poff+1;
     if ((p = readLine(r,&len)) != NULL) {
-        cur->plen = 1+len+2; /* include \r\n */
-        cur->clen = len;
-
         if (cur->type == REDIS_REPLY_INTEGER) {
             if (r->fn && r->fn->createInteger)
                 obj = r->fn->createInteger(cur,readLongLong(p));
@@ -402,13 +397,10 @@ static int processBulkItem(redisReader *r) {
     p = r->buf+r->pos;
     s = seekNewline(p,r->len-r->pos);
     if (s != NULL) {
+        p = r->buf+r->pos;
         bytelen = s-(r->buf+r->pos)+2; /* include \r\n */
-        cur->poff = (r->pos-r->roff)-1;
-        cur->plen = bytelen+1;
-        cur->coff = cur->poff+1+bytelen;
-        cur->clen = 0;
-
         len = readLongLong(p);
+
         if (len < 0) {
             /* The nil object can always be created. */
             if (r->fn && r->fn->createNil)
@@ -420,8 +412,6 @@ static int processBulkItem(redisReader *r) {
             /* Only continue when the buffer contains the entire bulk item. */
             bytelen += len+2; /* include \r\n */
             if (r->pos+bytelen <= r->len) {
-                cur->plen += len+2;
-                cur->clen = len;
                 if (r->fn && r->fn->createString)
                     obj = r->fn->createString(cur,s+2,len);
                 else
@@ -463,12 +453,7 @@ static int processMultiBulkItem(redisReader *r) {
         return REDIS_ERR;
     }
 
-    cur->poff = (r->pos-r->roff)-1;
-    cur->coff = 0;
     if ((p = readLine(r,NULL)) != NULL) {
-        cur->plen = (r->pos-r->roff)-cur->poff; /* includes \r\n */
-        cur->clen = 0;
-
         elements = readLongLong(p);
         root = (r->ridx == 0);
 
@@ -605,7 +590,7 @@ int redisReaderFeed(redisReader *r, const char *buf, size_t len) {
 
     /* Copy the provided buffer. */
     if (buf != NULL && len >= 1) {
-        /* Destroy buffer when it is empty and is quite large. */
+        /* Destroy internal buffer when it is empty and is quite large. */
         if (r->len == 0 && sdsavail(r->buf) > 16*1024) {
             sdsfree(r->buf);
             r->buf = sdsempty();
@@ -615,15 +600,6 @@ int redisReaderFeed(redisReader *r, const char *buf, size_t len) {
             assert(r->buf != NULL);
         }
 
-        /* Discard consumed part of the buffer when the offset for the reply
-         * that is currently being read is high enough. */
-        if (r->roff >= 1024) {
-            r->buf = sdsrange(r->buf,r->roff,-1);
-            r->pos -= r->roff;
-            r->roff = 0;
-            r->len = sdslen(r->buf);
-        }
-
         newbuf = sdscatlen(r->buf,buf,len);
         if (newbuf == NULL) {
             __redisReaderSetErrorOOM(r);
@@ -659,7 +635,6 @@ int redisReaderGetReply(redisReader *r, void **reply) {
         r->rstack[0].parent = NULL;
         r->rstack[0].privdata = r->privdata;
         r->ridx = 0;
-        r->roff = r->pos; /* Start offset in buffer. */
     }
 
     /* Process items in reply. */
@@ -671,6 +646,14 @@ int redisReaderGetReply(redisReader *r, void **reply) {
     if (r->err)
         return REDIS_ERR;
 
+    /* Discard part of the buffer when we've consumed at least 1k, to avoid
+     * doing unnecessary calls to memmove() in sds.c. */
+    if (r->pos >= 1024) {
+        r->buf = sdsrange(r->buf,r->pos,-1);
+        r->pos = 0;
+        r->len = sdslen(r->buf);
+    }
+
     /* Emit a reply when there is one. */
     if (r->ridx == -1) {
         if (reply != NULL)
@@ -680,17 +663,6 @@ int redisReaderGetReply(redisReader *r, void **reply) {
     return REDIS_OK;
 }
 
-const char *redisReaderGetRaw(redisReader *r, size_t *len) {
-    /* ridx == -1: No or a full reply has been read. */
-    /* pos > roff: Buffer position is larger than start offset, meaning
-     *   the buffer has not yet been truncated. */
-    if (r->ridx == -1 && r->pos > r->roff) {
-        if (len) *len = (r->pos-r->roff);
-        return r->buf+r->roff;
-    }
-    return NULL;
-}
-
 /* Calculate the number of bytes needed to represent an integer as string. */
 static int intlen(int i) {
     int len = 0;