19 #include "producer.hh" 34 public midge::_producer< test_producer, typelist_1( trigger_flag ) >
56 array< bool, 20 > t_flags = { 0, 0, 0, 1, 1, 1, 0, 1, 1, 0, 0, 1, 1, 1, 0, 1, 0, 0, 0, 1 };
58 out_stream< 0 >().
set( stream::s_start );
60 for( uint64_t t_id = 0; t_id < t_flags.size(); ++t_id )
64 t_flag_data->set_id( t_id );
65 t_flag_data->set_flag( t_flags[ t_id ] );
67 LDEBUG(
plog,
"Sending: " << t_id <<
", " << t_flags[t_id] );
69 out_stream< 0 >().
set( stream::s_run );
72 out_stream< 0 >().
set( stream::s_stop );
73 out_stream< 0 >().
set( stream::s_exit );
93 LINFO(
plog,
"Preparing" );
95 ::midge::diptera* t_root = new ::midge::diptera();
98 t_test_prod->set_name(
"tp" );
99 t_root->add( t_test_prod );
102 t_event_builder->set_name(
"eb" );
103 t_event_builder->set_pretrigger( 2 );
104 t_event_builder->set_skip_tolerance( 1 );
105 t_root->add( t_event_builder );
107 t_root->join(
"tp.out_0:eb.in_0" );
109 LINFO(
plog,
"Expecting the following events: 1-8, 9-15, 17-19" );
111 LINFO(
plog,
"Starting execution" );
113 t_root->run(
"tp:eb" );
115 LINFO(
plog,
"All done!" );
accessible(uint64_t, length)
static scarab::logger plog("batch_executor")
A transformer that considers a sequence of triggered packets and decides what constitutes a contiguou...
static scarab::logger plog("test_event_builder")
LOGGER(plog, "egg_writer")