From: Brian Aker <brian@tangent.org>
Date: Sat, 12 Feb 2011 07:26:48 +0000 (-0800)
Subject: Merge in fixes for get.
X-Git-Tag: 0.51~43^2~5
X-Git-Url: https://git.m6w6.name/?a=commitdiff_plain;h=d2346aec8760237e77a5c2ff982159bae9ee4579;p=awesomized%2Flibmemcached

Merge in fixes for get.
---

diff --git a/libmemcached/get.c b/libmemcached/get.c
index 8d76507c..a6cb549f 100644
--- a/libmemcached/get.c
+++ b/libmemcached/get.c
@@ -245,6 +245,7 @@ static memcached_return_t memcached_mget_by_key_real(memcached_st *ptr,
 
       if ((memcached_io_writev(instance, vector, 4, false)) == -1)
       {
+        fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
         rc= MEMCACHED_SOME_ERRORS;
         continue;
       }
@@ -257,6 +258,7 @@ static memcached_return_t memcached_mget_by_key_real(memcached_st *ptr,
       if ((memcached_io_writev(instance, (vector + 1), 3, false)) == -1)
       {
         memcached_server_response_reset(instance);
+        fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
         rc= MEMCACHED_SOME_ERRORS;
         continue;
       }
@@ -276,6 +278,7 @@ static memcached_return_t memcached_mget_by_key_real(memcached_st *ptr,
       /* We need to do something about non-connnected hosts in the future */
       if ((memcached_io_write(instance, "\r\n", 2, true)) == -1)
       {
+        fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
         rc= MEMCACHED_SOME_ERRORS;
       }
     }
@@ -409,6 +412,7 @@ static memcached_return_t simple_binary_mget(memcached_st *ptr,
     if (memcached_io_writev(instance, vector, 3, flush) == -1)
     {
       memcached_server_response_reset(instance);
+      fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
       rc= MEMCACHED_SOME_ERRORS;
       continue;
     }
@@ -418,6 +422,7 @@ static memcached_return_t simple_binary_mget(memcached_st *ptr,
     memcached_server_response_increment(instance);
     if ((x > 0 && x == ptr->io_key_prefetch) && memcached_flush_buffers(ptr) != MEMCACHED_SUCCESS)
     {
+      fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
       rc= MEMCACHED_SOME_ERRORS;
     }
   }
@@ -443,6 +448,7 @@ static memcached_return_t simple_binary_mget(memcached_st *ptr,
         {
           memcached_server_response_reset(instance);
           memcached_io_reset(instance);
+          fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
           rc= MEMCACHED_SOME_ERRORS;
         }
 
@@ -451,6 +457,7 @@ static memcached_return_t simple_binary_mget(memcached_st *ptr,
         {
           memcached_server_response_reset(instance);
           memcached_io_reset(instance);
+          fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
           rc= MEMCACHED_SOME_ERRORS;
         }
       }