30 #include <pcap/pcap.h>
32 #include <boost/endian/conversion.hpp>
39 const ethernet::Address& remoteEndpoint)
41 , m_pcap(localEndpoint.getName())
42 , m_srcAddress(localEndpoint.getEthernetAddress())
43 , m_destAddress(remoteEndpoint)
44 , m_interfaceName(localEndpoint.getName())
45 , m_hasRecentlyReceived(false)
55 NDN_THROW_NESTED(
Error(e.what()));
59 handleNetifStateChange(localEndpoint.getState());
61 m_netifStateChangedConn = localEndpoint.onStateChanged.connect(
62 [
this] (ndn::net::InterfaceState, ndn::net::InterfaceState newState) {
63 handleNetifStateChange(newState);
66 m_netifMtuChangedConn = localEndpoint.onMtuChanged.connect(
67 [
this] (uint32_t, uint32_t mtu) {
82 boost::system::error_code error;
96 EthernetTransport::handleNetifStateChange(ndn::net::InterfaceState netifState)
99 if (netifState == ndn::net::InterfaceState::RUNNING) {
110 EthernetTransport::doSend(
const Block& packet)
118 EthernetTransport::sendPacket(
const ndn::Block& block)
120 ndn::EncodingBuffer buffer(block);
123 if (block.size() < ethernet::MIN_DATA_LEN) {
124 static const uint8_t padding[ethernet::MIN_DATA_LEN] = {};
125 buffer.appendBytes(ndn::make_span(padding).subspan(block.size()));
129 uint16_t ethertype = boost::endian::native_to_big(ethernet::ETHERTYPE_NDN);
130 buffer.prependBytes({
reinterpret_cast<const uint8_t*
>(ðertype), ethernet::TYPE_LEN});
135 int sent = pcap_inject(
m_pcap, buffer.data(), buffer.size());
138 else if (
static_cast<size_t>(sent) < buffer.size())
139 handleError(
"Failed to send the full frame: size=" + to_string(buffer.size()) +
140 " sent=" + to_string(sent));
147 EthernetTransport::asyncRead()
149 m_socket.async_read_some(boost::asio::null_buffers(),
150 [
this] (
const auto& e,
auto) { this->handleRead(e); });
154 EthernetTransport::handleRead(
const boost::system::error_code& error)
159 if (error != boost::asio::error::operation_aborted &&
163 handleError(
"Receive operation failed: " + error.message());
179 ethernet::Address sender(eh->ether_shost);
180 pkt = pkt.subspan(ethernet::HDR_LEN);
187 if (nDropped - m_nDropped > 0)
189 m_nDropped = nDropped;
200 auto [isOk, element] = Block::fromBuffer(payload);
206 m_hasRecentlyReceived =
true;
212 EthernetTransport::handleError(
const std::string& errorMessage)
void receivePayload(span< const uint8_t > payload, const ethernet::Address &sender)
Processes the payload of an incoming frame.
void doClose() final
Performs Transport specific operations to close the transport.
boost::asio::posix::stream_descriptor m_socket
ethernet::Address m_srcAddress
ethernet::Address m_destAddress
EthernetTransport(const ndn::net::NetworkInterface &localEndpoint, const ethernet::Address &remoteEndpoint)
int getFd() const
Obtain a file descriptor that can be used in calls such as select(2) and poll(2).
std::string getLastError() const noexcept
Get last error message.
void activate(int dlt)
Start capturing packets.
size_t getNDropped() const
Get the number of packets dropped by the kernel, as reported by libpcap.
std::tuple< span< const uint8_t >, std::string > readNextPacket() const noexcept
Read the next packet captured on the interface.
void close() noexcept
Stop capturing and close the handle.
void receive(const Block &packet, const EndpointId &endpoint={})
Pass a received link-layer packet to the upper layer for further processing.
ndn::nfd::FacePersistency getPersistency() const noexcept
Returns the current persistency setting of the transport.
void setMtu(ssize_t mtu) noexcept
TransportState getState() const noexcept
Returns the current transport state.
void setState(TransportState newState)
Set transport state.
#define NFD_LOG_FACE_ERROR(msg)
Log a message at ERROR level.
#define NFD_LOG_FACE_DEBUG(msg)
Log a message at DEBUG level.
#define NFD_LOG_FACE_WARN(msg)
Log a message at WARN level.
#define NFD_LOG_FACE_TRACE(msg)
Log a message at TRACE level.
#define NFD_LOG_INIT(name)
std::tuple< const ether_header *, std::string > checkFrameHeader(span< const uint8_t > packet, const Address &localAddr, const Address &destAddr)
@ CLOSED
the transport is closed, and can be safely deallocated
@ CLOSING
the transport is being closed gracefully, either by the peer or by a call to close()
@ FAILED
the transport is being closed due to a failure
@ DOWN
the transport is temporarily down, and is being recovered
@ UP
the transport is up and can transmit packets
std::variant< std::monostate, ethernet::Address, udp::Endpoint > EndpointId
Identifies a remote endpoint on the link.
boost::asio::io_service & getGlobalIoService()
Returns the global io_service instance for the calling thread.