46 midge::enum_t t_command = midge::stream::s_none;
48 while( ! is_canceled() )
50 t_command = in_stream< 0 >().
get();
51 if( t_command == midge::stream::s_none )
continue;
52 if( t_command == midge::stream::s_error )
break;
54 if( t_command == midge::stream::s_exit )
56 LDEBUG(
plog,
"Terminator is exiting" );
60 if( t_command == midge::stream::s_stop )
62 LDEBUG(
plog,
"Terminator is stopping" );
66 if( t_command == midge::stream::s_start )
68 LDEBUG(
plog,
"Terminator is starting" );
72 if( t_command == midge::stream::s_run )
83 if( a_midge ) a_midge->throw_ex( std::current_exception() );
129 midge::enum_t t_command = midge::stream::s_none;
131 while( ! is_canceled() )
133 t_command = in_stream< 0 >().
get();
134 if( t_command == midge::stream::s_none )
continue;
135 if( t_command == midge::stream::s_error )
break;
137 if( t_command == midge::stream::s_exit )
139 LDEBUG(
plog,
"Terminator is exiting" );
143 if( t_command == midge::stream::s_stop )
145 LDEBUG(
plog,
"Terminator is stopping" );
149 if( t_command == midge::stream::s_start )
151 LDEBUG(
plog,
"Terminator is starting" );
155 if( t_command == midge::stream::s_run )
166 if( a_midge ) a_midge->throw_ex( std::current_exception() );
virtual void do_apply_config(terminator_freq_data *a_node, const scarab::param_node &a_config) const
virtual void execute(midge::diptera *a_midge=nullptr)
virtual void do_dump_config(const terminator_time_data *a_node, scarab::param_node &a_config) const
virtual void execute(midge::diptera *a_midge=nullptr)
virtual ~terminator_time_data_binding()
static scarab::logger plog("batch_executor")
#define IMPLEMENT_TERMINATOR(data_class)
virtual ~terminator_freq_data_binding()
virtual void initialize()
virtual void do_dump_config(const terminator_freq_data *a_node, scarab::param_node &a_config) const
REGISTER_NODE_AND_BUILDER(data_producer, "data-producer", data_producer_binding)
virtual ~terminator_time_data()
LOGGER(plog, "egg_writer")
terminator_time_data_binding()
virtual void do_apply_config(terminator_time_data *a_node, const scarab::param_node &a_config) const
terminator_freq_data_binding()
virtual ~terminator_freq_data()
virtual void initialize()