X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fio.h;h=3662954ddc291e3ac310abf26403616390169e97;hb=49fc1e5ea4ea006f4a2ac71428833760f6fac030;hp=5530d146709989c5524e069293667c8f5f7b53c3;hpb=284978b1dc258cb8cd2a32d6a0f25f2f9b284149;p=m6w6%2Flibmemcached diff --git a/libmemcached/io.h b/libmemcached/io.h index 5530d146..3662954d 100644 --- a/libmemcached/io.h +++ b/libmemcached/io.h @@ -40,38 +40,52 @@ struct udp_datagram_header_st uint16_t reserved; }; +struct libmemcached_io_vector_st +{ + size_t length; + const void *buffer; +}; + +LIBMEMCACHED_LOCAL +memcached_return_t memcached_io_wait_for_write(memcached_server_write_instance_st ptr); + +LIBMEMCACHED_LOCAL +ssize_t memcached_io_writev(memcached_server_write_instance_st ptr, + const struct libmemcached_io_vector_st *vector, + size_t number_of, bool with_flush); + LIBMEMCACHED_LOCAL -ssize_t memcached_io_write(memcached_server_instance_st *ptr, - const void *buffer, size_t length, char with_flush); +ssize_t memcached_io_write(memcached_server_write_instance_st ptr, + const void *buffer, size_t length, bool with_flush); LIBMEMCACHED_LOCAL -void memcached_io_reset(memcached_server_instance_st *ptr); +void memcached_io_reset(memcached_server_write_instance_st ptr); LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_read(memcached_server_instance_st *ptr, +memcached_return_t memcached_io_read(memcached_server_write_instance_st ptr, void *buffer, size_t length, ssize_t *nread); /* Read a line (terminated by '\n') into the buffer */ LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_readline(memcached_server_instance_st *ptr, +memcached_return_t memcached_io_readline(memcached_server_write_instance_st ptr, char *buffer_ptr, size_t size); LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_close(memcached_server_instance_st *ptr); +memcached_return_t memcached_io_close(memcached_server_write_instance_st ptr); /* Read n bytes of data from the server and store them in dta */ LIBMEMCACHED_LOCAL -memcached_return_t memcached_safe_read(memcached_server_instance_st *ptr, +memcached_return_t memcached_safe_read(memcached_server_write_instance_st ptr, void *dta, size_t size); LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_init_udp_header(memcached_server_instance_st *ptr, +memcached_return_t memcached_io_init_udp_header(memcached_server_write_instance_st ptr, uint16_t thread_id); LIBMEMCACHED_LOCAL -memcached_server_instance_st *memcached_io_get_readable_server(memcached_st *memc); +memcached_server_write_instance_st memcached_io_get_readable_server(memcached_st *memc); #ifdef __cplusplus }