X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fserver.h;h=d1a1cdacad5211549da66e835ae23b39819728cf;hb=118defb3246857a80d36ee1a8ee8b2b789fb6f09;hp=1b99ecbb66cc94422453895a2af2d30717763e52;hpb=e42302e08fa4d04cb21eaf7493f5f92b11169c03;p=awesomized%2Flibmemcached diff --git a/libmemcached/server.h b/libmemcached/server.h index 1b99ecbb..d1a1cdac 100644 --- a/libmemcached/server.h +++ b/libmemcached/server.h @@ -19,6 +19,7 @@ extern "C" { struct memcached_server_st { struct { bool is_allocated:1; + bool is_initialized:1; bool sockaddr_inited:1; } options; uint32_t number_of_hosts; @@ -29,6 +30,9 @@ struct memcached_server_st { uint32_t io_bytes_sent; /* # bytes sent since last read */ uint32_t server_failure_counter; uint32_t weight; + struct { // Place any "state" sort variables in here. + bool is_corked; + } state; uint8_t major_version; uint8_t micro_version; uint8_t minor_version; @@ -40,7 +44,7 @@ struct memcached_server_st { size_t write_buffer_offset; struct addrinfo *address_info; time_t next_retry; - memcached_st *root; + const memcached_st *root; uint64_t limit_maxbytes; char read_buffer[MEMCACHED_MAX_BUFFER]; char write_buffer[MEMCACHED_MAX_BUFFER]; @@ -89,11 +93,9 @@ void memcached_server_error_reset(memcached_server_st *ptr); /* These should not currently be used by end users */ /* TODO: Is the above comment valid? If so, how can we unit test these if they * aren't exported. If not, we should remove the comment */ -LIBMEMCACHED_LOCAL -memcached_server_st *memcached_server_create(memcached_st *memc, memcached_server_st *ptr); LIBMEMCACHED_LOCAL -memcached_server_st *memcached_server_create_with(memcached_st *memc, +memcached_server_st *memcached_server_create_with(const memcached_st *memc, memcached_server_st *host, const char *hostname, in_port_t port, @@ -104,8 +106,8 @@ LIBMEMCACHED_API void memcached_server_free(memcached_server_st *ptr); LIBMEMCACHED_LOCAL -memcached_server_st *memcached_server_clone(memcached_server_st *clone, - memcached_server_st *ptr); +memcached_server_st *memcached_server_clone(memcached_server_st *destination, + const memcached_server_st *source); LIBMEMCACHED_API memcached_return_t memcached_server_remove(memcached_server_st *st_ptr); @@ -113,6 +115,55 @@ memcached_return_t memcached_server_remove(memcached_server_st *st_ptr); LIBMEMCACHED_API memcached_server_st *memcached_server_get_last_disconnect(memcached_st *ptr); + +LIBMEMCACHED_API +memcached_return_t memcached_server_add_udp(memcached_st *ptr, + const char *hostname, + in_port_t port); +LIBMEMCACHED_API +memcached_return_t memcached_server_add_unix_socket(memcached_st *ptr, + const char *filename); +LIBMEMCACHED_API +memcached_return_t memcached_server_add(memcached_st *ptr, + const char *hostname, in_port_t port); + +LIBMEMCACHED_API +memcached_return_t memcached_server_add_udp_with_weight(memcached_st *ptr, + const char *hostname, + in_port_t port, + uint32_t weight); +LIBMEMCACHED_API +memcached_return_t memcached_server_add_unix_socket_with_weight(memcached_st *ptr, + const char *filename, + uint32_t weight); +LIBMEMCACHED_API +memcached_return_t memcached_server_add_with_weight(memcached_st *ptr, const char *hostname, + in_port_t port, + uint32_t weight); +/* Server List Public functions */ + +LIBMEMCACHED_API +void memcached_server_list_free(memcached_server_st *ptr); + + +LIBMEMCACHED_API +memcached_return_t memcached_server_push(memcached_st *ptr, memcached_server_st *list); + +LIBMEMCACHED_API +memcached_server_st *memcached_server_list_append(memcached_server_st *ptr, + const char *hostname, + in_port_t port, + memcached_return_t *error); +LIBMEMCACHED_API +memcached_server_st *memcached_server_list_append_with_weight(memcached_server_st *ptr, + const char *hostname, + in_port_t port, + uint32_t weight, + memcached_return_t *error); +LIBMEMCACHED_API +unsigned int memcached_server_list_count(memcached_server_st *ptr); + + #ifdef __cplusplus } #endif