projects
/
awesomized
/
libmemcached
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
|
github
raw
|
patch
|
inline
| side by side (from parent 1:
d46b596
)
Merge in fixes for get.
author
Brian Aker
<brian@tangent.org>
Sat, 12 Feb 2011 07:26:48 +0000
(23:26 -0800)
committer
Brian Aker
<brian@tangent.org>
Sat, 12 Feb 2011 07:26:48 +0000
(23:26 -0800)
libmemcached/get.c
patch
|
blob
|
history
diff --git
a/libmemcached/get.c
b/libmemcached/get.c
index 8d76507cd29dbd1564b6d6b12617f5efa4a4679f..a6cb549fce434185ebbcb6269cf40a7af558b7e6 100644
(file)
--- 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)
{
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;
}
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);
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;
}
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)
{
/* 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;
}
}
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);
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;
}
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)
{
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;
}
}
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);
{
memcached_server_response_reset(instance);
memcached_io_reset(instance);
+ fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
rc= MEMCACHED_SOME_ERRORS;
}
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);
{
memcached_server_response_reset(instance);
memcached_io_reset(instance);
+ fprintf(stderr, "%s:%d (%s)\n", __FILE__, __LINE__,__func__);fflush(stdout);
rc= MEMCACHED_SOME_ERRORS;
}
}
rc= MEMCACHED_SOME_ERRORS;
}
}