8 #ifndef PSYLLID_RUN_SERVER_HH_ 9 #define PSYLLID_RUN_SERVER_HH_ 17 #include "cancelable.hh" 24 class version_semantic;
31 class request_receiver;
53 void execute(
const scarab::param_node& a_config );
57 int get_return()
const;
59 dripline::reply_ptr_t handle_get_server_status_request(
const dripline::request_ptr_t a_request );
61 dripline::reply_ptr_t handle_stop_all_request(
const dripline::request_ptr_t a_request );
62 dripline::reply_ptr_t handle_quit_server_request(
const dripline::request_ptr_t a_request );
65 virtual void do_cancellation(
int a_code );
88 static std::string interpret_status(
status a_status );
91 void set_status(
status a_status );
98 inline int run_server::get_return()
const 105 return f_status.load();
108 inline void run_server::set_status(
status a_status )
110 f_status.store( a_status );
std::shared_ptr< stream_manager > f_stream_manager
std::atomic< status > f_status
std::shared_ptr< batch_executor > f_batch_executor
std::shared_ptr< request_receiver > f_request_receiver
std::shared_ptr< daq_control > f_daq_control
std::mutex f_component_mutex
Sets up daq_control, strea_manager and request_receiver. Registers request handles.