2 * Copyright (C) 2006-2009 Brian Aker
5 * Use and distribution licensed under the BSD license. See
6 * the COPYING file in the parent directory for full text.
13 Common include file for libmemached
16 #ifndef __LIBMEMCACHED_COMMON_H__
17 #define __LIBMEMCACHED_COMMON_H__
26 #include <sys/types.h>
27 #include <sys/socket.h>
28 #include <netinet/in.h>
29 #include <arpa/inet.h>
36 #include <netinet/tcp.h>
37 #ifdef TIME_WITH_SYS_TIME
38 # include <sys/time.h>
41 # ifdef HAVE_SYS_TIME_H
42 # include <sys/time.h>
48 /* Define this here, which will turn on the visibilty controls while we're
49 * building libmemcached.
51 #define BUILDING_LIBMEMCACHED 1
54 #include "libmemcached/memcached.h"
55 #include "libmemcached/watchpoint.h"
57 typedef struct memcached_server_st
* memcached_server_write_instance_st
;
59 typedef memcached_return_t (*memcached_server_execute_fn
)(memcached_st
*ptr
, memcached_server_write_instance_st server
, void *context
);
62 memcached_server_write_instance_st
memcached_server_instance_fetch(memcached_st
*ptr
, uint32_t server_key
);
65 memcached_return_t
memcached_server_execute(memcached_st
*ptr
,
66 memcached_server_execute_fn callback
,
70 /* These are private not to be installed headers */
71 #include "libmemcached/io.h"
72 #include "libmemcached/do.h"
73 #include "libmemcached/internal.h"
74 #include "libmemcached/libmemcached_probes.h"
75 #include "libmemcached/memcached/protocol_binary.h"
76 #include "libmemcached/byteorder.h"
77 #include "libmemcached/response.h"
80 struct memcached_continuum_item_st
86 /* Yum, Fortran.... can you make the reference? */
91 } memcached_ternary_t
;
94 #if !defined(__GNUC__) || (__GNUC__ == 2 && __GNUC_MINOR__ < 96)
96 #define likely(x) if((x))
97 #define unlikely(x) if((x))
101 #define likely(x) if(__builtin_expect((x) != 0, 1))
102 #define unlikely(x) if(__builtin_expect((x) != 0, 0))
105 #define MEMCACHED_BLOCK_SIZE 1024
106 #define MEMCACHED_DEFAULT_COMMAND_SIZE 350
107 #define SMALL_STRING_LEN 1024
108 #define HUGE_STRING_LEN 8196
115 memcached_return_t
memcached_connect(memcached_server_write_instance_st ptr
);
118 memcached_return_t
run_distribution(memcached_st
*ptr
);
120 #define memcached_server_response_increment(A) (A)->cursor_active++
121 #define memcached_server_response_decrement(A) (A)->cursor_active--
122 #define memcached_server_response_reset(A) (A)->cursor_active=0
125 #define memcached_is_allocated(__object) ((__object)->options.is_allocated)
126 #define memcached_is_initialized(__object) ((__object)->options.is_initialized)
127 #define memcached_is_purging(__object) ((__object)->state.is_purging)
128 #define memcached_is_processing_input(__object) ((__object)->state.is_processing_input)
129 #define memcached_set_purging(__object, __value) ((__object)->state.is_purging= (__value))
130 #define memcached_set_processing_input(__object, __value) ((__object)->state.is_processing_input= (__value))
131 #define memcached_set_initialized(__object, __value) ((__object)->options.is_initialized(= (__value))
132 #define memcached_set_allocated(__object, __value) ((__object)->options.is_allocated(= (__value))
135 void set_last_disconnected_host(memcached_server_write_instance_st ptr
);
138 memcached_return_t
memcached_key_test(const char * const *keys
,
139 const size_t *key_length
,
140 size_t number_of_keys
);
143 memcached_return_t
memcached_purge(memcached_server_write_instance_st ptr
);
146 memcached_server_st
*memcached_server_create_with(const memcached_st
*memc
,
147 memcached_server_write_instance_st host
,
148 const char *hostname
,
151 memcached_connection_t type
);
154 static inline memcached_return_t
memcached_validate_key_length(size_t key_length
, bool binary
)
156 unlikely (key_length
== 0)
157 return MEMCACHED_BAD_KEY_PROVIDED
;
161 unlikely (key_length
> 0xffff)
162 return MEMCACHED_BAD_KEY_PROVIDED
;
166 unlikely (key_length
>= MEMCACHED_MAX_KEY
)
167 return MEMCACHED_BAD_KEY_PROVIDED
;
170 return MEMCACHED_SUCCESS
;
174 #define CORK TCP_CORK
175 #elif defined TCP_NOPUSH
176 #define CORK TCP_NOPUSH
180 test_cork() tries to enable TCP_CORK. IF TCP_CORK is not an option
181 on the system it returns false but sets errno to 0. Otherwise on
182 failure errno is set.
184 static inline memcached_ternary_t
test_cork(memcached_server_st
*ptr
, int enable
)
187 if (ptr
->type
!= MEMCACHED_CONNECTION_TCP
)
190 int err
= setsockopt(ptr
->fd
, IPPROTO_TCP
, CORK
,
191 &enable
, (socklen_t
)sizeof(int));
197 perror(strerror(errno
));
198 ptr
->cached_errno
= errno
;
205 ptr
->cached_errno
= 0;
211 static inline void libmemcached_free(const memcached_st
*ptr
, void *mem
)
213 ptr
->allocators
.free(ptr
, mem
, ptr
->allocators
.context
);
216 static inline void *libmemcached_malloc(const memcached_st
*ptr
, const size_t size
)
218 return ptr
->allocators
.malloc(ptr
, size
, ptr
->allocators
.context
);
221 static inline void *libmemcached_realloc(const memcached_st
*ptr
, void *mem
, const size_t size
)
223 return ptr
->allocators
.realloc(ptr
, mem
, size
, ptr
->allocators
.context
);
226 static inline void *libmemcached_calloc(const memcached_st
*ptr
, size_t nelem
, size_t size
)
228 return ptr
->allocators
.calloc(ptr
, nelem
, size
, ptr
->allocators
.context
);
235 #endif /* __LIBMEMCACHED_COMMON_H__ */