X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fio.cc;h=c6d647be64cdaf73efcbd21d319ea79a7f88e4a7;hb=bd53173d0a23c8c2a0dac68056cbd2cc52d5a6ef;hp=d7268940543cedeb0e7d8bc84145b442cfdcde74;hpb=969fea8e7bed82c109685ec3976cf7b0ec514ae9;p=m6w6%2Flibmemcached diff --git a/libmemcached/io.cc b/libmemcached/io.cc index d7268940..c6d647be 100644 --- a/libmemcached/io.cc +++ b/libmemcached/io.cc @@ -306,7 +306,6 @@ static ssize_t io_flush(memcached_server_write_instance_st ptr, return -1; } } - ssize_t sent_length; size_t return_length; char *local_write_ptr= ptr->write_buffer; size_t write_length= ptr->write_buffer_offset; @@ -340,10 +339,10 @@ static ssize_t io_flush(memcached_server_write_instance_st ptr, { WATCHPOINT_ASSERT(ptr->fd != INVALID_SOCKET); WATCHPOINT_ASSERT(write_length > 0); - sent_length= 0; if (ptr->type == MEMCACHED_CONNECTION_UDP) increment_udp_message_id(ptr); + ssize_t sent_length= 0; WATCHPOINT_ASSERT(ptr->fd != INVALID_SOCKET); if (with_flush) { @@ -408,7 +407,7 @@ static ssize_t io_flush(memcached_server_write_instance_st ptr, } if (ptr->type == MEMCACHED_CONNECTION_UDP and - (size_t)sent_length != write_length) + size_t(sent_length) != write_length) { memcached_quit_server(ptr, true); *error= memcached_set_error(*ptr, MEMCACHED_WRITE_FAILURE, MEMCACHED_AT); @@ -611,13 +610,10 @@ memcached_return_t memcached_io_slurp(memcached_server_write_instance_st ptr) static ssize_t _io_write(memcached_server_write_instance_st ptr, const void *buffer, size_t length, bool with_flush) { - size_t original_length; - const char* buffer_ptr; - WATCHPOINT_ASSERT(ptr->fd != INVALID_SOCKET); - original_length= length; - buffer_ptr= static_cast(buffer); + size_t original_length= length; + const char *buffer_ptr= static_cast(buffer); while (length) {