3 char *memcached_get(memcached_st
*ptr
, char *key
, size_t key_length
,
6 memcached_return
*error
)
8 size_t send_length
, sent_length
;
9 char buffer
[MEMCACHED_DEFAULT_COMMAND_SIZE
];
11 unsigned int server_key
;
14 *error
= memcached_connect(ptr
);
16 if (*error
!= MEMCACHED_SUCCESS
)
19 server_key
= memcached_generate_hash(key
, key_length
) % ptr
->number_of_hosts
;
21 send_length
= snprintf(buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
, "get %.*s\r\n",
22 (int)key_length
, key
);
24 if (send_length
>= MEMCACHED_DEFAULT_COMMAND_SIZE
)
26 *error
= MEMCACHED_WRITE_FAILURE
;
30 sent_length
= write(ptr
->hosts
[server_key
].fd
, buffer
, send_length
);
32 if (sent_length
== -1)
34 fprintf(stderr
, "error %s: write: %m\n", __FUNCTION__
);
35 *error
= MEMCACHED_WRITE_FAILURE
;
39 if (sent_length
!= send_length
)
41 fprintf(stderr
, "error %s: short write %d %d: %m\n",
42 __FUNCTION__
, sent_length
, send_length
);
43 *error
= MEMCACHED_WRITE_FAILURE
;
47 memset(buffer
, 0, MEMCACHED_DEFAULT_COMMAND_SIZE
);
48 *error
= memcached_response(ptr
, buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
, server_key
);
50 if (*error
== MEMCACHED_SUCCESS
)
55 string_ptr
+= 6; /* "VALUE " */
57 /* We do nothing with the key, since we only asked for one key */
58 for (end_ptr
= string_ptr
; *end_ptr
!= ' '; end_ptr
++);
61 string_ptr
= end_ptr
+ 1;
62 for (end_ptr
= string_ptr
; *end_ptr
!= ' '; end_ptr
++);
63 *flags
= (uint16_t)strtol(string_ptr
, &end_ptr
, 10);
66 string_ptr
= end_ptr
+ 1;
67 for (end_ptr
= string_ptr
; *end_ptr
!= ' '; end_ptr
++);
68 *value_length
= strtoll(string_ptr
, &end_ptr
, 10);
70 /* Skip past the \r\n */
71 string_ptr
= end_ptr
+2;
79 value
= (char *)malloc(*value_length
* sizeof(char));
83 *error
= MEMCACHED_MEMORY_ALLOCATION_FAILURE
;
87 need_to_copy
= (*value_length
< (size_t)(buffer
-string_ptr
))
89 : (size_t)(buffer
-string_ptr
) ;
91 pos_ptr
= memcpy(value
, string_ptr
, need_to_copy
);
93 if ( need_to_copy
> *value_length
)
98 need_to_read
= *value_length
- need_to_copy
;
100 read_length
= read(ptr
->hosts
[server_key
].fd
, pos_ptr
, need_to_read
);
101 if (read_length
!= need_to_read
)
104 *error
= MEMCACHED_PARTIAL_READ
;