#include <device.h>
Classes | |
struct | SFrame |
Public Types | |
typedef boost::signals2::signal< void(const boost::shared_ptr< Data > &)> | SIG_ON_FRAME |
Public Types inherited from Any_Session | |
typedef boost::signals2::signal< void(const char *data, const size_t size, Any_Session *writer)> | SIG_ON_DATA |
incoming data with "data" of size "size" and handler to write back ("writer") More... | |
Public Member Functions | |
bool | closeStream () |
bool & | debugFlag () |
bool | debugFlag () const |
SIG_ON_FRAME & | getSignal () |
void | on_data (const char *data, const size_t size, Any_Session *writer) |
bool | openStream () |
Streaming (boost::asio::io_service &io_service, const std::string &remote_device_ip) | |
Public Member Functions inherited from TCP_Session | |
virtual void | close () |
virtual bool | connect (const std::string &path, const std::string &service) |
virtual bool | connect (const boost::asio::ip::tcp::resolver::endpoint_type &ep) |
boost::asio::ip::tcp::socket & | socket () |
getter for socket connection More... | |
TCP_Session (boost::asio::io_service &io_service, SIG_ON_DATA &cb) | |
virtual | ~TCP_Session () |
Public Member Functions inherited from Any_Session | |
Any_Session (SIG_ON_DATA &cb) | |
every session needs a data handler More... | |
virtual | ~Any_Session () |
Private Attributes | |
SFrame::Ptr | cur_frame_ |
bool | debugOutput_ |
Any_Session::SIG_ON_DATA | on_data_ |
signal handler for incoming data More... | |
SIG_ON_FRAME | on_frame_ |
const std::string | remote_device_ip_ |
Additional Inherited Members | |
Protected Types inherited from TCP_Session | |
enum | { max_length = 4096 } |
Protected Member Functions inherited from TCP_Session | |
virtual void | write (const std::string &buffer) |
write async. to TCP socket (implement abstract) More... | |
virtual void | write (const std::vector< char > &buffer) |
virtual void | write (const boost::asio::mutable_buffers_1 &buffer) |
write async. to TCP socket More... | |
Protected Attributes inherited from TCP_Session | |
char | data_ [max_length] |
data buffer of max. length More... | |
boost::mutex | mtx_ |
lock operations More... | |
boost::asio::ip::tcp::socket | socket_ |
TCP socket. More... | |
Protected Attributes inherited from Any_Session | |
SIG_ON_DATA & | on_data_ |
signal handler for incoming data More... | |
typedef boost::signals2::signal<void (const boost::shared_ptr<Data> &)> Streaming::SIG_ON_FRAME |
|
inline |
|
inline |
|
inline |
|
private |
|
private |
|
private |