projects
/
awesomized
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
libmemcached: fix #53 with supplied patch
[awesomized/libmemcached]
/
libmemcached
/
response.cc
diff --git
a/libmemcached/response.cc
b/libmemcached/response.cc
index 79ab7e6599cef0c5e9b0ad5f6eb5a96154d93b19..554f6dce3852fe67011b81d8e617c5fde819cb8a 100644
(file)
--- a/
libmemcached/response.cc
+++ b/
libmemcached/response.cc
@@
-783,7
+783,7
@@
static memcached_return_t binary_read_one_response(memcached_instance_st* instan
case PROTOCOL_BINARY_CMD_REPLACEQ:
case PROTOCOL_BINARY_CMD_APPENDQ:
case PROTOCOL_BINARY_CMD_PREPENDQ:
case PROTOCOL_BINARY_CMD_REPLACEQ:
case PROTOCOL_BINARY_CMD_APPENDQ:
case PROTOCOL_BINARY_CMD_PREPENDQ:
- return
binary_read_one_response(instance, buffer, buffer_length, result)
;
+ return
MEMCACHED_FETCH_NOTFINISHED
;
default:
break;
default:
break;
@@
-849,7
+849,9
@@
static memcached_return_t _read_one_response(memcached_instance_st* instance,
memcached_return_t rc;
if (memcached_is_binary(instance->root))
{
memcached_return_t rc;
if (memcached_is_binary(instance->root))
{
- rc= binary_read_one_response(instance, buffer, buffer_length, result);
+ do {
+ rc= binary_read_one_response(instance, buffer, buffer_length, result);
+ } while (rc == MEMCACHED_FETCH_NOTFINISHED);
}
else
{
}
else
{