6 memcached_st
*memcached_create(memcached_st
*ptr
)
8 memcached_result_st
*result_ptr
;
12 ptr
= (memcached_st
*)calloc(1, sizeof(memcached_st
));
15 return NULL
; /* MEMCACHED_MEMORY_ALLOCATION_FAILURE */
17 ptr
->is_allocated
= true;
21 memset(ptr
, 0, sizeof(memcached_st
));
23 result_ptr
= memcached_result_create(ptr
, &ptr
->result
);
24 WATCHPOINT_ASSERT(result_ptr
);
25 ptr
->poll_timeout
= MEMCACHED_DEFAULT_TIMEOUT
;
26 ptr
->connect_timeout
= MEMCACHED_DEFAULT_TIMEOUT
;
27 ptr
->retry_timeout
= 0;
28 ptr
->distribution
= MEMCACHED_DISTRIBUTION_MODULA
;
30 /* TODO, Document why we picked these defaults */
31 ptr
->io_msg_watermark
= 500;
32 ptr
->io_bytes_watermark
= 65 * 1024;
37 void memcached_free(memcached_st
*ptr
)
39 /* If we have anything open, lets close it now */
41 server_list_free(ptr
, ptr
->hosts
);
42 memcached_result_free(&ptr
->result
);
50 ptr
->call_free(ptr
, ptr
->continuum
);
55 if (ptr
->is_allocated
)
58 ptr
->call_free(ptr
, ptr
);
63 memset(ptr
, 0, sizeof(memcached_st
));
67 clone is the destination, while source is the structure to clone.
68 If source is NULL the call is the same as if a memcached_create() was
71 memcached_st
*memcached_clone(memcached_st
*clone
, memcached_st
*source
)
73 memcached_return rc
= MEMCACHED_SUCCESS
;
74 memcached_st
*new_clone
;
77 return memcached_create(clone
);
79 if (clone
&& clone
->is_allocated
)
84 new_clone
= memcached_create(clone
);
86 if (new_clone
== NULL
)
89 new_clone
->flags
= source
->flags
;
90 new_clone
->send_size
= source
->send_size
;
91 new_clone
->recv_size
= source
->recv_size
;
92 new_clone
->poll_timeout
= source
->poll_timeout
;
93 new_clone
->connect_timeout
= source
->connect_timeout
;
94 new_clone
->retry_timeout
= source
->retry_timeout
;
95 new_clone
->distribution
= source
->distribution
;
96 new_clone
->hash
= source
->hash
;
97 new_clone
->hash_continuum
= source
->hash_continuum
;
98 new_clone
->user_data
= source
->user_data
;
100 new_clone
->snd_timeout
= source
->snd_timeout
;
101 new_clone
->rcv_timeout
= source
->rcv_timeout
;
103 new_clone
->on_clone
= source
->on_clone
;
104 new_clone
->on_cleanup
= source
->on_cleanup
;
105 new_clone
->call_free
= source
->call_free
;
106 new_clone
->call_malloc
= source
->call_malloc
;
107 new_clone
->call_realloc
= source
->call_realloc
;
108 new_clone
->get_key_failure
= source
->get_key_failure
;
109 new_clone
->delete_trigger
= source
->delete_trigger
;
110 new_clone
->server_failure_limit
= source
->server_failure_limit
;
111 new_clone
->io_msg_watermark
= source
->io_msg_watermark
;
112 new_clone
->io_bytes_watermark
= source
->io_bytes_watermark
;
113 new_clone
->io_key_prefetch
= source
->io_key_prefetch
;
114 new_clone
->number_of_replicas
= source
->number_of_replicas
;
117 rc
= memcached_server_push(new_clone
, source
->hosts
);
119 if (rc
!= MEMCACHED_SUCCESS
)
121 memcached_free(new_clone
);
127 if (source
->prefix_key
[0] != 0)
129 strcpy(new_clone
->prefix_key
, source
->prefix_key
);
130 new_clone
->prefix_key_length
= source
->prefix_key_length
;
133 rc
= run_distribution(new_clone
);
134 if (rc
!= MEMCACHED_SUCCESS
)
136 memcached_free(new_clone
);
141 if (source
->on_clone
)
142 source
->on_clone(source
, new_clone
);