Class NlxPureReader

• Defined in File nlxpurereader.hpp

Inheritance Relationships

Base Type

• public IProcessor

Class Documentation

class NlxPureReader : public IProcessor

Public Functions

NlxPureReader()

void CreatePorts() override

void CompleteStreamInfo() override

void Prepare(GlobalContext &context) override

void Preprocess(ProcessingContext &context) override

void Process(ProcessingContext &context) override

void Postprocess(ProcessingContext &context) override

Public Members

decltype(timeout_.tv_sec) const TIMEOUT_SEC = 3

Protected Attributes

PortOut<VectorType<uint32_t>> *output_port_

BroadcasterState<uint64_t> *n_invalid_

fd_set file_descriptor_set_

int udp_socket_

int udp_socket_select_

struct sockaddr_in server_addr_

uint64_t valid_packet_counter_

struct timeval timeout_

TimePoint first_valid_packet_arrival_time_

ssize_t size_

int recvlen_

VectorType<uint32_t>::Data *data_out_

options::String address_ = {"127.0.0.1"}

options::Value<unsigned int, false> port_ = {5000}

options::Value<std::uint64_t, false> npackets_{0, options::zeroismax<std::uint64_t>()}

options::Value<unsigned int, false> nchannels_ = {nlx::NLX_DEFAULT_NCHANNELS}