22 #ifndef NDN_TRANSPORT_DETAIL_STREAM_TRANSPORT_IMPL_HPP 23 #define NDN_TRANSPORT_DETAIL_STREAM_TRANSPORT_IMPL_HPP 27 #include <boost/asio/deadline_timer.hpp> 28 #include <boost/asio/write.hpp> 40 template<
typename BaseTransport,
typename Protocol>
41 class StreamTransportImpl :
public std::enable_shared_from_this<StreamTransportImpl<BaseTransport, Protocol>>
58 connect(
const typename Protocol::endpoint& endpoint)
78 boost::system::error_code error;
116 BlockSequence sequence;
117 sequence.push_back(wire);
118 send(std::move(sequence));
124 BlockSequence sequence;
125 sequence.push_back(header);
126 sequence.push_back(payload);
127 send(std::move(sequence));
148 BOOST_THROW_EXCEPTION(
Transport::Error(error,
"error while connecting to the forwarder"));
159 BOOST_THROW_EXCEPTION(
Transport::Error(error,
"error while connecting to the forwarder"));
184 handleAsyncWrite(
const boost::system::error_code& error, TransmissionQueue::iterator queueItem)
187 if (error == boost::system::errc::operation_canceled) {
193 BOOST_THROW_EXCEPTION(
Transport::Error(error,
"error while sending data to socket"));
219 if (error == boost::system::errc::operation_canceled) {
225 BOOST_THROW_EXCEPTION(
Transport::Error(error,
"error while receiving data from socket"));
231 std::size_t offset = 0;
236 "input buffer full, but a valid TLV cannot be " 256 while (offset < nBytesAvailable) {
259 std::tie(isOk, element) =
Block::fromBuffer(buffer + offset, nBytesAvailable - offset);
264 offset += element.
size();
285 #endif // NDN_TRANSPORT_DETAIL_STREAM_TRANSPORT_IMPL_HPP
void connectHandler(const boost::system::error_code &error)
static std::tuple< bool, Block > fromBuffer(ConstBufferPtr buffer, size_t offset)
Try to parse Block from a wire buffer.
void handleAsyncWrite(const boost::system::error_code &error, TransmissionQueue::iterator queueItem)
StreamTransportImpl(BaseTransport &transport, boost::asio::io_service &ioService)
void send(const Block &header, const Block &payload)
std::list< Block > BlockSequence
std::list< BlockSequence > TransmissionQueue
Represents a TLV element of NDN packet format.
Implementation detail of a Boost.Asio-based stream-oriented transport.
void send(BlockSequence &&sequence)
size_t size() const
Get size of encoded wire, including Type-Length-Value.
Protocol::socket m_socket
void handleAsyncReceive(const boost::system::error_code &error, std::size_t nBytesRecvd)
void send(const Block &wire)
void connectTimeoutHandler(const boost::system::error_code &error)
uint8_t m_inputBuffer[MAX_NDN_PACKET_SIZE]
boost::asio::deadline_timer m_connectTimer
TransmissionQueue m_transmissionQueue
bool processAllReceived(uint8_t *buffer, size_t &offset, size_t nBytesAvailable)
BaseTransport & m_transport
const size_t MAX_NDN_PACKET_SIZE
practical limit of network layer packet size
void connect(const typename Protocol::endpoint &endpoint)
StreamTransportImpl< BaseTransport, Protocol > Impl