EventFilter Class Reference

Public Member Functions
void	CreatePorts () override
void	Prepare (GlobalContext &context) override
void	Preprocess (ProcessingContext &context) override
void	Process (ProcessingContext &context) override
void	Postprocess (ProcessingContext &context) override
Public Member Functions inherited from EventSync
void	CreatePorts () override
void	Process (ProcessingContext &context) override
void	Postprocess (ProcessingContext &context) override
Public Member Functions inherited from IProcessor
	IProcessor (ThreadPriority priority=PRIORITY_HIGH)
void	record_metrics (uint64_t sync, uint64_t work) noexcept
void	dump_benchmarks ()
const std::string	name () const
const std::string	type () const
unsigned int	n_input_ports () const
unsigned int	n_output_ports () const
const std::set< std::string >	input_port_names () const
const std::set< std::string >	output_port_names () const
bool	has_input_port (const std::string &port)
bool	has_output_port (const std::string &port)
virtual bool	issource () const
virtual bool	issink () const
virtual bool	isfilter () const
virtual bool	isautonomous () const
ThreadPriority	thread_priority () const
ThreadCore	thread_core () const
bool	running () const
YAML::Node	ExportYAML ()
void	checkNonvoluntaryContextSwitches ()

Protected Member Functions
std::tuple< bool, bool, std::size_t >	is_there_target (PortIn< EventType > *input_port, EventCounter &event_counter, std::vector< TimePoint > &arrival_times, std::vector< uint64_t > &arrival_timestamps)
double	time_between (TimePoint t2, TimePoint t1)
double	time_since (TimePoint t)
Protected Member Functions inherited from EventSync
void	update_latest_ts (EventType::Data *data_in)
void	log_and_reset_counters (std::string port_name, EventCounter &counter)
Protected Member Functions inherited from IProcessor
void	create_file (const std::string &prefix, const std::string &variable_name, const std::string &extension="bin")
void	prepare_latency_test (ProcessingContext &context)
void	save_source_timestamps_to_disk (std::uint64_t n_timestamps)
template<typename TValue>
void	add_option (std::string name, TValue &value, std::string description="", bool required=false)
void	remove_option (const std::string &name)
template<typename DATATYPE>
PortOut< DATATYPE > *	create_output_port (std::string name, const typename DATATYPE::Parameters &parameters, const PortOutPolicy &policy)
template<typename DATATYPE>
PortOut< DATATYPE > *	create_output_port (const typename DATATYPE::Parameters &parameters, const PortOutPolicy &policy)
template<typename DATATYPE>
PortIn< DATATYPE > *	create_input_port (std::string name, const typename DATATYPE::Capabilities &capabilities, const PortInPolicy &policy)
template<typename DATATYPE>
PortIn< DATATYPE > *	create_input_port (const typename DATATYPE::Capabilities &capabilities, const PortInPolicy &policy)
IPortIn *	input_port (const std::string &port)
IPortOut *	output_port (const std::string &port)
IPortIn *	input_port (const PortAddress &address)
IPortOut *	output_port (const PortAddress &address)
ISlotIn *	input_slot (const SlotAddress &address)
ISlotOut *	output_slot (const SlotAddress &address)
template<typename T>
StaticState< T > *	create_static_state (std::string state, T default_value, bool shared=true, Permission external=Permission::WRITE, std::string description="")
template<typename T>
ProducerState< T > *	create_producer_state (std::string state, T default_value, bool cooperative=false, Permission external=Permission::READ, std::string description="")
template<typename T>
BroadcasterState< T > *	create_broadcaster_state (std::string state, T default_value, Permission external=Permission::NONE, std::string description="")
template<typename T>
FollowerState< T > *	create_follower_state (std::string state, T default_value, Permission external=Permission::NONE, std::string description="")
template<typename T>
ReadableState< T > *	create_readable_shared_state (const std::string &state, T default_value, Permission peers=Permission::WRITE, Permission external=Permission::NONE, std::string description="")
template<typename T>
WritableState< T > *	create_writable_shared_state (const std::string &state, T default_value, Permission peers=Permission::READ, Permission external=Permission::NONE, std::string description="")
std::shared_ptr< IState >	shared_state (const std::string &state)
template<class T>
void	expose_method (const std::string &methodname, YAML::Node(T::*method)(const YAML::Node &))
std::function< YAML::Node(const YAML::Node &)> &	exposed_method (const std::string &method)
virtual std::string	default_input_port () const
virtual std::string	default_output_port () const

Protected Attributes
PortIn< EventType > *	block_in_port_
unsigned int	n_blocked_events_
EventCounter	blocking_events_counter_
TimePoint	gate_close_time_
std::chrono::duration< double, std::milli >	duration
const uint64_t	NULL_TIMESTAMP = std::numeric_limits<uint64_t>::max()
options::Measurement< double, false >	blockout_time_ {10., "ms", options::positive<double>()}
options::Measurement< double, false >	block_wait_time_ {1.5, "ms", options::positive<double>()}
options::Measurement< double, false >	sync_time_ {3.5, "ms", options::positive<double>()}
options::Bool	discard_warnings_ {false}
DetectionCriterionValue	detections_to_criterion_ {1}
Protected Attributes inherited from EventSync
PortIn< EventType > *	data_in_port_
PortOut< EventType > *	data_out_port_
EventCounter	event_counter_
uint64_t	n_events_synced_
TimestampRegister	timestamps_
options::Value< EventType::Data, false >	target_event_
Protected Attributes inherited from IProcessor
std::map< std::string, std::shared_ptr< std::ostream > >	streams_
std::vector< TimePoint >	test_source_timestamps_
options::OptionList	options_
options::OptionList	advanced_options_

Additional Inherited Members
Static Public Attributes inherited from IProcessor
static std::vector< TimingEntry > *	t_metrics = nullptr
static constexpr size_t	MAX_SAMPLES = 100000

Member Function Documentation

CreatePorts()

void EventFilter::CreatePorts ( )

overridevirtual

Implements IProcessor.

Postprocess()

void EventFilter::Postprocess ( ProcessingContext & context )

overridevirtual

Reimplemented from IProcessor.

Prepare()

void EventFilter::Prepare ( GlobalContext & context )

overridevirtual

Reimplemented from IProcessor.

Preprocess()

void EventFilter::Preprocess ( ProcessingContext & context )

overridevirtual

Reimplemented from IProcessor.

Process()

void EventFilter::Process ( ProcessingContext & context )

overridevirtual

Implements IProcessor.

---

The documentation for this class was generated from the following files:

• extensions/falcon-fklab-extensions/processors/eventfilter/eventfilter.hpp
• extensions/falcon-fklab-extensions/processors/eventfilter/eventfilter.cpp