X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=src%2Flibmemcached%2Fverbosity.cc;h=575a2aeec0d269b83a2eed1b9e359a4227cadf58;hb=cf49439d85021e56d5e326e0312e16e8736bf685;hp=43d7374428fcfec0ad450ccf5398ee9ded24dab7;hpb=5e760300d15ef4c5b7eed3fb9f37920ebca2f6ec;p=awesomized%2Flibmemcached diff --git a/src/libmemcached/verbosity.cc b/src/libmemcached/verbosity.cc index 43d73744..575a2aee 100644 --- a/src/libmemcached/verbosity.cc +++ b/src/libmemcached/verbosity.cc @@ -1,69 +1,43 @@ -/* vim:expandtab:shiftwidth=2:tabstop=2:smarttab: - * - * Libmemcached library - * - * Copyright (C) 2011 Data Differential, http://datadifferential.com/ - * Copyright (C) 2010 Brian Aker All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions are - * met: - * - * * Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - * * Redistributions in binary form must reproduce the above - * copyright notice, this list of conditions and the following disclaimer - * in the documentation and/or other materials provided with the - * distribution. - * - * * The names of its contributors may not be used to endorse or - * promote products derived from this software without specific prior - * written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT - * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR - * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT - * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT - * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE - * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - * - */ - -#include - -struct context_st -{ +/* + +--------------------------------------------------------------------+ + | libmemcached - C/C++ Client Library for memcached | + +--------------------------------------------------------------------+ + | Redistribution and use in source and binary forms, with or without | + | modification, are permitted under the terms of the BSD license. | + | You should have received a copy of the license in a bundled file | + | named LICENSE; in case you did not receive a copy you can review | + | the terms online at: https://opensource.org/licenses/BSD-3-Clause | + +--------------------------------------------------------------------+ + | Copyright (c) 2006-2014 Brian Aker https://datadifferential.com/ | + | Copyright (c) 2020 Michael Wallner | + +--------------------------------------------------------------------+ +*/ + +#include "libmemcached/common.h" + +struct context_st { size_t length; const char *buffer; }; -static memcached_return_t _set_verbosity(const Memcached *, - const memcached_instance_st * server, - void *context) -{ - libmemcached_io_vector_st *vector= (libmemcached_io_vector_st *)context; +static memcached_return_t _set_verbosity(const Memcached *, const memcached_instance_st *server, + void *context) { + libmemcached_io_vector_st *vector = (libmemcached_io_vector_st *) context; Memcached local_memc; - Memcached *memc_ptr= memcached_create(&local_memc); + Memcached *memc_ptr = memcached_create(&local_memc); - memcached_return_t rc= memcached_server_add(memc_ptr, memcached_server_name(server), memcached_server_port(server)); + memcached_return_t rc = + memcached_server_add(memc_ptr, memcached_server_name(server), memcached_server_port(server)); - if (rc == MEMCACHED_SUCCESS) - { - memcached_instance_st* instance= memcached_instance_fetch(memc_ptr, 0); + if (rc == MEMCACHED_SUCCESS) { + memcached_instance_st *instance = memcached_instance_fetch(memc_ptr, 0); - rc= memcached_vdo(instance, vector, 2, true); + rc = memcached_vdo(instance, vector, 2, true); - if (rc == MEMCACHED_SUCCESS) - { + if (rc == MEMCACHED_SUCCESS) { char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE]; - rc= memcached_response(instance, buffer, sizeof(buffer), NULL); + rc = memcached_response(instance, buffer, sizeof(buffer), NULL); } } @@ -72,12 +46,10 @@ static memcached_return_t _set_verbosity(const Memcached *, return rc; } -memcached_return_t memcached_verbosity(memcached_st *shell, uint32_t verbosity) -{ - Memcached* ptr= memcached2Memcached(shell); +memcached_return_t memcached_verbosity(memcached_st *shell, uint32_t verbosity) { + Memcached *ptr = memcached2Memcached(shell); memcached_return_t rc; - if (memcached_failed(rc= initialize_query(ptr, false))) - { + if (memcached_failed(rc = initialize_query(ptr, false))) { return rc; } @@ -85,20 +57,18 @@ memcached_return_t memcached_verbosity(memcached_st *shell, uint32_t verbosity) char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE]; - int send_length= snprintf(buffer, sizeof(buffer), "verbosity %u\r\n", verbosity); - if (send_length >= MEMCACHED_DEFAULT_COMMAND_SIZE or send_length < 0) - { - return memcached_set_error(*ptr, MEMCACHED_MEMORY_ALLOCATION_FAILURE, MEMCACHED_AT, + int send_length = snprintf(buffer, sizeof(buffer), "verbosity %u\r\n", verbosity); + if (send_length >= MEMCACHED_DEFAULT_COMMAND_SIZE or send_length < 0) { + return memcached_set_error(*ptr, MEMCACHED_MEMORY_ALLOCATION_FAILURE, MEMCACHED_AT, memcached_literal_param("snprintf(MEMCACHED_DEFAULT_COMMAND_SIZE)")); } - libmemcached_io_vector_st vector[]= - { - { NULL, 0 }, - { buffer, size_t(send_length) }, + libmemcached_io_vector_st vector[] = { + {NULL, 0}, + {buffer, size_t(send_length)}, }; - callbacks[0]= _set_verbosity; + callbacks[0] = _set_verbosity; return memcached_server_cursor(ptr, callbacks, vector, 1); }