! * Attach orphan TCs to workers. Note this does not ensure optimal placement. * This method can only be called when all workers are paused. */

Returns the underlying buffer of reconstructed flow bytes. Not guaranteed to return the same pointer between calls to InsertPacket().

For testing.

Returns the length of contiguous data available in the buffer starting from the beginning. Updated every time InsertPacket() is called.

Displays to the user the details of a list of devices given in "dev_list". The "extra_params" parameter, if given, should contain a string wi

run protoc on *.proto in srcdir, with python output to outdir

CPU time (in seconds) spent by the current thread. * Use it only relatively. */

This function gets additional details for a PCI device

Return the configured limit, in resource units

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

* Dequeue one object from a ring (multi-consumers safe). * * This function uses a "compare and set" instruction to move the * consumer index atomic

Return the configured max burst, in resource units

Releases the held fd from ownership. Returns -1 if no fd is held.

Resets this instance and closes the fd held, if any.

Adds the given traffic class to those that are considered blocked.

Remove all rules from the table.

Generate a TCP RST packet

returns (0.0, 1.0] (note it includes 1.0) */

True if any worker attached to this module is running.

Applies the `len`-byte bitmask `mask` to `buf`, in 8-byte chunks if able, otherwise, falls back to 1-byte chunks.

Return the single hex digit representing `nibble`. If it cannot be represented, return the char 'X'.

If a derived Module overrides OnEvent and doesn't return -ENOTSUP for a particular Event `e` it will be invoked for each instance of the derived Modu

pthread_sigmask shouldn't return EINTR, but we can check.

* Internal function: sets O_NONBLOCK on a file descriptor. */

! * Starts the thread running. Will call the user provided Run() * once it's ready (unless the thread was already asked to exit). * * Ret

Returns true if the IP checksum is correct

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

Check for new events in the stream and cache them in __events. @param wait (bool): block until an event is available. @param

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

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

* @internal Enqueue several objects on a ring (NOT multi-producers safe). * * @param r * A pointer to the ring structure. * @param obj_table *

Return a module instance retaining just the right protobuf names, built by importing most of the *_msg_pb2.py files in the builtin_pb and plug