X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fio.hpp;h=5480239f25e51313fab892b17f8ebd60f470737e;hb=585b2385384b32af964b5f2f999e70173b33a460;hp=ce9cef5122267c755fbdff75d1f3485bce46453b;hpb=146cc15e812ae3d737b1cc49d56cfdbaaf915440;p=awesomized%2Flibmemcached diff --git a/libmemcached/io.hpp b/libmemcached/io.hpp index ce9cef51..5480239f 100644 --- a/libmemcached/io.hpp +++ b/libmemcached/io.hpp @@ -38,35 +38,36 @@ #pragma once -bool memcached_io_write(memcached_server_write_instance_st ptr); +void initialize_binary_request(memcached_instance_st* server, protocol_binary_request_header&); -ssize_t memcached_io_write(memcached_server_write_instance_st ptr, +bool memcached_io_write(memcached_instance_st* ptr); + +ssize_t memcached_io_write(memcached_instance_st* ptr, const void *buffer, size_t length, bool with_flush); -bool memcached_io_writev(memcached_server_write_instance_st ptr, +bool memcached_io_writev(memcached_instance_st* ptr, libmemcached_io_vector_st vector[], const size_t number_of, const bool with_flush); -memcached_return_t memcached_io_wait_for_write(memcached_server_write_instance_st ptr); +memcached_return_t memcached_io_wait_for_write(memcached_instance_st*); +memcached_return_t memcached_io_wait_for_read(memcached_instance_st*); -void memcached_io_reset(memcached_server_write_instance_st ptr); +void memcached_io_reset(memcached_instance_st* ptr); -memcached_return_t memcached_io_read(memcached_server_write_instance_st ptr, +memcached_return_t memcached_io_read(memcached_instance_st* ptr, void *buffer, size_t length, ssize_t& nread); /* Read a line (terminated by '\n') into the buffer */ -memcached_return_t memcached_io_readline(memcached_server_write_instance_st ptr, +memcached_return_t memcached_io_readline(memcached_instance_st* ptr, char *buffer_ptr, size_t size, size_t& total); -void memcached_io_close(memcached_server_write_instance_st ptr); - /* Read n bytes of data from the server and store them in dta */ -memcached_return_t memcached_safe_read(memcached_server_write_instance_st ptr, +memcached_return_t memcached_safe_read(memcached_instance_st* ptr, void *dta, const size_t size); -memcached_server_write_instance_st memcached_io_get_readable_server(memcached_st *memc); +memcached_instance_st* memcached_io_get_readable_server(memcached_st *memc, memcached_return_t&); -memcached_return_t memcached_io_slurp(memcached_server_write_instance_st ptr); +memcached_return_t memcached_io_slurp(memcached_instance_st* ptr);