Class OpenEphysZMQ¶
Defined in File openephysZMQ.hpp
Inheritance Relationships¶
Base Type¶
public IProcessor
Class Documentation¶
-
class OpenEphysZMQ : public IProcessor¶
Public Functions
-
OpenEphysZMQ()¶
-
void Preprocess(ProcessingContext &context) override¶
-
void CreatePorts() override¶
-
void CompleteStreamInfo() override¶
-
void Process(ProcessingContext &context) override¶
-
void Postprocess(ProcessingContext &context) override¶
Protected Attributes
-
options::String address_ = {"127.0.0.1", options::notempty<std::string>()}¶
-
options::Value<unsigned int, false> port_ = {5556, options::positive<unsigned int>(true)}¶
-
options::Value<std::uint64_t, false> npackets_ = {0, options::zeroismax<std::uint64_t>()}¶
-
options::Value<unsigned int, false> batch_size_ = {1}¶
-
options::Value<unsigned int, false> nchannels_ = {384, options::positive<unsigned int>(true)}¶
-
PortOut<MultiChannelType<double>> *data_port_¶
-
zmq::socket_t socket_¶
-
uint64_t last_message_number_¶
-
uint64_t missing_packets_counter_¶
-
uint64_t valid_packets_counter_¶
-
uint64_t invalid_packets_counter_¶
-
TimePoint first_valid_packet_arrival_time_¶
-
flatbuffers::FlatBufferBuilder flatbuilder_¶
-
openephysflatbuffer::ContinuousDataBuilder builder_¶
-
OpenEphysZMQ()¶