17 #ifndef DEFAULTOPERATIONTCPCHANNEL_HPP_
18 #define DEFAULTOPERATIONTCPCHANNEL_HPP_
27 #include <boost/asio.hpp>
56 virtual const std::string&
getId()
const {
return CHANNEL_ID; }
75 return SUPPORTED_TYPES;
83 failoverStrategy_ = strategy;
87 connectivityChecker_= checker;
90 void onReadEvent(
const boost::system::error_code& err);
104 static const std::uint16_t PING_TIMEOUT;
105 static const std::uint16_t CONN_ACK_TIMEOUT;
106 static const std::uint16_t RECONNECT_TIMEOUT;
108 boost::system::error_code sendKaaSync(
const std::map<TransportType, ChannelDirection>& transportTypes);
109 boost::system::error_code sendConnect();
110 boost::system::error_code sendDisconnect();
111 boost::system::error_code sendPingRequest();
112 boost::system::error_code sendData(
const IKaaTcpRequest& request);
114 void readFromSocket();
116 void setConnAckTimer();
118 void createThreads();
123 static const std::string CHANNEL_ID;
124 static const std::map<TransportType, ChannelDirection> SUPPORTED_TYPES;
125 static const std::uint16_t TIMER_THREADPOOL_SIZE = 1;
126 static const std::uint16_t SOCKET_THREADPOOL_SIZE = 1;
127 static const std::uint32_t KAA_PLATFORM_PROTOCOL_AVRO_ID;
129 std::list<TransportType> ackTypes_;
132 boost::asio::io_service io_;
133 boost::asio::io_service socketIo_;
134 boost::asio::io_service::work work_;
135 boost::asio::io_service::work socketWork_;
137 std::unique_ptr<boost::asio::ip::tcp::socket> sock_;
138 boost::asio::deadline_timer pingTimer_;
139 boost::asio::deadline_timer connAckTimer_;
143 std::unique_ptr<boost::asio::streambuf> responseBuffer_;
144 std::array<std::thread, TIMER_THREADPOOL_SIZE> timerThreads_;
145 std::array<std::thread, SOCKET_THREADPOOL_SIZE> channelThreads_;
149 bool isFirstResponseReceived_;
150 bool isPendingSyncRequest_;
153 bool isFailoverInProgress_;
158 std::shared_ptr<IPTransportInfo> currentServer_;
160 std::unique_ptr<RsaEncoderDecoder> encDec_;
162 KAA_MUTEX_DECLARE(channelGuard_);
void onConnack(const ConnackMessage &message)
std::shared_ptr< IConnectivityChecker > ConnectivityCheckerPtr
std::shared_ptr< IFailoverStrategy > IFailoverStrategyPtr
virtual void setMultiplexer(IKaaDataMultiplexer *multiplexer)
virtual void setServer(ITransportConnectionInfoPtr server)
DefaultOperationTcpChannel(IKaaChannelManager *channelManager, const KeyPair &clientKeys, IKaaClientStateStoragePtr clientState)
virtual void syncAck(TransportType type)
static const TransportProtocolId TCP_TRANSPORT_ID
virtual void setConnectivityChecker(ConnectivityCheckerPtr checker)
virtual ServerType getServerType() const
virtual ITransportConnectionInfoPtr getServer()
virtual const std::string & getId() const
virtual void setDemultiplexer(IKaaDataDemultiplexer *demultiplexer)
virtual void setFailoverStrategy(IFailoverStrategyPtr strategy)
void onReadEvent(const boost::system::error_code &err)
std::shared_ptr< IKaaClientStateStorage > IKaaClientStateStoragePtr
virtual const std::map< TransportType, ChannelDirection > & getSupportedTransportTypes() const
void onPingTimeout(const boost::system::error_code &err)
virtual TransportProtocolId getTransportProtocolId() const
virtual void sync(TransportType type)
virtual ~DefaultOperationTcpChannel()
void onDisconnect(const DisconnectMessage &message)
void onConnAckTimeout(const boost::system::error_code &err)
void onKaaSync(const KaaSyncResponse &message)
std::shared_ptr< ITransportConnectionInfo > ITransportConnectionInfoPtr