X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=libmemcached%2Fio.h;h=3014582341bfcef525c3d2f738c9e8a415890d8a;hb=ea260e7bce23c9a41c3c60fd68f55b33608714a9;hp=df7708c846c20461ceef81519f16a3e59b0d7df6;hpb=55b5455291498ef63c1c34976552d58708a74732;p=m6w6%2Flibmemcached diff --git a/libmemcached/io.h b/libmemcached/io.h index df7708c8..30145823 100644 --- a/libmemcached/io.h +++ b/libmemcached/io.h @@ -9,17 +9,17 @@ * */ -#ifndef LIBMEMCACHED_MEMCACHED_IO_H -#define LIBMEMCACHED_MEMCACHED_IO_H - -#ifdef __cplusplus -extern "C" { -#endif +#ifndef __LIBMEMCACHED_IO_H__ +#define __LIBMEMCACHED_IO_H__ #if defined(BUILDING_LIBMEMCACHED) #include "libmemcached/memcached.h" +#ifdef __cplusplus +extern "C" { +#endif + #define MAX_UDP_DATAGRAM_LENGTH 1400 #define UDP_DATAGRAM_HEADER_LENGTH 8 #define UDP_REQUEST_ID_MSG_SIG_DIGITS 10 @@ -40,43 +40,54 @@ struct udp_datagram_header_st uint16_t reserved; }; +struct __write_vector_st +{ + size_t length; + const void *buffer; +}; + +LIBMEMCACHED_LOCAL +ssize_t memcached_io_writev(memcached_server_write_instance_st ptr, + const struct __write_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); - -#endif /* BUILDING_LIBMEMCACHED */ +memcached_server_write_instance_st memcached_io_get_readable_server(memcached_st *memc); #ifdef __cplusplus } #endif -#endif /* LIBMEMCACHED_MEMCACHED_IO_H */ +#endif /* BUILDING_LIBMEMCACHED */ + +#endif /* __LIBMEMCACHED_IO_H__ */