tcpdatatransport.hpp

Go to the documentation of this file.

 
#ifndef LOGICALACCESS_TCPDATATRANSPORT_HPP
#define LOGICALACCESS_TCPDATATRANSPORT_HPP
 
#include <logicalaccess/readerproviders/datatransport.hpp>
#include <boost/asio.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/asio/ip/tcp.hpp>
 
namespace logicalaccess
{
#define TRANSPORT_TCP "TCP"
 
class LLA_CORE_API TCPDataTransport : public DataTransport
{
  public:
    TCPDataTransport();
 
    virtual ~TCPDataTransport();
 
    std::string getTransportType() const override
    {
        return TRANSPORT_TCP;
    }
 
    bool connect() override;
 
    virtual bool connect(long int timeout);
 
    void disconnect() override;
 
    bool isConnected() override;
 
    std::string getName() const override;
 
    void serialize(boost::property_tree::ptree &parentNode) override;
 
    void unSerialize(boost::property_tree::ptree &node) override;
 
    std::string getDefaultXmlNodeName() const override;
 
    std::string getIpAddress() const;
 
    void setIpAddress(std::string ipAddress);
 
    int getPort() const;
 
    void setPort(int port);
 
    void send(const ByteVector &data) override;
 
    ByteVector receive(long int timeout) override;
 
    void connect_complete(const boost::system::error_code &error);
 
    void read_complete(const boost::system::error_code &error, size_t bytes_transferred);
 
    void time_out(const boost::system::error_code &error);
 
  protected:
    boost::asio::io_service d_ios;
 
    boost::asio::ip::tcp::socket d_socket;
 
    boost::asio::deadline_timer d_timer;
 
    bool d_read_error;
 
    size_t d_bytes_transferred;
 
    std::string d_ipAddress;
 
    int d_port;
};
}
 
#endif /* LOGICALACCESS_TCPDATATRANSPORT_HPP */