projects
/
awesomized
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Update changelog
[awesomized/libmemcached]
/
libmemcached
/
memcached_version.c
diff --git
a/libmemcached/memcached_version.c
b/libmemcached/memcached_version.c
index 0a77529c7d1ed5ab1926c903a774fe0082728791..30bcb1bd28554638681c45618036cd93d3b71048 100644
(file)
--- a/
libmemcached/memcached_version.c
+++ b/
libmemcached/memcached_version.c
@@
-10,6
+10,9
@@
static inline memcached_return memcached_version_textual(memcached_st *ptr);
memcached_return memcached_version(memcached_st *ptr)
{
memcached_return memcached_version(memcached_st *ptr)
{
+ if (ptr->flags & MEM_USE_UDP)
+ return MEMCACHED_NOT_SUPPORTED;
+
if (ptr->flags & MEM_BINARY_PROTOCOL)
return memcached_version_binary(ptr);
else
if (ptr->flags & MEM_BINARY_PROTOCOL)
return memcached_version_binary(ptr);
else
@@
-41,7
+44,10
@@
static inline memcached_return memcached_version_textual(memcached_st *ptr)
rrc= memcached_response(&ptr->hosts[x], buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, NULL);
if (rrc != MEMCACHED_SUCCESS)
rrc= memcached_response(&ptr->hosts[x], buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, NULL);
if (rrc != MEMCACHED_SUCCESS)
+ {
rc= MEMCACHED_SOME_ERRORS;
rc= MEMCACHED_SOME_ERRORS;
+ continue;
+ }
/* Find the space, and then move one past it to copy version */
response_ptr= index(buffer, ' ');
/* Find the space, and then move one past it to copy version */
response_ptr= index(buffer, ' ');
@@
-94,6
+100,7
@@
static inline memcached_return memcached_version_binary(memcached_st *ptr)
{
memcached_io_reset(&ptr->hosts[x]);
rc= MEMCACHED_SOME_ERRORS;
{
memcached_io_reset(&ptr->hosts[x]);
rc= MEMCACHED_SOME_ERRORS;
+ continue;
}
ptr->hosts[x].major_version= (uint8_t)strtol(buffer, &p, 10);
}
ptr->hosts[x].major_version= (uint8_t)strtol(buffer, &p, 10);