X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fresult.cc;h=6fa507b28e60bf541105cee7ec34c82c7040e3aa;hb=59acef2d2b59a3f1a55337a933b97d901d46133a;hp=f9d55a9412c1087d6ca0a0e0a2407b301aa8bf92;hpb=a6c3e3a3d04f379b1480c8c88a8eae17e54b1449;p=awesomized%2Flibmemcached diff --git a/libmemcached/result.cc b/libmemcached/result.cc index f9d55a94..6fa507b2 100644 --- a/libmemcached/result.cc +++ b/libmemcached/result.cc @@ -2,7 +2,7 @@ * * Libmemcached library * - * Copyright (C) 2011 Data Differential, http://datadifferential.com/ + * Copyright (C) 2011-2013 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 @@ -45,20 +45,22 @@ #include static inline void _result_init(memcached_result_st *self, - memcached_st *memc) + Memcached *memc) { self->item_flags= 0; self->item_expiration= 0; self->key_length= 0; self->item_cas= 0; self->root= memc; + self->numeric_value= UINT64_MAX; + self->count= 0; self->item_key[0]= 0; } -memcached_result_st *memcached_result_create(const memcached_st *memc, +memcached_result_st *memcached_result_create(const memcached_st *shell, memcached_result_st *ptr) { - WATCHPOINT_ASSERT(memc); + const Memcached* memc= memcached2Memcached(shell); /* Saving malloc calls :) */ if (ptr) @@ -67,10 +69,12 @@ memcached_result_st *memcached_result_create(const memcached_st *memc, } else { - ptr= static_cast(libmemcached_malloc(memc, sizeof(memcached_result_st))); + ptr= libmemcached_xmalloc(memc, memcached_result_st); - if (ptr == NULL) + if (not ptr) + { return NULL; + } ptr->options.is_allocated= true; } @@ -94,14 +98,18 @@ void memcached_result_reset(memcached_result_st *ptr) ptr->item_flags= 0; ptr->item_cas= 0; ptr->item_expiration= 0; + ptr->numeric_value= UINT64_MAX; } void memcached_result_free(memcached_result_st *ptr) { - if (not ptr) + if (ptr == NULL) + { return; + } memcached_string_free(&ptr->value); + ptr->numeric_value= UINT64_MAX; if (memcached_is_allocated(ptr)) { @@ -110,10 +118,16 @@ void memcached_result_free(memcached_result_st *ptr) } else { + ptr->count= 0; ptr->options.is_initialized= false; } } +void memcached_result_reset_value(memcached_result_st *ptr) +{ + memcached_string_reset(&ptr->value); +} + memcached_return_t memcached_result_set_value(memcached_result_st *ptr, const char *value, size_t length) @@ -148,6 +162,12 @@ size_t memcached_result_length(const memcached_result_st *self) return memcached_string_length(sptr); } +char *memcached_result_take_value(memcached_result_st *self) +{ + memcached_string_st *sptr= &self->value; + return memcached_string_take_value(sptr); +} + uint32_t memcached_result_flags(const memcached_result_st *self) { return self->item_flags;