3 static memcached_return
memcached_auto(memcached_st
*ptr
,
5 char *key
, size_t key_length
,
9 size_t send_length
, sent_length
;
11 char buffer
[MEMCACHED_DEFAULT_COMMAND_SIZE
];
12 unsigned int server_key
;
15 return MEMCACHED_NO_KEY_PROVIDED
;
17 if (ptr
->hosts
== NULL
|| ptr
->number_of_hosts
== 0)
18 return MEMCACHED_NO_SERVERS
;
20 server_key
= memcached_generate_hash(ptr
, key
, key_length
);
22 if ((rc
= memcached_connect(ptr
, server_key
)) != MEMCACHED_SUCCESS
)
25 send_length
= snprintf(buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
,
26 "%s %.*s %u\r\n", verb
,
29 if (send_length
>= MEMCACHED_DEFAULT_COMMAND_SIZE
)
30 return MEMCACHED_WRITE_FAILURE
;
31 sent_length
= memcached_io_write(ptr
, server_key
, buffer
, send_length
, 1);
33 if (sent_length
== -1 || sent_length
!= send_length
)
34 return MEMCACHED_WRITE_FAILURE
;
36 memset(buffer
, 0, MEMCACHED_DEFAULT_COMMAND_SIZE
);
38 rc
= memcached_response(ptr
, buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
, server_key
);
41 So why recheck responce? Because the protocol is brain dead :)
42 The number returned might end up equaling one of the string
43 values. Less chance of a mistake with memcmp() so we will
44 use it. We still called memcached_response() though since it
45 worked its magic for non-blocking IO.
47 if (!memcmp(buffer
, "ERROR\r\n", MEMCACHED_DEFAULT_COMMAND_SIZE
))
50 rc
= MEMCACHED_PROTOCOL_ERROR
;
52 else if (!memcmp(buffer
, "NOT_FOUND\r\n", MEMCACHED_DEFAULT_COMMAND_SIZE
))
55 rc
= MEMCACHED_NOTFOUND
;
59 *value
= (uint64_t)strtoll(buffer
, (char **)NULL
, 10);
60 rc
= MEMCACHED_SUCCESS
;
66 memcached_return
memcached_increment(memcached_st
*ptr
,
67 char *key
, size_t key_length
,
73 LIBMEMCACHED_MEMCACHED_INCREMENT_START();
74 rc
= memcached_auto(ptr
, "incr", key
, key_length
, offset
, value
);
75 LIBMEMCACHED_MEMCACHED_INCREMENT_END();
80 memcached_return
memcached_decrement(memcached_st
*ptr
,
81 char *key
, size_t key_length
,
87 LIBMEMCACHED_MEMCACHED_DECREMENT_START();
88 rc
= memcached_auto(ptr
, "decr", key
, key_length
, offset
, value
);
89 LIBMEMCACHED_MEMCACHED_DECREMENT_END();