X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fstorage.cc;h=cd29670df1183750e66358668dad3e223125a823;hb=535cb0763dff986a148356bf58dd91f15ad8ed39;hp=97470048e5d081e78b71e355d5343188d2db2080;hpb=b5495838fb245aa1068a1198ed549b98a9c3e666;p=awesomized%2Flibmemcached diff --git a/libmemcached/storage.cc b/libmemcached/storage.cc index 97470048..cd29670d 100644 --- a/libmemcached/storage.cc +++ b/libmemcached/storage.cc @@ -139,7 +139,7 @@ static inline uint8_t get_com_code(const memcached_storage_action_t verb, const } static memcached_return_t memcached_send_binary(memcached_st *ptr, - memcached_server_write_instance_st server, + org::libmemcached::Instance* server, uint32_t server_key, const char *key, const size_t key_length, @@ -217,7 +217,7 @@ static memcached_return_t memcached_send_binary(memcached_st *ptr, server_key= 0; } - memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, server_key); + org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, server_key); if (memcached_vdo(instance, vector, 5, false) != MEMCACHED_SUCCESS) { @@ -245,7 +245,7 @@ static memcached_return_t memcached_send_binary(memcached_st *ptr, } static memcached_return_t memcached_send_ascii(memcached_st *ptr, - memcached_server_write_instance_st instance, + org::libmemcached::Instance* instance, const char *key, const size_t key_length, const char *value, @@ -299,10 +299,10 @@ static memcached_return_t memcached_send_ascii(memcached_st *ptr, { storage_op_string(verb), strlen(storage_op_string(verb))}, { memcached_array_string(ptr->_namespace), memcached_array_size(ptr->_namespace) }, { key, key_length }, - { flags_buffer, flags_buffer_length }, - { expiration_buffer, expiration_buffer_length }, - { value_buffer, value_buffer_length }, - { cas_buffer, cas_buffer_length }, + { flags_buffer, size_t(flags_buffer_length) }, + { expiration_buffer, size_t(expiration_buffer_length) }, + { value_buffer, size_t(value_buffer_length) }, + { cas_buffer, size_t(cas_buffer_length) }, { " noreply", reply ? 0 : memcached_literal_param_size(" noreply") }, { memcached_literal_param("\r\n") }, { value, value_length }, @@ -371,7 +371,7 @@ static inline memcached_return_t memcached_send(memcached_st *ptr, } uint32_t server_key= memcached_generate_hash_with_redistribution(ptr, group_key, group_key_length); - memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, server_key); + org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, server_key); WATCHPOINT_SET(instance->io_wait_count.read= 0); WATCHPOINT_SET(instance->io_wait_count.write= 0);