17 #ifndef DEFAULTOPERATIONTCPCHANNEL_HPP_
18 #define DEFAULTOPERATIONTCPCHANNEL_HPP_
27 #include <boost/asio.hpp>
57 virtual const std::string&
getId()
const {
return CHANNEL_ID; }
76 return SUPPORTED_TYPES;
84 failoverStrategy_ = strategy;
88 connectivityChecker_= checker;
91 void onReadEvent(
const boost::system::error_code& err);
105 static const std::uint16_t PING_TIMEOUT;
106 static const std::uint16_t CHANNEL_TIMEOUT;
107 static const std::uint16_t CONN_ACK_TIMEOUT;
108 static const std::uint16_t RECONNECT_TIMEOUT;
110 boost::system::error_code sendKaaSync(
const std::map<TransportType, ChannelDirection>& transportTypes);
111 boost::system::error_code sendConnect();
112 boost::system::error_code sendDisconnect();
113 boost::system::error_code sendPingRequest();
114 boost::system::error_code sendData(
const IKaaTcpRequest& request);
116 void readFromSocket();
118 void setConnAckTimer();
120 void createThreads();
125 static const std::string CHANNEL_ID;
126 static const std::map<TransportType, ChannelDirection> SUPPORTED_TYPES;
127 static const std::uint16_t TIMER_THREADPOOL_SIZE = 1;
128 static const std::uint16_t SOCKET_THREADPOOL_SIZE = 1;
129 static const std::uint32_t KAA_PLATFORM_PROTOCOL_AVRO_ID;
131 std::list<TransportType> ackTypes_;
134 boost::asio::io_service io_;
135 boost::asio::io_service socketIo_;
136 boost::asio::io_service::work work_;
137 boost::asio::io_service::work socketWork_;
139 std::unique_ptr<boost::asio::ip::tcp::socket> sock_;
140 boost::asio::deadline_timer pingTimer_;
141 boost::asio::deadline_timer connAckTimer_;
145 std::unique_ptr<boost::asio::streambuf> responseBuffer_;
146 std::array<std::thread, TIMER_THREADPOOL_SIZE> timerThreads_;
147 std::array<std::thread, SOCKET_THREADPOOL_SIZE> channelThreads_;
151 bool isFirstResponseReceived_;
152 bool isPendingSyncRequest_;
155 bool isFailoverInProgress_;
160 std::shared_ptr<IPTransportInfo> currentServer_;
162 std::unique_ptr<RsaEncoderDecoder> encDec_;
164 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, IKaaClientContext &context)
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)
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