X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fcommon.h;h=5dc77a08a8a8e9e05c9c9d55f588137fe259b8a9;hb=b10a03e4afb5514f1c86f5c75b9bfc7d46ce49b4;hp=90c8a140b7e3ef4b41013de55b30093261712ad2;hpb=933e5a561b10c1450563f1421b83d72396b805d2;p=awesomized%2Flibmemcached diff --git a/libmemcached/common.h b/libmemcached/common.h index 90c8a140..5dc77a08 100644 --- a/libmemcached/common.h +++ b/libmemcached/common.h @@ -22,11 +22,11 @@ #include #include -#if TIME_WITH_SYS_TIME +#ifdef TIME_WITH_SYS_TIME # include # include #else -# if HAVE_SYS_TIME_H +# ifdef HAVE_SYS_TIME_H # include # else # include @@ -39,7 +39,7 @@ #include "memcached_io.h" #include "memcached/protocol_binary.h" -#include +#include "libmemcached_config.h" #if !defined(__GNUC__) || (__GNUC__ == 2 && __GNUC_MINOR__ < 96) @@ -52,13 +52,6 @@ #define unlikely(x) if(__builtin_expect((x), 0)) #endif - -#ifdef HAVE_DTRACE -#define _DTRACE_VERSION 1 -#else -#undef _DTRACE_VERSION -#endif - #include "libmemcached_probes.h" #define MEMCACHED_BLOCK_SIZE 1024 @@ -82,14 +75,21 @@ typedef enum { /* 11 used for weighted ketama */ MEM_KETAMA_WEIGHTED= (1 << 11), MEM_BINARY_PROTOCOL= (1 << 12), + MEM_HASH_WITH_PREFIX_KEY= (1 << 13), + MEM_NOREPLY= (1 << 14), + MEM_USE_UDP= (1 << 15), + MEM_AUTO_EJECT_HOSTS= (1 << 16) } memcached_flags; /* Hashing algo */ void md5_signature(const unsigned char *key, unsigned int length, unsigned char *result); uint32_t hash_crc32(const char *data, size_t data_len); +#ifdef HAVE_HSIEH_HASH uint32_t hsieh_hash(const char *key, size_t key_length); +#endif uint32_t murmur_hash(const char *key, size_t key_length); +uint32_t jenkins_hash(const void *key, size_t length, uint32_t initval); memcached_return memcached_connect(memcached_server_st *ptr); memcached_return memcached_response(memcached_server_st *ptr, @@ -110,14 +110,38 @@ memcached_return value_fetch(memcached_server_st *ptr, memcached_result_st *result); void server_list_free(memcached_st *ptr, memcached_server_st *servers); -memcached_return memcachd_key_test(char **keys, size_t *key_length, - unsigned int number_of_keys); +memcached_return memcached_key_test(char **keys, size_t *key_length, + unsigned int number_of_keys); memcached_return run_distribution(memcached_st *ptr); uint32_t generate_hash(memcached_st *ptr, const char *key, size_t key_length); +memcached_return memcached_server_remove(memcached_server_st *st_ptr); +#ifndef HAVE_HTONLL extern uint64_t ntohll(uint64_t); extern uint64_t htonll(uint64_t); +#endif + +memcached_return memcached_purge(memcached_server_st *ptr); + +static inline memcached_return memcached_validate_key_length(size_t key_length, + bool binary) { + unlikely (key_length == 0) + return MEMCACHED_BAD_KEY_PROVIDED; + + if (binary) + { + unlikely (key_length > 0xffff) + return MEMCACHED_BAD_KEY_PROVIDED; + } + else + { + unlikely (key_length >= MEMCACHED_MAX_KEY) + return MEMCACHED_BAD_KEY_PROVIDED; + } + + return MEMCACHED_SUCCESS; +} #endif /* __COMMON_H__ */