* Dequeue one object from a ring. * * This function calls the multi-consumers or the single-consumer * version depending on the default behaviour t

* Dequeue several objects from a ring (NOT multi-consumers safe).When the * request objects are more than the available objects, only dequeue the *

Runs a pipeline that injects data (input_pkts) at module src_module on input gate igate and collects it at module dst_module

Creates new gate hook from the given builder, initializes it, and adds it to the given gate. If any of these steps go wrong the gatehook instance is

Note: returns the exit status of the child, or 0 if no child.

! * Get any placement constraints that need to be met when receiving from this * port. */

returns [0.0, 1.0) */

! * Opens the fifo now, with a non-blocking open() call. * Returns 0 on success, or the reason the open failed, * e.g., -ENXIO if there is no reade

TODO(melvinw): add support for shifting at bit granularity Shifts `buf` to the left by `len` bytes and fills in with zeroes using std::memmove() and s

* Stops any opener thread. Once done, everything is back to the * way it was before an opener thread was started (or before * opening the FIFO dire

Returns the summary of the histogram. "percentiles" is a vector of doubles, whose values are in the range of [0.0, 100.0] and monotonically increasing

Returns true if the 'cksum' is correct for the 'len' bytes from 'buf'

Returns true if the IP checksum is correct

Returns true if the TCP checksum is correct with the TCP header and pseudo header info - source ip, destiniation ip, and tcp byte stream length tcp_le

Routine to wait a short while for opener.GetCurrentFd to return a valid fd. Needed since asynchronous threads are, well, asynchronous. Returns true

return true if a device is assigned to a driver. False otherwise

Returns a value in [0, range) as a function of an opaque number. * Also see utils/random.h */

Return the configured limit, in work units

* Test if a ring is empty. * * @param r * A pointer to the ring structure. * @return * - 1: The ring is empty. * - 0: The ring is not empt

* Enqueue several objects on the ring (multi-producers safe). * * This function uses a "compare and set" instruction to move the * producer index a

* Dequeue one object from a ring (NOT multi-consumers safe). * * @param r * A pointer to the ring structure. * @param obj_p * A pointer to a

Return the configured max burst, in work units

Returns the prefix length

Unbind the device identified by "dev_id" from its current driver

Note that the return type is uint32_t. You can add up increments from both ChecksumIncrement16() and ChecksumIncrement32()

Copy exactly "bytes" (<= 64). Works best if size is a compile-time constant.

Extract an ExactMatchKey from `buf` based on the fields that have been added to this table.

Only valid for memory blocks allocated by AllocHugepage() or DmaMemoryPool::Alloc()

Returns the root of the tree this class belongs to. Expensive in that it is recursive, so do not call from performance-sensitive code.

The entry point of worker threads */

TODO(melvinw): add support for shifting at bit granularity Shifts `buf` to the left by `len` bytes and fills in with zeroes. Will shift in 8-byte chun

TODO(melvinw): add support for shifting at bit granularity Shifts `buf` to the right by `len` bytes and fills in with zeroes. Will shift in 8-byte chu

Signals to parent task(s) that module is overloaded. TODO: SignalOverload and SignalUnderload are only safe if the module is not thread safe (e.g. mul

Signals to parent task(s) that module is underloaded.

* Requests that the thread, if started, terminate. Optionally * (but by default) waits for the thread to terminate. * * You may call this on