X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fcommon.h;h=a3e4ea90310b73ae02808babd0142d6886949912;hb=81204a653b40f87ae9f43fd8ee12cc8177021f3a;hp=b8deac8e558474a621624b33307cfba1f0472334;hpb=a6c3e3a3d04f379b1480c8c88a8eae17e54b1449;p=awesomized%2Flibmemcached diff --git a/libmemcached/common.h b/libmemcached/common.h index b8deac8e..a3e4ea90 100644 --- a/libmemcached/common.h +++ b/libmemcached/common.h @@ -49,64 +49,101 @@ #include #include #include -#include +#include +#include +#include #else #include #include #include #include +#include +#include #endif -#include #include -#include #include #include -#include +#ifdef HAVE_STRINGS_H +#include +#endif + +#include #include #include +#include +#include + +#ifdef HAVE_POLL_H +#include +#else +#include "poll/poll.h" +#endif + #ifdef __cplusplus extern "C" { #endif -typedef struct memcached_server_st * memcached_server_write_instance_st; - typedef memcached_return_t (*memcached_server_execute_fn)(memcached_st *ptr, memcached_server_write_instance_st server, void *context); -LIBMEMCACHED_LOCAL -memcached_server_write_instance_st memcached_server_instance_fetch(memcached_st *ptr, uint32_t server_key); - -LIBMEMCACHED_LOCAL -memcached_return_t memcached_server_execute(memcached_st *ptr, - memcached_server_execute_fn callback, - void *context); #ifdef __cplusplus } // extern "C" #endif +#ifdef __cplusplus +org::libmemcached::Instance* memcached_instance_fetch(memcached_st *ptr, uint32_t server_key); +#endif + +memcached_return_t memcached_server_execute(memcached_st *ptr, + memcached_server_execute_fn callback, + void *context); /* These are private not to be installed headers */ #include #include #include -#include +#ifdef __cplusplus +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#endif #include #include #include -#include #include #include +#ifdef __cplusplus #include -#include +#endif +#include +#include -/* string value */ -struct memcached_continuum_item_st -{ - uint32_t index; - uint32_t value; -}; +#ifdef __cplusplus +#include +#include +#include +#include +#include +#include +#include +#endif + +#include #if !defined(__GNUC__) || (__GNUC__ == 2 && __GNUC_MINOR__ < 96) @@ -128,55 +165,21 @@ struct memcached_continuum_item_st extern "C" { #endif -LIBMEMCACHED_LOCAL -memcached_return_t memcached_connect(memcached_server_write_instance_st ptr); - -LIBMEMCACHED_LOCAL memcached_return_t run_distribution(memcached_st *ptr); -#define memcached_server_response_increment(A) (A)->cursor_active++ -#define memcached_server_response_decrement(A) (A)->cursor_active-- -#define memcached_server_response_reset(A) (A)->cursor_active=0 - -LIBMEMCACHED_LOCAL -void set_last_disconnected_host(memcached_server_write_instance_st ptr); - -LIBMEMCACHED_LOCAL -memcached_return_t memcached_key_test(const char * const *keys, - const size_t *key_length, - size_t number_of_keys); - -LIBMEMCACHED_LOCAL -memcached_return_t memcached_purge(memcached_server_write_instance_st ptr); - -LIBMEMCACHED_LOCAL -memcached_server_st *memcached_server_create_with(const memcached_st *memc, - memcached_server_write_instance_st host, - const char *hostname, - in_port_t port, - uint32_t weight, - memcached_connection_t type); - - -static inline memcached_return_t 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; -} +#define memcached_server_response_increment(A) (A)->cursor_active_++ +#define memcached_server_response_decrement(A) (A)->cursor_active_-- +#define memcached_server_response_reset(A) (A)->cursor_active_=0 + +#define memcached_instance_response_increment(A) (A)->cursor_active_++ +#define memcached_instance_response_decrement(A) (A)->cursor_active_-- +#define memcached_instance_response_reset(A) (A)->cursor_active_=0 #ifdef __cplusplus } #endif + +#ifdef __cplusplus +bool memcached_purge(org::libmemcached::Instance*); +org::libmemcached::Instance* memcached_instance_by_position(const memcached_st *ptr, uint32_t server_key); +#endif