X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fio.c;fp=libmemcached%2Fio.c;h=3b8943c8dc31c1c00a0f0bc0b1705cb8f150f6e8;hb=e42302e08fa4d04cb21eaf7493f5f92b11169c03;hp=179bdc48121b2cce451b33e2b5d5de6e261bda34;hpb=c67da677fe0944d3d2d3ff46e65fc3bc775404ae;p=m6w6%2Flibmemcached

diff --git a/libmemcached/io.c b/libmemcached/io.c
index 179bdc48..3b8943c8 100644
--- a/libmemcached/io.c
+++ b/libmemcached/io.c
@@ -127,10 +127,15 @@ static bool process_input_buffer(memcached_server_instance_st *ptr)
    */
     memcached_callback_st cb= *ptr->root->callbacks;
 
+    ptr->root->options.is_processing_input= true;
+
     char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
     memcached_return_t error;
     error= memcached_response(ptr, buffer, sizeof(buffer),
                               &ptr->root->result);
+
+    ptr->root->options.is_processing_input = false;
+
     if (error == MEMCACHED_SUCCESS)
     {
       for (unsigned int x= 0; x < cb.number_of_callback; x++)