Small cleanups for design of some functions that will work with cluster.
[awesomized/libmemcached] / lib / memcached.c
1 /*
2 Memcached library
3 */
4 #include <memcached.h>
5
6 memcached_st *memcached_init(memcached_st *ptr)
7 {
8 if (!ptr)
9 {
10 ptr= (memcached_st *)malloc(sizeof(memcached_st));
11
12 if (!ptr)
13 return NULL; /* MEMCACHED_MEMORY_ALLOCATION_FAILURE */
14
15 memset(ptr, 0, sizeof(memcached_st));
16 ptr->is_allocated= MEMCACHED_ALLOCATED;
17 }
18 else
19 {
20 memset(ptr, 0, sizeof(memcached_st));
21 }
22 ptr->fd= -1;
23
24 return ptr;
25 }
26
27 memcached_return memcached_increment(memcached_st *ptr, char *key, size_t key_length,
28 unsigned int count)
29 {
30 return MEMCACHED_SUCCESS;
31 }
32
33 memcached_return memcached_decrement(memcached_st *ptr, char *key, size_t key_length,
34 unsigned int count)
35 {
36 return MEMCACHED_SUCCESS;
37 }
38
39 memcached_return memcached_flush(memcached_st *ptr, time_t expiration)
40 {
41 size_t send_length;
42 memcached_return rc;
43 char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
44
45 rc= memcached_connect(ptr);
46
47 if (expiration)
48 send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
49 "flush_all %u\r\n", expiration);
50 else
51 send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
52 "flush_all\r\n");
53 if ((send(ptr->fd, buffer, send_length, 0) == -1))
54 {
55 fprintf(stderr, "failed flush_all TCP\n");
56
57 return MEMCACHED_WRITE_FAILURE;
58 }
59
60 return memcached_response(ptr, buffer, MEMCACHED_DEFAULT_COMMAND_SIZE);
61 }
62
63 memcached_return memcached_verbosity(memcached_st *ptr, unsigned int verbosity)
64 {
65 size_t send_length;
66 memcached_return rc;
67 char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
68
69 rc= memcached_connect(ptr);
70
71 send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
72 "verbosity %u\r\n", verbosity);
73
74 if ((send(ptr->fd, buffer, send_length, 0) == -1))
75 {
76 fprintf(stderr, "failed verbosity\n");
77
78 return MEMCACHED_WRITE_FAILURE;
79 }
80
81 return memcached_response(ptr, buffer, MEMCACHED_DEFAULT_COMMAND_SIZE);
82 }
83
84 /*
85 When this is implemented you will be able to remove single hosts
86 from your current pool of hosts.
87 */
88 memcached_return memcached_quit(memcached_st *ptr, char *hostname, unsigned port)
89 {
90 return MEMCACHED_SUCCESS;
91 }
92
93 void memcached_deinit(memcached_st *ptr)
94 {
95 memcached_host_st *host_ptr;
96
97 if (ptr->fd > 0)
98 close(ptr->fd);
99
100 for (host_ptr= ptr->hosts; host_ptr;)
101 {
102 memcached_host_st *temp;
103
104 temp= host_ptr;
105 host_ptr= host_ptr->next;
106 if (temp->hostname)
107 free(temp->hostname);
108 free(temp);
109 }
110
111 if (ptr->is_allocated == MEMCACHED_ALLOCATED)
112 free(ptr);
113 else
114 memset(ptr, 0, sizeof(memcached_st));
115 }
116
117 char *memcached_strerror(memcached_st *ptr, memcached_return rc)
118 {
119 switch (rc)
120 {
121 case MEMCACHED_SUCCESS:
122 return "SUCCESS";
123 case MEMCACHED_FAILURE:
124 return "FAILURE";
125 case MEMCACHED_HOST_LOCKUP_FAILURE:
126 return "HOSTNAME LOOKUP FAILURE";
127 case MEMCACHED_CONNECTION_FAILURE:
128 return "CONNECTION FAILURE";
129 case MEMCACHED_CONNECTION_BIND_FAILURE:
130 return "CONNECTION BIND FAILURE";
131 case MEMCACHED_READ_FAILURE:
132 return "READ FAILURE";
133 case MEMCACHED_UNKNOWN_READ_FAILURE:
134 return "UNKNOWN READ FAILURE";
135 case MEMCACHED_PROTOCOL_ERROR:
136 return "PROTOCOL ERROR";
137 case MEMCACHED_CLIENT_ERROR:
138 return "CLIENT ERROR";
139 case MEMCACHED_SERVER_ERROR:
140 return "SERVER ERROR";
141 case MEMCACHED_WRITE_FAILURE:
142 return "WRITE FAILURE";
143 case MEMCACHED_CONNECTION_SOCKET_CREATE_FAILURE:
144 return "CONNECTION SOCKET CREATE FAILURE";
145 case MEMCACHED_DATA_EXISTS:
146 return "CONNECTION DATA EXISTS";
147 case MEMCACHED_DATA_DOES_NOT_EXIST:
148 return "CONNECTION DATA DOES NOT EXIST";
149 case MEMCACHED_NOTSTORED:
150 return "NOT STORED";
151 case MEMCACHED_NOTFOUND:
152 return "NOT FOUND";
153 case MEMCACHED_MEMORY_ALLOCATION_FAILURE:
154 return "MEMORY ALLOCATION FAILURE";
155 case MEMCACHED_PARTIAL_READ:
156 return "PARTIAL READ";
157 };
158 }