/* vim:expandtab:shiftwidth=2:tabstop=2:smarttab: * * Libmemcached library * * Copyright (C) 2011 Data Differential, http://datadifferential.com/ * Copyright (C) 2006-2009 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. * */ /* memcached_result_st are used to internally represent the return values from memcached. We use a structure so that long term as identifiers are added to memcached we will be able to absorb new attributes without having to addjust the entire API. */ #include static inline void _result_init(memcached_result_st *self, memcached_st *memc) { self->item_flags= 0; self->item_expiration= 0; self->key_length= 0; self->item_cas= 0; self->root= memc; self->count= 0; self->item_key[0]= 0; } memcached_result_st *memcached_result_create(const memcached_st *memc, memcached_result_st *ptr) { WATCHPOINT_ASSERT(memc); /* Saving malloc calls :) */ if (ptr) { ptr->options.is_allocated= false; } else { ptr= static_cast(libmemcached_malloc(memc, sizeof(memcached_result_st))); if (not ptr) { return NULL; } ptr->options.is_allocated= true; } ptr->options.is_initialized= true; _result_init(ptr, (memcached_st *)memc); WATCHPOINT_SET(ptr->value.options.is_initialized= false); memcached_string_create((memcached_st*)memc, &ptr->value, 0); WATCHPOINT_ASSERT_INITIALIZED(&ptr->value); WATCHPOINT_ASSERT(ptr->value.string == NULL); return ptr; } void memcached_result_reset(memcached_result_st *ptr) { ptr->key_length= 0; memcached_string_reset(&ptr->value); ptr->item_flags= 0; ptr->item_cas= 0; ptr->item_expiration= 0; } void memcached_result_free(memcached_result_st *ptr) { if (not ptr) return; memcached_string_free(&ptr->value); if (memcached_is_allocated(ptr)) { WATCHPOINT_ASSERT(ptr->root); // Without a root, that means that result was not properly initialized. libmemcached_free(ptr->root, ptr); } else { ptr->count= 0; ptr->options.is_initialized= false; } } memcached_return_t memcached_result_set_value(memcached_result_st *ptr, const char *value, size_t length) { if (memcached_failed(memcached_string_append(&ptr->value, value, length))) { return memcached_set_errno(*ptr->root, errno, MEMCACHED_AT); } return MEMCACHED_SUCCESS; } const char *memcached_result_key_value(const memcached_result_st *self) { return self->key_length ? self->item_key : NULL; } size_t memcached_result_key_length(const memcached_result_st *self) { return self->key_length; } const char *memcached_result_value(const memcached_result_st *self) { const memcached_string_st *sptr= &self->value; return memcached_string_value(sptr); } size_t memcached_result_length(const memcached_result_st *self) { const memcached_string_st *sptr= &self->value; return memcached_string_length(sptr); } uint32_t memcached_result_flags(const memcached_result_st *self) { return self->item_flags; } uint64_t memcached_result_cas(const memcached_result_st *self) { return self->item_cas; } void memcached_result_set_flags(memcached_result_st *self, uint32_t flags) { self->item_flags= flags; } void memcached_result_set_expiration(memcached_result_st *self, time_t expiration) { self->item_expiration= expiration; }