8 #ifndef PSYLLID_EVENT_BUILDER_HH_ 9 #define PSYLLID_EVENT_BUILDER_HH_ 11 #include "transformer.hh" 19 #include <boost/circular_buffer.hpp> 69 public midge::_transformer< midge::type_list< trigger_flag >, midge::type_list< trigger_flag > >
88 virtual void execute( midge::diptera* a_midge =
nullptr );
128 a_data->set_flag( a_flag );
129 LTRACE(
eblog_hdr,
"Event builder writing data to the output stream at index " << out_stream< 0 >().get_current_index() );
130 if( ! out_stream< 0 >().
set( midge::stream::s_run ) )
132 LERROR(
eblog_hdr,
"Exiting due to stream error" );
142 a_data->set_flag( a_flag );
143 LTRACE(
eblog_hdr,
"Event builder writing data to the output stream at index " << out_stream< 0 >().get_current_index() );
144 if( ! out_stream< 0 >().
set( midge::stream::s_run ) )
146 LERROR(
eblog_hdr,
"Exiting due to stream error" );
160 virtual void do_apply_config(
event_builder* a_node,
const scarab::param_node& a_config )
const;
161 virtual void do_dump_config(
const event_builder* a_node, scarab::param_node& a_config )
const;
pretrigger_buffer_t f_skip_buffer
virtual void execute(midge::diptera *a_midge=nullptr)
bool write_output_from_ptbuff_front(bool a_flag, trigger_flag *a_data)
const pretrigger_buffer_t & skip_buffer() const
static scarab::logger eblog_hdr("event_builder_h")
bool write_output_from_skipbuff_front(bool a_flag, trigger_flag *a_data)
A transformer that considers a sequence of triggered packets and decides what constitutes a contiguou...
boost::circular_buffer< uint64_t > pretrigger_buffer_t
virtual void initialize()
LOGGER(plog, "egg_writer")
bool is_triggered() const
const pretrigger_buffer_t & pretrigger_buffer() const
pretrigger_buffer_t f_pretrigger_buffer
void advance_output_stream(trigger_flag *a_write_flag, uint64_t a_id, bool a_trig_flag)
mv_accessible(uint64_t, length)