dunedaq::dpdklibs::sender Namespace Reference

Classes
class	BufGuard
class	CallbackGate
struct	DpdkTxBackend
class	WIBEthTransmitter

Enumerations
enum class	TxOutcome { kSent , kAllocFailed , kPrepareFailed , kTxFailed }

Functions
template<typename Backend, typename BuildFn, typename OnSentFn>
TxOutcome	send_packet (Backend &backend, std::size_t packet_bytes, std::uint8_t *pre_tx_copy, BuildFn &&build, OnSentFn &&on_sent)

Enumeration Type Documentation

TxOutcome

enum class dunedaq::dpdklibs::sender::TxOutcome

strong

Enumerator
kSent
kAllocFailed
kPrepareFailed
kTxFailed

Definition at line 40 of file TxEngine.hpp.

{
  kSent,          // backend took ownership of the buffer
  kAllocFailed,   // no buffer was available
  kPrepareFailed, // append rejected: insufficient tailroom
  kTxFailed       // backend refused the packet; buffer freed
};

Function Documentation

send_packet()

template<typename Backend, typename BuildFn, typename OnSentFn>

TxOutcome dunedaq::dpdklibs::sender::send_packet	(	Backend &	backend,
		std::size_t	packet_bytes,
		std::uint8_t *	pre_tx_copy,
		BuildFn &&	build,
		OnSentFn &&	on_sent )

Definition at line 84 of file TxEngine.hpp.

{
  void* buf = backend.alloc();
  if (buf == nullptr) {
    return TxOutcome::kAllocFailed;
  }
  BufGuard<Backend> guard(backend, buf);
 
  std::uint8_t* dst = backend.prepare(buf, packet_bytes);
  if (dst == nullptr) {
    return TxOutcome::kPrepareFailed;
  }
 
  build(dst);
  if (pre_tx_copy != nullptr) {
    std::memcpy(pre_tx_copy, dst, packet_bytes);
  }
 
  if (!backend.transmit(buf)) {
    return TxOutcome::kTxFailed;
  }
 
  guard.release();
  on_sent();
  return TxOutcome::kSent;
}