75 const std::string&
get_host(
void)
const;
90 void connect(
const std::string& host, std::uint32_t port, std::uint32_t timeout_msecs = 0);
97 void disconnect(
bool wait_for_removal =
false);
195 const std::shared_ptr<tacopie::io_service>&
get_io_service(
void)
const;
void connect(const std::string &host, std::uint32_t port, std::uint32_t timeout_msecs=0)
bool success
Definition: tcp_client.hpp:117
async_write_callback_t process_write(write_result &result)
void clear_write_requests(void)
std::function< void(write_result &)> async_write_callback_t
Definition: tcp_client.hpp:142
void disconnect(bool wait_for_removal=false)
void async_read(const read_request &request)
std::size_t size
Definition: tcp_client.hpp:151
Definition: tcp_socket.hpp:38
bool is_connected(void) const
const std::shared_ptr< tacopie::io_service > & get_io_service(void) const
tacopie::tcp_socket m_socket
Definition: tcp_client.hpp:271
void on_write_available(fd_t fd)
void set_on_disconnection_handler(const disconnection_handler_t &disconnection_handler)
void clear_read_requests(void)
void call_disconnection_handler(void)
Definition: tcp_client.hpp:116
std::uint32_t get_port(void) const
Definition: tcp_client.hpp:126
bool operator==(const tcp_client &rhs) const
tcp_client(std::uint32_t num_io_workers=1)
ctor & dtor
Definition: io_service.hpp:48
bool operator!=(const tcp_client &rhs) const
bool success
Definition: tcp_client.hpp:127
std::mutex m_write_requests_mtx
Definition: tcp_client.hpp:294
std::vector< char > buffer
Definition: tcp_client.hpp:161
std::function< void()> disconnection_handler_t
Definition: tcp_client.hpp:203
std::function< void(read_result &)> async_read_callback_t
Definition: tcp_client.hpp:136
std::atomic< bool > m_is_connected
Definition: tcp_client.hpp:276
Definition: tcp_client.hpp:150
Definition: tcp_client.hpp:37
async_read_callback_t async_read_callback
Definition: tcp_client.hpp:152
async_read_callback_t process_read(read_result &result)
std::mutex m_read_requests_mtx
Definition: tcp_client.hpp:290
tacopie::tcp_socket & get_socket(void)
std::vector< char > buffer
Definition: tcp_client.hpp:118
void async_write(const write_request &request)
disconnection_handler_t m_disconnection_handler
Definition: tcp_client.hpp:299
void on_read_available(fd_t fd)
const std::string & get_host(void) const
tcp_client & operator=(const tcp_client &)=delete
assignment operator
std::size_t size
Definition: tcp_client.hpp:128
Definition: tcp_client.hpp:160
std::queue< write_request > m_write_requests
Definition: tcp_client.hpp:285
int fd_t
file descriptor platform type
Definition: typedefs.hpp:36
async_write_callback_t async_write_callback
Definition: tcp_client.hpp:162
std::shared_ptr< io_service > m_io_service
Definition: tcp_client.hpp:266
std::queue< read_request > m_read_requests
Definition: tcp_client.hpp:281