20 using std::unique_ptr;
30 LINFO(
plog,
"Attempting to cancel" );
40 midge::diptera* t_root =
new midge::diptera();
43 t_udpr->set_name(
"udpr" );
44 t_udpr->set_time_length( 10 );
45 t_root->add( t_udpr );
48 t_fmt->set_name(
"fmt" );
53 t_eb->set_name(
"eb" );
54 t_eb->set_pretrigger( 1 );
55 t_eb->set_skip_tolerance( 0 );
59 t_ew->set_name(
"ew" );
63 t_root->join(
"udpr.out_0:ew.in_0" );
64 t_root->join(
"udpr.out_1:fmt.in_0" );
65 t_root->join(
"fmt.out_0:eb.in_0" );
66 t_root->join(
"eb.out_0:ew.in_1" );
72 std::exception_ptr t_e_ptr = t_root->run(
"udpr:fmt:eb:ew" );
74 if( t_e_ptr ) std::rethrow_exception( t_e_ptr );
81 catch( std::exception& e )
83 LERROR(
plog,
"Exception caught: " << e.what() );
static scarab::logger plog("batch_executor")
void set_threshold_ampl_snr(double a_ampl_snr)
A transformer that considers a sequence of triggered packets and decides what constitutes a contiguou...
A transformer to receive raw blocks of memory, parse them, and distribute them as time and frequency ...
A consumer to that writes triggered time ROACH packets to an egg file.
LOGGER(plog, "egg_writer")
scarab::cancelable * f_cancelable