X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=lib%2Fmemcached_delete.c;h=5ec5d1b4c11d353a52857ae25a9037193cd5260c;hb=151506dd4b5da014f23438226ee286772a78dfd3;hp=b50aaef0f9be5c7fdb4c459d0ee79b31f0c3f22d;hpb=452f5b545eec58ac1bddd32ea131b79e2b1a52a9;p=m6w6%2Flibmemcached diff --git a/lib/memcached_delete.c b/lib/memcached_delete.c index b50aaef0..5ec5d1b4 100644 --- a/lib/memcached_delete.c +++ b/lib/memcached_delete.c @@ -1,4 +1,4 @@ -#include +#include "common.h" memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_length, time_t expiration) @@ -8,6 +8,8 @@ memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_lengt char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE]; unsigned int server_key; + LIBMEMCACHED_MEMCACHED_DELETE_START(); + rc= memcached_connect(ptr); if (rc != MEMCACHED_SUCCESS) @@ -26,10 +28,13 @@ memcached_return memcached_delete(memcached_st *ptr, char *key, size_t key_lengt if (send_length >= MEMCACHED_DEFAULT_COMMAND_SIZE) return MEMCACHED_WRITE_FAILURE; - sent_length= write(ptr->hosts[server_key].fd, buffer, send_length); + sent_length= send(ptr->hosts[server_key].fd, buffer, send_length, 0); if (sent_length == -1 || sent_length != send_length) return MEMCACHED_WRITE_FAILURE; - return memcached_response(ptr, buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, server_key); + rc= memcached_response(ptr, buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, server_key); + LIBMEMCACHED_MEMCACHED_DELETE_END(); + + return rc; }