X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached_behavior.c;h=ef4907dd24e02502cd96b69b534421cf3c2e7729;hb=a9b22f8a1c9f98eef8becdbef11d8e20d43dd23c;hp=6b36626e9e07d00a2fa06b7d2525e75bfb3e20ad;hpb=933e5a561b10c1450563f1421b83d72396b805d2;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached_behavior.c b/libmemcached/memcached_behavior.c index 6b36626e..ef4907dd 100644 --- a/libmemcached/memcached_behavior.c +++ b/libmemcached/memcached_behavior.c @@ -9,7 +9,7 @@ We quit all connections so we can reset the sockets. */ -void set_behavior_flag(memcached_st *ptr, memcached_flags temp_flag, uint64_t data) +static void set_behavior_flag(memcached_st *ptr, memcached_flags temp_flag, uint64_t data) { if (data) ptr->flags|= temp_flag; @@ -23,6 +23,15 @@ memcached_return memcached_behavior_set(memcached_st *ptr, { switch (flag) { + case MEMCACHED_BEHAVIOR_SND_TIMEOUT: + ptr->snd_timeout= (int32_t)data; + break; + case MEMCACHED_BEHAVIOR_RCV_TIMEOUT: + ptr->rcv_timeout= (int32_t)data; + break; + case MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT: + ptr->server_failure_limit= (uint32_t)data; + break; case MEMCACHED_BEHAVIOR_BINARY_PROTOCOL: set_behavior_flag(ptr, MEM_BINARY_PROTOCOL, data); break; @@ -153,21 +162,27 @@ uint64_t memcached_behavior_get(memcached_st *ptr, return ptr->hash; case MEMCACHED_BEHAVIOR_KETAMA_HASH: return ptr->hash_continuum; + case MEMCACHED_BEHAVIOR_SERVER_FAILURE_LIMIT: + return ptr->server_failure_limit; case MEMCACHED_BEHAVIOR_SORT_HOSTS: temp_flag= MEM_USE_SORT_HOSTS; break; case MEMCACHED_BEHAVIOR_POLL_TIMEOUT: { - return (unsigned long long)ptr->poll_timeout; + return (uint64_t)ptr->poll_timeout; } case MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT: { - return (unsigned long long)ptr->connect_timeout; + return (uint64_t)ptr->connect_timeout; } case MEMCACHED_BEHAVIOR_RETRY_TIMEOUT: { - return (unsigned long long)ptr->retry_timeout; + return (uint64_t)ptr->retry_timeout; } + case MEMCACHED_BEHAVIOR_SND_TIMEOUT: + return (uint64_t)ptr->snd_timeout; + case MEMCACHED_BEHAVIOR_RCV_TIMEOUT: + return (uint64_t)ptr->rcv_timeout; case MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE: { int sock_size;