X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached.hh;h=42334e29353211516fbffea91cdee485c3e433ec;hb=dbd274af6fc88a8f7a0456eb419a753dd842c88f;hp=f7e349e7ee2fca05a4e28a8e8b5e78424f89610a;hpb=8fce86636639afaeac4ca0e869e8bcd833324a62;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached.hh b/libmemcached/memcached.hh index f7e349e7..42334e29 100644 --- a/libmemcached/memcached.hh +++ b/libmemcached/memcached.hh @@ -1,100 +1,230 @@ -#ifdef USE_PRAGMA_INTERFACE -#pragma interface /* gcc class implementation */ -#endif - -#include +#include "libmemcached/memcached.h" #include #include +#include + class Memcached { memcached_st memc; + memcached_result_st result; public: - Memcached() + Memcached() + : + memc(), + result() { memcached_create(&memc); } - Memcached(memcached_st *clone) + Memcached(memcached_st *clone) + : + memc(), + result() { memcached_clone(&memc, clone); } - char *get(char *key, size_t *value_length) + ~Memcached() + { + memcached_free(&memc); + } + + std::string fetch(const std::string& key, size_t *key_length, size_t *value_length) { uint32_t flags; memcached_return rc; - - return memcached_get(&memc, key, strlen(key), - value_length, &flags, &rc); + std::string ret_val; + + char *value= memcached_fetch(&memc, const_cast(key.c_str()), key_length, + value_length, &flags, &rc); + if (value) + { + ret_val.assign(value); + } + return ret_val; } - char *get_by_key(char *master_key, char *key, size_t *value_length) + std::string get(const std::string& key, size_t *value_length) { uint32_t flags; memcached_return rc; + std::string ret_val; + + char *value= memcached_get(&memc, key.c_str(), key.length(), + value_length, &flags, &rc); + if (value) + { + ret_val.assign(value); + } + return ret_val; + } - return memcached_get_by_key(&memc, master_key, strlen(master_key), key, strlen(key), - value_length, &flags, &rc); + std::string get_by_key(const std::string& master_key, + const std::string& key, + size_t *value_length) + { + uint32_t flags; + memcached_return rc; + std::string ret_val; + + char *value= memcached_get_by_key(&memc, master_key.c_str(), master_key.length(), + key.c_str(), key.length(), + value_length, &flags, &rc); + if (value) + { + ret_val.assign(value); + } + return ret_val; } - memcached_return mget(char **keys, size_t *key_length, unsigned int number_of_keys) + memcached_return mget(char **keys, size_t *key_length, + unsigned int number_of_keys) { return memcached_mget(&memc, keys, key_length, number_of_keys); } - memcached_return set(char *key, char *value, size_t value_length) + bool set(const std::string& key, const char *value, size_t value_length) { - return memcached_set(&memc, key, strlen(key), - value, value_length, - (time_t)0, (uint32_t)0); + memcached_return rc= memcached_set(&memc, key.c_str(), key.length(), + value, value_length, + time_t(0), uint32_t(0)); + return (rc == MEMCACHED_SUCCESS); } - memcached_return set_by_key(char *master_key, char *key, char *value, size_t value_length) + bool set_by_key(const std::string& master_key, + const std::string& key, + const char *value, size_t value_length) { - return memcached_set_by_key(&memc, master_key, strlen(master_key), - key, strlen(key), - value, value_length, - (time_t)0, - (uint32_t)0 ); + memcached_return rc= memcached_set_by_key(&memc, master_key.c_str(), + master_key.length(), + key.c_str(), key.length(), + value, value_length, + time_t(0), + uint32_t(0)); + return (rc == MEMCACHED_SUCCESS); } + bool increment(const std::string& key, unsigned int offset, uint64_t *value) + { + memcached_return rc= memcached_increment(&memc, key.c_str(), key.length(), + offset, value); + return (rc == MEMCACHED_SUCCESS); + } + + bool decrement(const char *key, unsigned int offset, uint64_t *value) + { + memcached_return rc= memcached_decrement(&memc, key, strlen(key), + offset, value); + return (rc == MEMCACHED_SUCCESS); + } - memcached_return add(char *key, char *value, size_t value_length) + + bool add(const char *key, const char *value, size_t value_length) { - return memcached_add(&memc, key, strlen(key), - value, value_length, - (time_t)0, (uint32_t)0); + memcached_return rc= memcached_add(&memc, key, strlen(key), value, value_length, 0, 0); + return (rc == MEMCACHED_SUCCESS); } - memcached_return replace(char *key, char *value, size_t value_length) + bool add_by_key(const char *master_key, const char *key, + const char *value, size_t value_length) { - return memcached_replace(&memc, key, strlen(key), - value, value_length, - (time_t)0, (uint32_t)0); + memcached_return rc= memcached_add_by_key(&memc, master_key, strlen(master_key), + key, strlen(key), + value, value_length, + 0, 0); + return (rc == MEMCACHED_SUCCESS); } - memcached_return prepend(char *key, char *value, size_t value_length) + bool replace(const char *key, const char *value, + size_t value_length) { - return memcached_prepend(&memc, key, strlen(key), - value, value_length, - (time_t)0, - (uint32_t)0); + memcached_return rc= memcached_replace(&memc, key, strlen(key), + value, value_length, + 0, 0); + return (rc == MEMCACHED_SUCCESS); } + bool replace_by_key(const char *master_key, const char *key, + const char *value, size_t value_length) + { + memcached_return rc= memcached_replace_by_key(&memc, master_key, strlen(master_key), + key, strlen(key), + value, value_length, 0, 0); + return (rc == MEMCACHED_SUCCESS); + } + + bool prepend(const char *key, const char *value, + size_t value_length) + { + memcached_return rc= memcached_prepend(&memc, key, strlen(key), + value, value_length, 0, 0); + return (rc == MEMCACHED_SUCCESS); + } + + bool prepend_by_key(const char *master_key, const char *key, + const char *value, size_t value_length) + { + memcached_return rc= memcached_prepend_by_key(&memc, master_key, strlen(master_key), + key, strlen(key), + value, value_length, + 0, + 0); + return (rc == MEMCACHED_SUCCESS); + } + + bool append(const char *key, const char *value, + size_t value_length) + { + memcached_return rc= memcached_append(&memc, key, strlen(key), + value, value_length, 0, 0); + return (rc == MEMCACHED_SUCCESS); + } + + bool append_by_key(const char *master_key, const char *key, + const char *value, size_t value_length) + { + memcached_return rc= memcached_append_by_key(&memc, + master_key, strlen(master_key), + key, strlen(key), + value, value_length, 0, 0); + return (rc == MEMCACHED_SUCCESS); + } + + bool cas(const char *key, const char *value, + size_t value_length, uint64_t cas_arg) + { + memcached_return rc= memcached_cas(&memc, key, strlen(key), + value, value_length, 0, 0, cas_arg); + return (rc == MEMCACHED_SUCCESS); + } + + bool cas_by_key(const char *master_key, const char *key, + const char *value, size_t value_length, + uint64_t cas_arg) + { + memcached_return rc= memcached_cas_by_key(&memc, + master_key, strlen(master_key), + key, strlen(key), + value, value_length, + 0, 0, cas_arg); + return (rc == MEMCACHED_SUCCESS); + } + + // using 'remove' vs. 'delete' since 'delete' is a keyword + bool remove(const std::string& key) + { + memcached_return rc= memcached_delete(&memc, key.c_str(), key.length(), 0); + return (rc == MEMCACHED_SUCCESS); + } - memcached_return append(char *key, char *value, size_t value_length) + bool delete_by_key(const char *master_key, const char *key) { - return memcached_append(&memc, key, strlen(key), - value, value_length, - (time_t)0, - (uint32_t)0); + memcached_return rc= memcached_delete_by_key(&memc, master_key, strlen(master_key), + key, strlen(key), 0); + return (rc == MEMCACHED_SUCCESS); } - ~Memcached() - { - memcached_free(&memc); - } };