X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fio.hpp;h=5625ce94492134ea628a1a39b63dba64ca943774;hb=eff4858179d7883b92ab8682392357d104d5a8ab;hp=23a4a6b412109812d1f761c9db4b5fe3442c5d5a;hpb=191f8532ea251eabbcb56bc71bee2184a3ad971f;p=m6w6%2Flibmemcached diff --git a/libmemcached/io.hpp b/libmemcached/io.hpp index 23a4a6b4..5625ce94 100644 --- a/libmemcached/io.hpp +++ b/libmemcached/io.hpp @@ -38,38 +38,37 @@ #pragma once -LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_wait_for_write(memcached_server_write_instance_st ptr); +void initialize_binary_request(org::libmemcached::Instance* server, protocol_binary_request_header&); -LIBMEMCACHED_LOCAL -void memcached_io_reset(memcached_server_write_instance_st ptr); +bool memcached_io_write(org::libmemcached::Instance* ptr); -LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_read(memcached_server_write_instance_st ptr, - void *buffer, size_t length, ssize_t *nread); +ssize_t memcached_io_write(org::libmemcached::Instance* ptr, + const void *buffer, size_t length, bool with_flush); + +bool memcached_io_writev(org::libmemcached::Instance* ptr, + libmemcached_io_vector_st vector[], + const size_t number_of, const bool with_flush); + +memcached_return_t memcached_io_wait_for_write(org::libmemcached::Instance* ptr); + +void memcached_io_reset(org::libmemcached::Instance* ptr); + +memcached_return_t memcached_io_read(org::libmemcached::Instance* 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_write_instance_st ptr, +memcached_return_t memcached_io_readline(org::libmemcached::Instance* ptr, char *buffer_ptr, size_t size, size_t& total); -LIBMEMCACHED_LOCAL -void memcached_io_close(memcached_server_write_instance_st ptr); +void memcached_io_close(org::libmemcached::Instance* ptr); /* Read n bytes of data from the server and store them in dta */ -LIBMEMCACHED_LOCAL -memcached_return_t memcached_safe_read(memcached_server_write_instance_st ptr, +memcached_return_t memcached_safe_read(org::libmemcached::Instance* ptr, void *dta, - size_t size); - -LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_init_udp_header(memcached_server_write_instance_st ptr, - uint16_t thread_id); + const size_t size); -LIBMEMCACHED_LOCAL -memcached_server_write_instance_st memcached_io_get_readable_server(memcached_st *memc); +org::libmemcached::Instance* memcached_io_get_readable_server(memcached_st *memc); -LIBMEMCACHED_LOCAL -memcached_return_t memcached_io_slurp(memcached_server_write_instance_st ptr); +memcached_return_t memcached_io_slurp(org::libmemcached::Instance* ptr);