Home
last modified time | relevance | path

Searched refs:ptr (Results 1 - 25 of 230) sorted by relevance

12345678910

/5.5.2/moxi/libmemcached/libmemcached/
H A Dbehavior.c27 static memcached_ternary_t test_cork(memcached_server_st *ptr, int enable) in test_cork() argument
31 if (ptr->type != MEMCACHED_CONNECTION_TCP) in test_cork()
34 err= setsockopt(ptr->fd, IPPROTO_TCP, CORK, in test_cork()
42 ptr->cached_errno= errno; in test_cork()
46 (void)ptr; in test_cork()
49 ptr->cached_errno= 0; in test_cork()
68 memcached_return_t memcached_behavior_set(memcached_st *ptr, in memcached_behavior_set() argument
75 ptr->number_of_replicas= (uint32_t)data; in memcached_behavior_set()
78 ptr->io_msg_watermark= (uint32_t) data; in memcached_behavior_set()
81 ptr in memcached_behavior_set()
280 _is_auto_eject_host(const memcached_st *ptr) _is_auto_eject_host() argument
285 memcached_behavior_get(memcached_st *ptr, const memcached_behavior_t flag) memcached_behavior_get() argument
435 memcached_behavior_set_distribution(memcached_st *ptr, memcached_server_distribution_t type) memcached_behavior_set_distribution() argument
451 memcached_behavior_get_distribution(memcached_st *ptr) memcached_behavior_get_distribution() argument
456 memcached_behavior_set_key_hash(memcached_st *ptr, memcached_hash_t type) memcached_behavior_set_key_hash() argument
464 memcached_behavior_get_key_hash(memcached_st *ptr) memcached_behavior_get_key_hash() argument
469 memcached_behavior_set_distribution_hash(memcached_st *ptr, memcached_hash_t type) memcached_behavior_set_distribution_hash() argument
477 memcached_behavior_get_distribution_hash(memcached_st *ptr) memcached_behavior_get_distribution_hash() argument
[all...]
H A Dio.c20 static ssize_t io_flush(memcached_server_write_instance_st ptr,
22 static void increment_udp_message_id(memcached_server_write_instance_st ptr);
24 static memcached_return_t io_wait(memcached_server_write_instance_st ptr, in io_wait() argument
32 fds.fd= ptr->fd; in io_wait()
38 WATCHPOINT_SET(ptr->io_wait_count.write++); in io_wait()
42 WATCHPOINT_SET(ptr->io_wait_count.read++); in io_wait()
55 memcached_return_t rc= memcached_purge(ptr); in io_wait()
62 error= poll(&fds, 1, ptr->root->poll_timeout); in io_wait()
87 (void)getsockopt(ptr->fd, SOL_SOCKET, SO_ERROR, &err, &len); in io_wait()
88 ptr in io_wait()
109 memcached_io_wait_for_write(memcached_server_write_instance_st ptr) memcached_io_wait_for_write() argument
120 repack_input_buffer(memcached_server_write_instance_st ptr) repack_input_buffer() argument
161 process_input_buffer(memcached_server_write_instance_st ptr) process_input_buffer() argument
205 memcached_io_cork_push(memcached_server_st *ptr) memcached_io_cork_push() argument
222 memcached_io_cork_pop(memcached_server_st *ptr) memcached_io_cork_pop() argument
266 memcached_io_read(memcached_server_write_instance_st ptr, void *buffer, size_t length, ssize_t *nread) memcached_io_read() argument
363 _io_write(memcached_server_write_instance_st ptr, const void *buffer, size_t length, bool with_flush) _io_write() argument
444 memcached_io_write(memcached_server_write_instance_st ptr, const void *buffer, size_t length, bool with_flush) memcached_io_write() argument
450 memcached_io_writev(memcached_server_write_instance_st ptr, const struct libmemcached_io_vector_st *vector, size_t number_of, bool with_flush) memcached_io_writev() argument
480 memcached_io_close(memcached_server_write_instance_st ptr) memcached_io_close() argument
575 io_flush(memcached_server_write_instance_st ptr, memcached_return_t *error) io_flush() argument
710 memcached_io_reset(memcached_server_write_instance_st ptr) memcached_io_reset() argument
719 memcached_safe_read(memcached_server_write_instance_st ptr, void *dta, size_t size) memcached_safe_read() argument
740 memcached_io_readline(memcached_server_write_instance_st ptr, char *buffer_ptr, size_t size) memcached_io_readline() argument
798 increment_udp_message_id(memcached_server_write_instance_st ptr) increment_udp_message_id() argument
811 memcached_io_init_udp_header(memcached_server_write_instance_st ptr, uint16_t thread_id) memcached_io_init_udp_header() argument
[all...]
H A Dconnect.c16 static memcached_return_t connect_poll(memcached_server_st *ptr) in connect_poll() argument
22 fds[0].fd = ptr->fd; in connect_poll()
27 error= poll(fds, 1, ptr->root->connect_timeout); in connect_poll()
35 (void)getsockopt(ptr->fd, SOL_SOCKET, SO_ERROR, &err, &len); in connect_poll()
44 ptr->cached_errno= errno; in connect_poll()
65 (void)getsockopt(ptr->fd, SOL_SOCKET, SO_ERROR, &err, &len); in connect_poll()
66 ptr->cached_errno= (err == 0) ? get_socket_errno() : err; in connect_poll()
70 ptr->cached_errno= get_socket_errno(); in connect_poll()
73 (void)closesocket(ptr->fd); in connect_poll()
74 ptr in connect_poll()
150 set_socket_nonblocking(memcached_server_st *ptr) set_socket_nonblocking() argument
189 set_socket_options(memcached_server_st *ptr) set_socket_options() argument
323 unix_socket_connect(memcached_server_st *ptr) unix_socket_connect() argument
369 network_connect(memcached_server_st *ptr) network_connect() argument
468 set_last_disconnected_host(memcached_server_write_instance_st ptr) set_last_disconnected_host() argument
483 memcached_connect(memcached_server_write_instance_st ptr) memcached_connect() argument
[all...]
H A Dquit.c12 void memcached_quit_server(memcached_server_st *ptr, bool io_death) in memcached_quit_server() argument
14 if (ptr->fd != -1) in memcached_quit_server()
16 if (io_death == false && ptr->type != MEMCACHED_CONNECTION_UDP && ptr->options.is_shutting_down == false) in memcached_quit_server()
21 ptr->options.is_shutting_down= true; in memcached_quit_server()
23 if (ptr->root->flags.binary_protocol) in memcached_quit_server()
30 rc= memcached_do(ptr, request.bytes, sizeof(request.bytes), true); in memcached_quit_server()
34 rc= memcached_do(ptr, "quit\r\n", strlen("quit\r\n"), true); in memcached_quit_server()
48 if (ptr->root->flags.buffer_requests || ptr in memcached_quit_server()
87 memcached_quit(memcached_st *ptr) memcached_quit() argument
[all...]
H A Dallocators.c4 void libmemcached_free(const memcached_st *ptr, void *mem) in libmemcached_free() argument
6 ptr->allocators.free(ptr, mem, ptr->allocators.context); in libmemcached_free()
9 void *libmemcached_malloc(const memcached_st *ptr, const size_t size) in libmemcached_malloc() argument
11 return ptr->allocators.malloc(ptr, size, ptr->allocators.context); in libmemcached_malloc()
14 void *libmemcached_realloc(const memcached_st *ptr, void *mem, const size_t size) in libmemcached_realloc() argument
16 return ptr in libmemcached_realloc()
19 libmemcached_calloc(const memcached_st *ptr, size_t nelem, size_t size) libmemcached_calloc() argument
24 _libmemcached_free(const memcached_st *ptr, void *mem, void *context) _libmemcached_free() argument
31 _libmemcached_malloc(const memcached_st *ptr, const size_t size, void *context) _libmemcached_malloc() argument
38 _libmemcached_realloc(const memcached_st *ptr, void *mem, const size_t size, void *context) _libmemcached_realloc() argument
45 _libmemcached_calloc(const memcached_st *ptr, size_t nelem, size_t size, void *context) _libmemcached_calloc() argument
75 memcached_set_memory_allocators(memcached_st *ptr, memcached_malloc_fn mem_malloc, memcached_free_fn mem_free, memcached_realloc_fn mem_realloc, memcached_calloc_fn mem_calloc, void *context) memcached_set_memory_allocators() argument
103 memcached_get_memory_allocators_context(const memcached_st *ptr) memcached_get_memory_allocators_context() argument
108 memcached_get_memory_allocators(const memcached_st *ptr, memcached_malloc_fn *mem_malloc, memcached_free_fn *mem_free, memcached_realloc_fn *mem_realloc, memcached_calloc_fn *mem_calloc) memcached_get_memory_allocators() argument
[all...]
H A Dmemcached.c72 memcached_st *memcached_create(memcached_st *ptr) in memcached_create() argument
74 if (ptr == NULL) in memcached_create()
76 ptr= (memcached_st *)malloc(sizeof(memcached_st)); in memcached_create()
78 if (! ptr) in memcached_create()
83 ptr->options.is_allocated= true; in memcached_create()
87 ptr->options.is_allocated= false; in memcached_create()
91 memcached_set_purging(ptr, false); in memcached_create()
92 memcached_set_processing_input(ptr, false); in memcached_create()
95 if (! _memcached_init(ptr)) in memcached_create()
97 memcached_free(ptr); in memcached_create()
112 memcached_servers_reset(memcached_st *ptr) memcached_servers_reset() argument
126 memcached_reset_last_disconnected_server(memcached_st *ptr) memcached_reset_last_disconnected_server() argument
135 memcached_free(memcached_st *ptr) memcached_free() argument
272 memcached_get_user_data(const memcached_st *ptr) memcached_get_user_data() argument
277 memcached_set_user_data(memcached_st *ptr, void *data) memcached_set_user_data() argument
290 memcached_server_instance_fetch(memcached_st *ptr, uint32_t server_key) memcached_server_instance_fetch() argument
295 memcached_server_instance_by_position(const memcached_st *ptr, uint32_t server_key) memcached_server_instance_by_position() argument
[all...]
H A Dhash.c20 static uint32_t generate_hash(const memcached_st *ptr, const char *key, size_t key_length) in generate_hash() argument
22 return hashkit_digest(&ptr->hashkit, key, key_length); in generate_hash()
25 static uint32_t dispatch_host(const memcached_st *ptr, uint32_t hash) in dispatch_host() argument
27 switch (ptr->distribution) in dispatch_host()
34 uint32_t num= ptr->continuum_points_counter; in dispatch_host()
35 WATCHPOINT_ASSERT(ptr->continuum); in dispatch_host()
37 begin= left= ptr->continuum; in dispatch_host()
38 end= right= ptr->continuum + num; in dispatch_host()
53 return hash % memcached_server_count(ptr); in dispatch_host()
55 return (uint32_t) random() % memcached_server_count(ptr); in dispatch_host()
67 _generate_hash_wrapper(const memcached_st *ptr, const char *key, size_t key_length) _generate_hash_wrapper() argument
96 _regen_for_auto_eject(memcached_st *ptr) _regen_for_auto_eject() argument
110 memcached_autoeject(memcached_st *ptr) memcached_autoeject() argument
115 memcached_generate_hash_with_redistribution(memcached_st *ptr, const char *key, size_t key_length) memcached_generate_hash_with_redistribution() argument
124 memcached_generate_hash(const memcached_st *ptr, const char *key, size_t key_length) memcached_generate_hash() argument
129 memcached_get_hashkit(const memcached_st *ptr) memcached_get_hashkit() argument
[all...]
H A Dget.c17 char *memcached_get(memcached_st *ptr, const char *key, in memcached_get() argument
23 return memcached_get_by_key(ptr, NULL, 0, key, key_length, value_length, in memcached_get()
27 static memcached_return_t memcached_mget_by_key_real(memcached_st *ptr,
35 char *memcached_get_by_key(memcached_st *ptr, in memcached_get_by_key() argument
48 unlikely (ptr->flags.use_udp) in memcached_get_by_key()
55 *error= memcached_mget_by_key_real(ptr, master_key, master_key_length, in memcached_get_by_key()
59 value= memcached_fetch(ptr, NULL, NULL, in memcached_get_by_key()
67 if (ptr->get_key_failure && *error == MEMCACHED_NOTFOUND) in memcached_get_by_key()
71 memcached_result_reset(&ptr->result); in memcached_get_by_key()
72 rc= ptr in memcached_get_by_key()
123 memcached_mget(memcached_st *ptr, const char * const *keys, const size_t *key_length, size_t number_of_keys) memcached_mget() argument
139 memcached_mget_by_key_real(memcached_st *ptr, const char *master_key, size_t master_key_length, const char * const *keys, const size_t *key_length, size_t number_of_keys, bool mget_mode) memcached_mget_by_key_real() argument
319 memcached_mget_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char * const *keys, const size_t *key_length, const size_t number_of_keys) memcached_mget_by_key() argument
330 memcached_mget_execute(memcached_st *ptr, const char * const *keys, const size_t *key_length, const size_t number_of_keys, memcached_execute_fn *callback, void *context, const unsigned int number_of_callbacks) memcached_mget_execute() argument
343 memcached_mget_execute_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char * const *keys, const size_t *key_length, size_t number_of_keys, memcached_execute_fn *callback, void *context, const unsigned int number_of_callbacks) memcached_mget_execute_by_key() argument
373 simple_binary_mget(memcached_st *ptr, uint32_t master_server_key, bool is_master_key_set, const char * const *keys, const size_t *key_length, size_t number_of_keys, bool mget_mode) simple_binary_mget() argument
501 replication_binary_mget(memcached_st *ptr, uint32_t* hash, bool* dead_servers, const char *const *keys, const size_t *key_length, size_t number_of_keys) replication_binary_mget() argument
602 binary_mget_by_key(memcached_st *ptr, uint32_t master_server_key, bool is_master_key_set, const char * const *keys, const size_t *key_length, size_t number_of_keys, bool mget_mode) binary_mget_by_key() argument
[all...]
H A Dhosts.c16 static memcached_return_t server_add(memcached_st *ptr, const char *hostname,
20 static memcached_return_t update_continuum(memcached_st *ptr);
38 static void sort_hosts(memcached_st *ptr) in sort_hosts() argument
40 if (memcached_server_count(ptr)) in sort_hosts()
44 qsort(memcached_server_list(ptr), memcached_server_count(ptr), sizeof(memcached_server_st), compare_servers); in sort_hosts()
45 instance= memcached_server_instance_fetch(ptr, 0); in sort_hosts()
46 instance->number_of_hosts= memcached_server_count(ptr); in sort_hosts()
51 memcached_return_t run_distribution(memcached_st *ptr) in run_distribution() argument
53 if (ptr in run_distribution()
102 update_continuum(memcached_st *ptr) update_continuum() argument
318 memcached_server_push(memcached_st *ptr, const memcached_server_list_st list) memcached_server_push() argument
365 memcached_server_add_unix_socket(memcached_st *ptr, const char *filename) memcached_server_add_unix_socket() argument
371 memcached_server_add_unix_socket_with_weight(memcached_st *ptr, const char *filename, uint32_t weight) memcached_server_add_unix_socket_with_weight() argument
381 memcached_server_add_udp(memcached_st *ptr, const char *hostname, in_port_t port) memcached_server_add_udp() argument
388 memcached_server_add_udp_with_weight(memcached_st *ptr, const char *hostname, in_port_t port, uint32_t weight) memcached_server_add_udp_with_weight() argument
402 memcached_server_add(memcached_st *ptr, const char *hostname, in_port_t port) memcached_server_add() argument
409 memcached_server_add_with_weight(memcached_st *ptr, const char *hostname, in_port_t port, uint32_t weight) memcached_server_add_with_weight() argument
423 server_add(memcached_st *ptr, const char *hostname, in_port_t port, uint32_t weight, memcached_connection_t type) server_add() argument
[all...]
H A Dcallback.c19 memcached_return_t memcached_callback_set(memcached_st *ptr, in memcached_callback_set() argument
39 || (strncpy(ptr->prefix_key, key, MEMCACHED_PREFIX_KEY_MAX_SIZE) == NULL)) in memcached_callback_set()
41 ptr->prefix_key_length= 0; in memcached_callback_set()
46 ptr->prefix_key_length= key_length; in memcached_callback_set()
51 ptr->prefix_key[0]= 0; in memcached_callback_set()
52 ptr->prefix_key_length= 0; in memcached_callback_set()
59 ptr->user_data= data; in memcached_callback_set()
65 ptr->on_cleanup= func; in memcached_callback_set()
71 ptr->on_clone= func; in memcached_callback_set()
78 ptr in memcached_callback_set()
114 memcached_callback_get(memcached_st *ptr, const memcached_callback_t flag, memcached_return_t *error) memcached_callback_get() argument
[all...]
H A Dresult.c32 memcached_result_st *ptr) in memcached_result_create()
37 if (ptr) in memcached_result_create()
39 ptr->options.is_allocated= false; in memcached_result_create()
43 ptr= libmemcached_malloc(memc, sizeof(memcached_result_st)); in memcached_result_create()
45 if (ptr == NULL) in memcached_result_create()
48 ptr->options.is_allocated= true; in memcached_result_create()
51 ptr->options.is_initialized= true; in memcached_result_create()
53 _result_init(ptr, memc); in memcached_result_create()
55 ptr->root= memc; in memcached_result_create()
56 WATCHPOINT_SET(ptr in memcached_result_create()
31 memcached_result_create(const memcached_st *memc, memcached_result_st *ptr) memcached_result_create() argument
64 memcached_result_reset(memcached_result_st *ptr) memcached_result_reset() argument
73 memcached_result_free(memcached_result_st *ptr) memcached_result_free() argument
91 memcached_result_set_value(memcached_result_st *ptr, const char *value, size_t length) memcached_result_set_value() argument
[all...]
H A Dpurge.c3 memcached_return_t memcached_purge(memcached_server_write_instance_st ptr) in memcached_purge() argument
7 memcached_st *root= (memcached_st *)ptr->root; in memcached_purge()
10 if (memcached_is_purging(ptr->root) || /* already purging */ in memcached_purge()
11 (memcached_server_response_count(ptr) < ptr->root->io_msg_watermark && in memcached_purge()
12 ptr->io_bytes_sent < ptr->root->io_bytes_watermark) || in memcached_purge()
13 (ptr->io_bytes_sent >= ptr->root->io_bytes_watermark && in memcached_purge()
14 memcached_server_response_count(ptr) < in memcached_purge()
[all...]
H A Dauto.c14 static memcached_return_t text_incr_decr(memcached_st *ptr, in text_incr_decr() argument
25 bool no_reply= ptr->flags.no_reply; in text_incr_decr()
28 unlikely (memcached_server_count(ptr) == 0) in text_incr_decr()
31 if (ptr->flags.verify_key && (memcached_key_test((const char **)&key, &key_length, 1) == MEMCACHED_BAD_KEY_PROVIDED)) in text_incr_decr()
34 server_key= memcached_generate_hash_with_redistribution(ptr, master_key, master_key_length); in text_incr_decr()
35 instance= memcached_server_instance_fetch(ptr, server_key); in text_incr_decr()
39 (int)ptr->prefix_key_length, in text_incr_decr()
40 ptr->prefix_key, in text_incr_decr()
83 static memcached_return_t binary_incr_decr(memcached_st *ptr, uint8_t cmd, in binary_incr_decr() argument
92 bool no_reply= ptr in binary_incr_decr()
141 memcached_increment(memcached_st *ptr, const char *key, size_t key_length, uint32_t offset, uint64_t *value) memcached_increment() argument
149 memcached_decrement(memcached_st *ptr, const char *key, size_t key_length, uint32_t offset, uint64_t *value) memcached_decrement() argument
157 memcached_increment_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, uint64_t offset, uint64_t *value) memcached_increment_by_key() argument
185 memcached_decrement_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, uint64_t offset, uint64_t *value) memcached_decrement_by_key() argument
213 memcached_increment_with_initial(memcached_st *ptr, const char *key, size_t key_length, uint64_t offset, uint64_t initial, time_t expiration, uint64_t *value) memcached_increment_with_initial() argument
226 memcached_increment_with_initial_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, uint64_t offset, uint64_t initial, time_t expiration, uint64_t *value) memcached_increment_with_initial_by_key() argument
254 memcached_decrement_with_initial(memcached_st *ptr, const char *key, size_t key_length, uint64_t offset, uint64_t initial, time_t expiration, uint64_t *value) memcached_decrement_with_initial() argument
267 memcached_decrement_with_initial_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, uint64_t offset, uint64_t initial, time_t expiration, uint64_t *value) memcached_decrement_with_initial_by_key() argument
[all...]
H A Ddelete.c4 memcached_return_t memcached_delete(memcached_st *ptr, const char *key, size_t key_length, in memcached_delete() argument
7 return memcached_delete_by_key(ptr, key, key_length, in memcached_delete()
11 static memcached_return_t binary_delete(memcached_st *ptr,
17 memcached_return_t memcached_delete_by_key(memcached_st *ptr, in memcached_delete_by_key() argument
32 ptr->flags.binary_protocol); in memcached_delete_by_key()
36 unlikely (memcached_server_count(ptr) == 0) in memcached_delete_by_key()
39 server_key= memcached_generate_hash_with_redistribution(ptr, master_key, master_key_length); in memcached_delete_by_key()
40 instance= memcached_server_instance_fetch(ptr, server_key); in memcached_delete_by_key()
42 to_write= (ptr->flags.buffer_requests) ? false : true; in memcached_delete_by_key()
44 no_reply= (ptr in memcached_delete_by_key()
151 binary_delete(memcached_st *ptr, uint32_t server_key, const char *key, size_t key_length, bool flush) binary_delete() argument
[all...]
H A Dstorage.c47 static memcached_return_t memcached_send_binary(memcached_st *ptr,
59 static memcached_return_t memcached_send(memcached_st *ptr, in memcached_send() argument
77 rc= memcached_validate_key_length(key_length, ptr->flags.binary_protocol); in memcached_send()
81 unlikely (memcached_server_count(ptr) == 0) in memcached_send()
84 if (ptr->flags.verify_key && (memcached_key_test((const char **)&key, &key_length, 1) == MEMCACHED_BAD_KEY_PROVIDED)) in memcached_send()
87 server_key= memcached_generate_hash_with_redistribution(ptr, master_key, master_key_length); in memcached_send()
88 instance= memcached_server_instance_fetch(ptr, server_key); in memcached_send()
93 if (ptr->flags.binary_protocol) in memcached_send()
95 rc= memcached_send_binary(ptr, instance, server_key, in memcached_send()
111 (int)ptr in memcached_send()
230 memcached_set(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_set() argument
244 memcached_add(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_add() argument
259 memcached_replace(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_replace() argument
274 memcached_prepend(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_prepend() argument
287 memcached_append(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_append() argument
300 memcached_cas(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas) memcached_cas() argument
314 memcached_set_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_set_by_key() argument
331 memcached_add_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_add_by_key() argument
347 memcached_replace_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_replace_by_key() argument
363 memcached_prepend_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_prepend_by_key() argument
377 memcached_append_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags) memcached_append_by_key() argument
391 memcached_cas_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas) memcached_cas_by_key() argument
464 memcached_send_binary(memcached_st *ptr, memcached_server_write_instance_st server, uint32_t server_key, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas, memcached_storage_action_t verb) memcached_send_binary() argument
[all...]
H A Ddo.c14 memcached_return_t memcached_do(memcached_server_write_instance_st ptr, const void *command, in memcached_do() argument
23 if ((rc= memcached_connect(ptr)) != MEMCACHED_SUCCESS) in memcached_do()
34 if (ptr->type == MEMCACHED_CONNECTION_UDP && with_flush && ptr->write_buffer_offset > UDP_DATAGRAM_HEADER_LENGTH) in memcached_do()
36 memcached_io_write(ptr, NULL, 0, true); in memcached_do()
39 sent_length= memcached_io_write(ptr, command, command_length, with_flush); in memcached_do()
45 else if ((ptr->root->flags.no_reply) == 0) in memcached_do()
47 memcached_server_response_increment(ptr); in memcached_do()
53 memcached_return_t memcached_vdo(memcached_server_write_instance_st ptr, in memcached_vdo() argument
65 if ((rc= memcached_connect(ptr)) ! in memcached_vdo()
[all...]
H A Dresponse.c14 static memcached_return_t textual_read_one_response(memcached_server_write_instance_st ptr,
17 static memcached_return_t binary_read_one_response(memcached_server_write_instance_st ptr,
21 memcached_return_t memcached_read_one_response(memcached_server_write_instance_st ptr, in memcached_read_one_response() argument
26 memcached_server_response_decrement(ptr); in memcached_read_one_response()
30 memcached_st *root= (memcached_st *)ptr->root; in memcached_read_one_response()
34 if (ptr->root->flags.binary_protocol) in memcached_read_one_response()
35 rc= binary_read_one_response(ptr, buffer, buffer_length, result); in memcached_read_one_response()
37 rc= textual_read_one_response(ptr, buffer, buffer_length, result); in memcached_read_one_response()
43 memcached_io_reset(ptr); in memcached_read_one_response()
48 memcached_return_t memcached_response(memcached_server_write_instance_st ptr, in memcached_response() argument
84 textual_value_fetch(memcached_server_write_instance_st ptr, char *buffer, memcached_result_st *result) textual_value_fetch() argument
215 textual_read_one_response(memcached_server_write_instance_st ptr, char *buffer, size_t buffer_length, memcached_result_st *result) textual_read_one_response() argument
338 binary_read_one_response(memcached_server_write_instance_st ptr, char *buffer, size_t buffer_length, memcached_result_st *result) binary_read_one_response() argument
[all...]
/5.5.2/platform/tests/cjson/
H A Dcjson_utils_test.cc22 unique_cJSON_ptr ptr; in TEST() local
23 EXPECT_THROW(to_string(ptr.get()), std::invalid_argument); in TEST()
24 EXPECT_THROW(to_string(ptr), std::invalid_argument); in TEST()
28 unique_cJSON_ptr ptr(cJSON_CreateObject()); in TEST()
29 cJSON_AddStringToObject(ptr.get(), "foo", "bar"); in TEST()
32 EXPECT_EQ(expected, to_string(ptr)); in TEST()
33 EXPECT_EQ(expected, to_string(ptr.get())); in TEST()
37 unique_cJSON_ptr ptr(cJSON_CreateObject()); in TEST()
38 cJSON_AddStringToObject(ptr.get(), "foo", "bar"); in TEST()
41 EXPECT_EQ(expected, to_string(ptr, tru in TEST()
[all...]
/5.5.2/sigar/src/os/linux/
H A Dlinux_sigar.c97 char buffer[BUFSIZ], *ptr=buffer; in get_proc_signal_offset() local
106 while (*ptr) { in get_proc_signal_offset()
107 if (*ptr++ == ' ') { in get_proc_signal_offset()
128 char buffer[BUFSIZ], *ptr; in sigar_boot_time_get() local
135 while ((ptr = fgets(buffer, sizeof(buffer), fp))) { in sigar_boot_time_get()
136 if (strnEQ(ptr, "btime", 5)) { in sigar_boot_time_get()
137 if ((ptr = sigar_skip_token(ptr))) { in sigar_boot_time_get()
138 sigar->boot_time = sigar_strtoul(ptr); in sigar_boot_time_get()
229 char buffer[BUFSIZ], *ptr; in get_ram() local
296 char *ptr, *tok; sigar_meminfo() local
349 char buffer[BUFSIZ], *ptr; sigar_swap_get() local
397 char *ptr = sigar_skip_token(line); /* "cpu%d" */ get_cpu_metrics() local
449 char buffer[BUFSIZ], *ptr=buffer; proc_isthread() local
558 char buffer[BUFSIZ], *ptr=buffer, *tmp; proc_stat_read() local
660 char buffer[BUFSIZ], *ptr=buffer; sigar_proc_mem_get() local
703 char buffer[BUFSIZ], *ptr; proc_status_get() local
874 convert_hex_address(sigar_net_address_t *address, char *ptr, int len) convert_hex_address() argument
962 char *ptr = sigar->proc_net; proc_net_read() local
1193 char *ptr = addr; sigar_net_interface_ipv6_config_get() local
[all...]
/5.5.2/moxi/src/
H A Dmcs.c48 mcs_st *lvb_create(mcs_st *ptr, const char *config,
52 void lvb_free_data(mcs_st *ptr);
54 uint32_t lvb_key_hash(mcs_st *ptr, const char *key, size_t key_length,
56 void lvb_server_invalid_vbucket(mcs_st *ptr, int server_index,
61 mcs_st *lmc_create(mcs_st *ptr, const char *config,
65 void lmc_free_data(mcs_st *ptr);
66 uint32_t lmc_key_hash(mcs_st *ptr, const char *key, size_t key_length,
71 mcs_st *mcs_create(mcs_st *ptr, const char *config, in mcs_create() argument
79 return lvb_create(ptr, config, default_usr, default_pwd, opts); in mcs_create()
85 return lmc_create(ptr, confi in mcs_create()
93 mcs_free(mcs_st *ptr) mcs_free() argument
128 mcs_server_count(mcs_st *ptr) mcs_server_count() argument
132 mcs_server_index(mcs_st *ptr, int i) mcs_server_index() argument
136 mcs_key_hash(mcs_st *ptr, const char *key, size_t key_length, int *vbucket) mcs_key_hash() argument
147 mcs_server_invalid_vbucket(mcs_st *ptr, int server_index, int vbucket) mcs_server_invalid_vbucket() argument
156 lvb_create(mcs_st *ptr, const char *config, const char *default_usr, const char *default_pwd, const char *opts) lvb_create() argument
240 lvb_free_data(mcs_st *ptr) lvb_free_data() argument
285 lvb_key_hash(mcs_st *ptr, const char *key, size_t key_length, int *vbucket) lvb_key_hash() argument
303 lvb_server_invalid_vbucket(mcs_st *ptr, int server_index, int vbucket) lvb_server_invalid_vbucket() argument
318 lmc_create(mcs_st *ptr, const char *config, const char *default_usr, const char *default_pwd, const char *opts) lmc_create() argument
404 lmc_free_data(mcs_st *ptr) lmc_free_data() argument
414 lmc_key_hash(mcs_st *ptr, const char *key, size_t key_length, int *vbucket) lmc_key_hash() argument
427 mcs_server_st_quit(mcs_server_st *ptr, uint8_t io_death) mcs_server_st_quit() argument
438 mcs_server_st_connect(mcs_server_st *ptr, int *errno_out, bool blocking) mcs_server_st_connect() argument
751 mcs_server_st_hostname(mcs_server_st *ptr) mcs_server_st_hostname() argument
755 mcs_server_st_port(mcs_server_st *ptr) mcs_server_st_port() argument
759 mcs_server_st_fd(mcs_server_st *ptr) mcs_server_st_fd() argument
763 mcs_server_st_usr(mcs_server_st *ptr) mcs_server_st_usr() argument
767 mcs_server_st_pwd(mcs_server_st *ptr) mcs_server_st_pwd() argument
[all...]
H A Dcache.c27 void** ptr = calloc(initial_pool_size, bufsize); in cache_create() local
28 if (ret == NULL || nm == NULL || ptr == NULL) { in cache_create()
31 free(ptr); in cache_create()
36 ret->ptr = ptr; in cache_create()
51 static void* get_object(void *ptr) { in get_object() argument
53 uint64_t *pre = ptr; in get_object()
56 return ptr; in get_object()
61 void *ptr = cache->ptr[ in cache_destroy() local
107 cache_free(cache_t *cache, void *ptr) cache_free() argument
[all...]
/5.5.2/kv_engine/daemon/
H A Ddarwin_zone.cc60 static size_t zone_size(malloc_zone_t *zone, const void *ptr);
64 static void zone_free(malloc_zone_t *zone, void *ptr);
65 static void *zone_realloc(malloc_zone_t *zone, void *ptr, size_t size);
68 static void zone_free_definite_size(malloc_zone_t *zone, void *ptr,
72 static inline void invoke_new_hook(void* ptr, size_t size) { in invoke_new_hook() argument
74 (*new_hook)(ptr, size); in invoke_new_hook()
78 static inline void invoke_delete_hook(void* ptr) { in invoke_delete_hook() argument
80 (*delete_hook)(ptr); in invoke_delete_hook()
91 zone_size(malloc_zone_t *zone, const void *ptr) in zone_size() argument
93 return default_zone->size(default_zone, ptr); in zone_size()
99 void *ptr = default_zone->malloc(default_zone, size); zone_malloc() local
107 void *ptr = default_zone->calloc(default_zone, num_items, size); zone_calloc() local
115 void *ptr = default_zone->valloc(default_zone, size); zone_valloc() local
121 zone_free(malloc_zone_t *zone, void *ptr) zone_free() argument
128 zone_realloc(malloc_zone_t *zone, void *ptr, size_t size) zone_realloc() argument
139 void *ptr = default_zone->memalign(default_zone, alignment, size); zone_memalign() local
145 zone_free_definite_size(malloc_zone_t *zone, void *ptr, size_t size) zone_free_definite_size() argument
[all...]
/5.5.2/kv_engine/auditd/tests/
H A Deventdescriptor_test.cc44 EventDescriptor ptr(json.get()); in TEST_F()
45 EXPECT_EQ(1, ptr.getId()); in TEST_F()
46 EXPECT_EQ("name", ptr.getName()); in TEST_F()
47 EXPECT_EQ("description", ptr.getDescription()); in TEST_F()
48 EXPECT_FALSE(ptr.isSync()); in TEST_F()
49 EXPECT_TRUE(ptr.isEnabled()); in TEST_F()
54 EXPECT_THROW(EventDescriptor ptr(json.get()), in TEST_F()
60 EXPECT_THROW(EventDescriptor ptr(json.get()), in TEST_F()
67 EXPECT_THROW(EventDescriptor ptr(json.get()), in TEST_F()
73 EXPECT_THROW(EventDescriptor ptr(jso in TEST_F()
[all...]
/5.5.2/kv_engine/xattr/
H A Dkey_validator.cc36 * @param ptr pointer to the raw byte array
42 int get_utf8_char_width(const char* ptr, size_t avail) { in get_utf8_char_width() argument
43 if (static_cast<uint8_t>(ptr[0]) < 0x80) { in get_utf8_char_width()
51 if ((ptr[0] & 0xE0) == 0xC0) { in get_utf8_char_width()
52 if ((ptr[1] & 0xC0) == 0x80) { in get_utf8_char_width()
62 if ((ptr[0] & 0xf0) == 0xE0) { in get_utf8_char_width()
63 if (((ptr[1] & 0xC0) == 0x80) && in get_utf8_char_width()
64 ((ptr[2] & 0xC0) == 0x80)) { in get_utf8_char_width()
74 if ((ptr[0] & 0xf8) == 0xF0) { in get_utf8_char_width()
75 if (((ptr[ in get_utf8_char_width()
93 const char* ptr = path.buf; is_valid_xattr_key() local
[all...]
/5.5.2/sigar/src/
H A Dsigar_cache.c33 static void free_value(void *ptr) in free_value() argument
35 free(ptr); in free_value()
107 sigar_cache_entry_t *entry, **ptr; in sigar_cache_find() local
109 for (ptr = SIGAR_CACHE_IX(table, key), entry = *ptr; in sigar_cache_find()
111 ptr = &entry->next, entry = *ptr) in sigar_cache_find()
125 sigar_cache_entry_t *entry, **ptr; in sigar_cache_get() local
127 for (ptr = SIGAR_CACHE_IX(table, key), entry = *ptr; in sigar_cache_get()
164 sigar_cache_entry_t *entry, *ptr; sigar_cache_destroy() local
[all...]

Completed in 63 milliseconds

12345678910