X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached.h;h=9415f4321eb84d946cc27bc108a2122fde93e56e;hb=2c51ea585ccfbf3a14fed6d28f9115292ad0e6fc;hp=62d3b1dc58669dffe38a7603a90765f857408e2b;hpb=dac48f2dbe34915755f8f4f7f88419f47dc9e27f;p=m6w6%2Flibmemcached diff --git a/libmemcached/memcached.h b/libmemcached/memcached.h index 62d3b1dc..9415f432 100644 --- a/libmemcached/memcached.h +++ b/libmemcached/memcached.h @@ -10,19 +10,20 @@ * */ -#ifndef __MEMCACHED_H__ -#define __MEMCACHED_H__ +#ifndef __LIBMEMCACHED_MEMCACHED_H__ +#define __LIBMEMCACHED_MEMCACHED_H__ -#include #include +#include +#include +#include +#include + #if !defined(__cplusplus) # include #endif -#include -#include - #include #include #include @@ -52,55 +53,32 @@ #include #include -#ifdef __cplusplus -extern "C" { -#endif - -LIBMEMCACHED_API -void memcached_servers_reset(memcached_st *ptr); - -LIBMEMCACHED_API -memcached_st *memcached_create(memcached_st *ptr); - -LIBMEMCACHED_API -void memcached_free(memcached_st *ptr); - -LIBMEMCACHED_API -memcached_st *memcached_clone(memcached_st *clone, const memcached_st *ptr); - -LIBMEMCACHED_API -void *memcached_get_user_data(const memcached_st *ptr); - -LIBMEMCACHED_API -void *memcached_set_user_data(memcached_st *ptr, void *data); - - struct memcached_st { /** @note these are static and should not change without a call to behavior. */ struct { - bool is_purging:1; - bool is_processing_input:1; + bool is_purging MEMCACHED_BITFIELD; + bool is_processing_input MEMCACHED_BITFIELD; } state; struct { // Everything below here is pretty static. - bool auto_eject_hosts:1; - bool binary_protocol:1; - bool buffer_requests:1; - bool cork:1; - bool hash_with_prefix_key:1; - bool ketama_weighted:1; - bool no_block:1; - bool no_reply:1; - bool randomize_replica_read:1; - bool reuse_memory:1; - bool support_cas:1; - bool tcp_nodelay:1; - bool use_cache_lookups:1; - bool use_sort_hosts:1; - bool use_udp:1; - bool verify_key:1; + bool auto_eject_hosts MEMCACHED_BITFIELD; + bool binary_protocol MEMCACHED_BITFIELD; + bool buffer_requests MEMCACHED_BITFIELD; + bool cork MEMCACHED_BITFIELD; + bool hash_with_prefix_key MEMCACHED_BITFIELD; + bool ketama_weighted MEMCACHED_BITFIELD; + bool no_block MEMCACHED_BITFIELD; + bool no_reply MEMCACHED_BITFIELD; + bool randomize_replica_read MEMCACHED_BITFIELD; + bool reuse_memory MEMCACHED_BITFIELD; + bool support_cas MEMCACHED_BITFIELD; + bool tcp_nodelay MEMCACHED_BITFIELD; + bool use_cache_lookups MEMCACHED_BITFIELD; + bool use_sort_hosts MEMCACHED_BITFIELD; + bool use_udp MEMCACHED_BITFIELD; + bool verify_key MEMCACHED_BITFIELD; } flags; memcached_server_distribution_t distribution; hashkit_st hashkit; @@ -144,106 +122,37 @@ struct memcached_st { memcached_callback_st *callbacks; char prefix_key[MEMCACHED_PREFIX_KEY_MAX_SIZE]; struct { - bool is_allocated:1; + bool is_allocated MEMCACHED_BITFIELD; } options; +}; + #ifdef __cplusplus - memcached_st() : - state(), - flags(), - distribution(), - hashkit(), - continuum_points_counter(), - number_of_hosts(), - servers(), - last_disconnected_server(), - snd_timeout(), - rcv_timeout(), - server_failure_limit(), - io_msg_watermark(), - io_bytes_watermark(), - io_key_prefetch(), - cached_errno(), - poll_timeout(), - connect_timeout(), - retry_timeout(), - continuum_count(), - send_size(), - recv_size(), - user_data(), - next_distribution_rebuild(), - prefix_key_length(), - number_of_replicas(), - distribution_hashkit(), - result(), - continuum(), - allocators(), - on_clone(), - on_cleanup(), - get_key_failure(), - delete_trigger(), - callbacks(), - prefix_key(), - options() - { - memcached_create(this); - } +extern "C" { +#endif - ~memcached_st() - { - memcached_free(this); - } +LIBMEMCACHED_API +void memcached_servers_reset(memcached_st *ptr); - memcached_st(const memcached_st& source) : - state(), - flags(), - distribution(), - hashkit(), - continuum_points_counter(), - number_of_hosts(), - servers(), - last_disconnected_server(), - snd_timeout(), - rcv_timeout(), - server_failure_limit(), - io_msg_watermark(), - io_bytes_watermark(), - io_key_prefetch(), - cached_errno(), - poll_timeout(), - connect_timeout(), - retry_timeout(), - continuum_count(), - send_size(), - recv_size(), - user_data(), - next_distribution_rebuild(), - prefix_key_length(), - number_of_replicas(), - distribution_hashkit(), - result(), - continuum(), - allocators(), - on_clone(), - on_cleanup(), - get_key_failure(), - delete_trigger(), - callbacks(), - prefix_key(), - options() - { - memcached_clone(this, &source); - } +LIBMEMCACHED_API +memcached_st *memcached_create(memcached_st *ptr); - memcached_st& operator=(const memcached_st& source) - { - memcached_clone(this, &source); +LIBMEMCACHED_API +void memcached_free(memcached_st *ptr); - return *this; - } +LIBMEMCACHED_API +memcached_st *memcached_clone(memcached_st *clone, const memcached_st *ptr); +LIBMEMCACHED_API +void *memcached_get_user_data(const memcached_st *ptr); + +LIBMEMCACHED_API +void *memcached_set_user_data(memcached_st *ptr, void *data); + +#ifdef __cplusplus +} // extern "C" #endif -}; + // Local Only Inline static inline memcached_server_st *memcached_server_instance_fetch(memcached_st *ptr, uint32_t server_key) @@ -251,10 +160,34 @@ static inline memcached_server_st *memcached_server_instance_fetch(memcached_st return &ptr->servers[server_key]; } - #ifdef __cplusplus -} // extern "C" +class Memcached : private memcached_st { +public: + + Memcached() + { + memcached_create(this); + } + + ~Memcached() + { + memcached_free(this); + } + + Memcached(const Memcached& source) + { + memcached_clone(this, &source); + } + + Memcached& operator=(const Memcached& source) + { + memcached_free(this); + memcached_clone(this, &source); + + return *this; + } +}; #endif +#endif /* __LIBMEMCACHED_MEMCACHED_H__ */ -#endif /* __MEMCACHED_H__ */