bridge-transport.hpp

Go to the documentation of this file.

#ifndef NDNPH_FACE_BRIDGE_TRANSPORT_HPP
#define NDNPH_FACE_BRIDGE_TRANSPORT_HPP
 
#include "transport-rxqueue.hpp"
 
namespace ndnph {
 
class BridgeTransport
  : public virtual Transport
  , public transport::DynamicRxQueueMixin {
public:
  using transport::DynamicRxQueueMixin::DynamicRxQueueMixin;
 
  bool begin(BridgeTransport& peer) {
    if (m_peer != nullptr || peer.m_peer != nullptr) {
      return false;
    }
    m_peer = &peer;
    peer.m_peer = this;
    return true;
  }
  bool begin(BridgeTransport& peer) {…}
 
  bool end() {
    if (m_peer == nullptr || m_peer->m_peer != this) {
      return false;
    }
    m_peer->m_peer = nullptr;
    m_peer = nullptr;
    return true;
  }
  bool end() {…}
 
private:
  bool doIsUp() const final {
    return m_peer != nullptr;
  }
  bool doIsUp() const final {…}
 
  void doLoop() final {
    this->loopRxQueue();
  }
  void doLoop() final {…}
 
  bool doSend(const uint8_t* pkt, size_t pktLen, uint64_t endpointId) final {
    if (m_peer == nullptr) {
      return false;
    }
    if (auto r = m_peer->receiving()) {
      if (r.bufLen() < pktLen) {
        return false;
      }
      std::copy_n(pkt, pktLen, r.buf());
      r(pktLen, endpointId);
      return true;
    }
    return false;
  }
  bool doSend(const uint8_t* pkt, size_t pktLen, uint64_t endpointId) final {…}
 
private:
  BridgeTransport* m_peer = nullptr;
};
class BridgeTransport {…};
 
} // namespace ndnph
 
#endif // NDNPH_FACE_BRIDGE_TRANSPORT_HPP