New version update
[m6w6/libmemcached] / libmemcached / memcached.c
1 /*
2 Memcached library
3 */
4 #include "common.h"
5
6 memcached_st *memcached_create(memcached_st *ptr)
7 {
8 memcached_result_st *result_ptr;
9
10 if (ptr == NULL)
11 {
12 ptr= (memcached_st *)malloc(sizeof(memcached_st));
13
14 if (!ptr)
15 return NULL; /* MEMCACHED_MEMORY_ALLOCATION_FAILURE */
16
17 memset(ptr, 0, sizeof(memcached_st));
18 ptr->is_allocated= MEMCACHED_ALLOCATED;
19 }
20 else
21 {
22 memset(ptr, 0, sizeof(memcached_st));
23 }
24 result_ptr= memcached_result_create(ptr, &ptr->result);
25 WATCHPOINT_ASSERT(result_ptr);
26 ptr->poll_timeout= MEMCACHED_DEFAULT_TIMEOUT;
27 ptr->connect_timeout= MEMCACHED_DEFAULT_TIMEOUT;
28 ptr->retry_timeout= 0;
29 ptr->distribution= MEMCACHED_DISTRIBUTION_MODULA;
30
31 return ptr;
32 }
33
34 void memcached_free(memcached_st *ptr)
35 {
36 /* If we have anything open, lets close it now */
37 memcached_quit(ptr);
38 server_list_free(ptr, ptr->hosts);
39 memcached_result_free(&ptr->result);
40
41 if (ptr->on_cleanup)
42 ptr->on_cleanup(ptr);
43
44 if (ptr->is_allocated == MEMCACHED_ALLOCATED)
45 {
46 if (ptr->call_free)
47 ptr->call_free(ptr, ptr);
48 else
49 free(ptr);
50 }
51 else
52 ptr->is_allocated= MEMCACHED_USED;
53 }
54
55 /*
56 clone is the destination, while ptr is the structure to clone.
57 If ptr is NULL the call is the same as if a memcached_create() was
58 called.
59 */
60 memcached_st *memcached_clone(memcached_st *clone, memcached_st *ptr)
61 {
62 memcached_return rc= MEMCACHED_SUCCESS;
63 memcached_st *new_clone;
64
65 if (ptr == NULL)
66 return memcached_create(clone);
67
68 if (ptr->is_allocated == MEMCACHED_USED)
69 {
70 WATCHPOINT_ASSERT(0);
71 return NULL;
72 }
73
74 new_clone= memcached_create(clone);
75
76 if (new_clone == NULL)
77 return NULL;
78
79 if (ptr->hosts)
80 rc= memcached_server_push(new_clone, ptr->hosts);
81
82 if (rc != MEMCACHED_SUCCESS)
83 {
84 memcached_free(new_clone);
85
86 return NULL;
87 }
88
89
90 new_clone->flags= ptr->flags;
91 new_clone->send_size= ptr->send_size;
92 new_clone->recv_size= ptr->recv_size;
93 new_clone->poll_timeout= ptr->poll_timeout;
94 new_clone->connect_timeout= ptr->connect_timeout;
95 new_clone->retry_timeout= ptr->retry_timeout;
96 new_clone->distribution= ptr->distribution;
97 new_clone->hash= ptr->hash;
98 new_clone->user_data= ptr->user_data;
99
100 new_clone->on_clone= ptr->on_clone;
101 new_clone->on_cleanup= ptr->on_cleanup;
102 new_clone->call_free= ptr->call_free;
103 new_clone->call_malloc= ptr->call_malloc;
104 new_clone->call_realloc= ptr->call_realloc;
105 new_clone->get_key_failure= ptr->get_key_failure;
106
107 if (ptr->on_clone)
108 ptr->on_clone(ptr, new_clone);
109
110 return new_clone;
111 }