|
| LigierDataHandler (boost::asio::io_service &service, std::string const &tag, boost::asio::ip::tcp::endpoint const &endpoint, char *buffer, std::size_t buffer_size, Consumer const &consumer) |
|
template<class Consumer>
class LigierDataHandler< Consumer >
Definition at line 183 of file clb_swiss_knife.cpp.
◆ this_type
◆ LigierDataHandler() [1/2]
◆ LigierDataHandler() [2/2]
template<class Consumer>
LigierDataHandler< Consumer >::LigierDataHandler |
( |
boost::asio::io_service & |
service, |
|
|
std::string const & |
tag, |
|
|
boost::asio::ip::tcp::endpoint const & |
endpoint, |
|
|
char * |
buffer, |
|
|
std::size_t |
buffer_size, |
|
|
Consumer const & |
consumer |
|
) |
| |
|
inline |
◆ data_handle()
template<class Consumer>
void LigierDataHandler< Consumer >::data_handle |
( |
boost::system::error_code const & |
error, |
|
|
std::size_t |
size |
|
) |
| |
|
inlineprivate |
Definition at line 198 of file clb_swiss_knife.cpp.
203 if (error && error != boost::asio::error::operation_aborted) {
206 }
else if (error == boost::asio::error::operation_aborted) {
210 boost::asio::async_read(
216 , boost::asio::placeholders::error
217 , boost::asio::placeholders::bytes_transferred
◆ timeout_handle()
template<class Consumer>
void LigierDataHandler< Consumer >::timeout_handle |
( |
boost::system::error_code const & |
error | ) |
|
|
inlineprivate |
◆ connect_handle()
template<class Consumer>
void LigierDataHandler< Consumer >::connect_handle |
( |
boost::system::error_code const & |
error | ) |
|
|
inlineprivate |
Definition at line 237 of file clb_swiss_knife.cpp.
239 if (error && error != boost::asio::error::operation_aborted) {
241 m_timer.expires_from_now(boost::posix_time::seconds(1));
247 , boost::asio::placeholders::error
250 }
else if (error == boost::asio::error::operation_aborted) {
254 boost::asio::async_write(
256 , boost::asio::buffer(
m_buffer, size)
260 , boost::asio::placeholders::error
261 , boost::asio::placeholders::bytes_transferred
◆ subscribe_handle()
template<class Consumer>
void LigierDataHandler< Consumer >::subscribe_handle |
( |
boost::system::error_code const & |
error, |
|
|
std::size_t |
bytes_transferred |
|
) |
| |
|
inlineprivate |
Definition at line 267 of file clb_swiss_knife.cpp.
271 if (error && error != boost::asio::error::operation_aborted) {
274 }
else if (error == boost::asio::error::operation_aborted) {
276 boost::asio::async_read(
282 , boost::asio::placeholders::error
283 , boost::asio::placeholders::bytes_transferred
◆ header_handle()
template<class Consumer>
void LigierDataHandler< Consumer >::header_handle |
( |
boost::system::error_code const & |
error, |
|
|
std::size_t |
bytes_transferred |
|
) |
| |
|
inlineprivate |
Definition at line 289 of file clb_swiss_knife.cpp.
293 if (error && error != boost::asio::error::operation_aborted) {
296 }
else if (error == boost::asio::error::operation_aborted) {
300 boost::asio::async_read(
302 , boost::asio::buffer(
m_buffer + 16, size)
306 , boost::asio::placeholders::error
307 , boost::asio::placeholders::bytes_transferred
◆ restart()
Definition at line 313 of file clb_swiss_knife.cpp.
315 boost::system::error_code ec;
317 m_socket.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ec);
325 , boost::asio::placeholders::error
◆ operator=()
◆ m_socket
◆ m_timer
◆ m_tag
◆ m_endpoint
◆ m_buffer
◆ m_buffer_size
◆ m_consumer
The documentation for this class was generated from the following file: