#include <asio_client.hpp>

Inheritance diagram for asio_client:

Collaboration diagram for asio_client:

Public Member Functions
	asio_client (std::string address, ana::port port)
	Standard constructor.
virtual	~asio_client ()
Private Member Functions
virtual void	connect (ana::connection_handler *)
virtual void	connect_through_proxy (std::string proxy_address, std::string proxy_port, ana::connection_handler *handler, std::string user_name="", std::string password="")
virtual void	run ()
virtual ana::operation_id	send (boost::asio::const_buffer, ana::send_handler *, ana::send_type)
virtual void	disconnect ()
	Disconnect the component.
virtual void	disconnect_listener ()
virtual void	handle_proxy_connection (const boost::system::error_code &, ana::connection_handler , ana::timer )
virtual tcp::socket &	socket ()
virtual void	log_receive (ana::read_buffer buffer)
virtual const ana::stats *	get_stats (ana::stat_type type) const
virtual ana::stats_collector &	stats_collector ()
	Get associated stats_collector object.
virtual ana::timer *	create_timer ()
virtual void	cancel_pending ()
virtual void	set_connect_timeout (size_t ms)
virtual void	expecting_message (size_t ms_until_timeout)
virtual std::string	ip_address () const
void	handle_connect (const boost::system::error_code &ec, tcp::resolver::iterator endpoint_iterator, ana::connection_handler , ana::timer )
void	inform_connection_result (ana::connection_handler *, ana::error_code)
void	handle_timeout (const boost::system::error_code &ec, ana::connection_handler , ana::timer )
ana::timer *	start_connection_timer (ana::connection_handler *)
	asio_client (const asio_client &other)
asio_client &	operator= (const asio_client &other)
Private Attributes
boost::asio::io_service	io_service_
std::list< boost::thread * >	io_threads_
boost::asio::io_service::work	work_
tcp::socket	socket_
std::string	address_
ana::port	port_
size_t	connect_timeout_ms_
proxy_connection *	proxy_
bool	use_proxy_
ana::stats_collector	stats_collector_
ana::operation_id	last_valid_operation_id_
boost::mutex	connection_informed_mutex_
bool	connection_informed_

Detailed Description

Definition at line 50 of file asio_client.hpp.

Constructor & Destructor Documentation

asio_client::asio_client	(	std::string	address,
		ana::port	port
	)

Standard constructor.

Parameters:

	address	: Address to try to connect to. The server should be there.
	port	: port to use for the connection. The server should have opened it.

Definition at line 44 of file asio_client.cpp.

asio_client::~asio_client ( ) [virtual]

Definition at line 62 of file asio_client.cpp.

References disconnect_listener(), and io_threads_.

Here is the call graph for this function:

asio_client::asio_client ( const asio_client & other ) [private]

Member Function Documentation

void asio_client::cancel_pending ( ) [private, virtual]

Definition at line 257 of file asio_client.cpp.

References socket_.

Referenced by handle_timeout().

Here is the caller graph for this function:

void asio_client::connect ( ana::connection_handler * handler ) [private, virtual]

Definition at line 183 of file asio_client.cpp.

References address_, error(), ana::generic_error, handle_connect(), inform_connection_result(), io_service_, port_, socket_, and start_connection_timer().

Here is the call graph for this function:

void asio_client::connect_through_proxy	(	std::string	proxy_address,
		std::string	proxy_port,
		ana::connection_handler *	handler,
		std::string	user_name = `""`,
		std::string	password = `""`
	)			`[private, virtual]`

Definition at line 205 of file asio_client.cpp.

References address_, proxy_connection::connect(), proxy_information::password, port_, proxy_, proxy_information::proxy_address, proxy_information::proxy_port, socket_, start_connection_timer(), use_proxy_, and proxy_information::user_name.

Here is the call graph for this function:

virtual ana::timer* asio_client::create_timer ( ) [inline, private, virtual]

Definition at line 98 of file asio_client.hpp.

References io_service_.

virtual void asio_client::disconnect ( ) [inline, private, virtual]

Disconnect the component.

Implements ana::detail::ana_component.

Definition at line 82 of file asio_client.hpp.

References disconnect_listener().

Here is the call graph for this function:

void asio_client::disconnect_listener ( ) [private, virtual]

Definition at line 277 of file asio_client.cpp.

References io_service_.

Referenced by disconnect(), and ~asio_client().

Here is the caller graph for this function:

void asio_client::expecting_message ( size_t ms_until_timeout ) [private, virtual]

Definition at line 267 of file asio_client.cpp.

References asio_listener::wait_for_incoming_message().

Here is the call graph for this function:

const ana::stats * asio_client::get_stats ( ana::stat_type type ) const [private, virtual]

Definition at line 247 of file asio_client.cpp.

References stats_collector_.

void asio_client::handle_connect	(	const boost::system::error_code &	ec,
		tcp::resolver::iterator	endpoint_iterator,
		ana::connection_handler *	handler,
		ana::timer *	timer
	)			`[private]`

Definition at line 107 of file asio_client.cpp.

References error(), ana::detail::ana_component::header_mode(), inform_connection_result(), asio_listener::run_listener(), and socket_.

Referenced by connect().

Here is the call graph for this function:

Here is the caller graph for this function:

void asio_client::handle_proxy_connection	(	const boost::system::error_code &	ec,
		ana::connection_handler *	handler,
		ana::timer *	timer
	)			`[private, virtual]`