X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=lib%2Fmemcached_delete.c;h=0c36aaebb172b40fcb6c8ed643b109db02aed602;hb=5845b33395414c577e0d88cc13a011db55cffa02;hp=0ed6092a03f0b8114e003ea31d22149d467e9bcc;hpb=131622cdc2710ecd9ad554ce7d08c6003fbdcf6e;p=awesomized%2Flibmemcached diff --git a/lib/memcached_delete.c b/lib/memcached_delete.c index 0ed6092a..0c36aaeb 100644 --- a/lib/memcached_delete.c +++ b/lib/memcached_delete.c @@ -4,22 +4,21 @@ memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_lengt time_t expiration) { char to_write; - size_t send_length, sent_length; + size_t send_length; memcached_return rc; char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE]; unsigned int server_key; LIBMEMCACHED_MEMCACHED_DELETE_START(); + if (key_length == 0) + return MEMCACHED_NO_KEY_PROVIDED; + if (ptr->hosts == NULL || ptr->number_of_hosts == 0) return MEMCACHED_NO_SERVERS; server_key= memcached_generate_hash(ptr, key, key_length); - if ((rc= memcached_connect(ptr, server_key)) != MEMCACHED_SUCCESS) - return rc; - - if (expiration) send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, "delete %.*s %llu\r\n", (int)key_length, key, @@ -39,12 +38,9 @@ memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_lengt else to_write= 1; - if ((sent_length= memcached_io_write(ptr, server_key, buffer, send_length, to_write)) == -1) - { - memcached_quit_server(ptr, server_key); - rc= MEMCACHED_WRITE_FAILURE; + rc= memcached_do(ptr, server_key, buffer, send_length, to_write); + if (rc != MEMCACHED_SUCCESS) goto error; - } if ((ptr->flags & MEM_NO_BLOCK)) { @@ -58,8 +54,7 @@ memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_lengt rc= MEMCACHED_SUCCESS; } - LIBMEMCACHED_MEMCACHED_DELETE_END(); - error: + LIBMEMCACHED_MEMCACHED_DELETE_END(); return rc; }