Sets up daq_control, strea_manager and request_receiver. Registers request handles.
More...
#include <run_server.hh>
Sets up daq_control, strea_manager and request_receiver. Registers request handles.
- Author
- N. S. Oblath
A run_server instance is created by the psyllid executable. The executable calls run_server.execute() and waits for it's return. In execute(), run_server creates new instances of daq_control, stream_manager and request_receiver. It also adds set, get and cmd request handlers by registering handlers with the request_receiver. Then it calls daq_control.execute and request_receiver.execute in 2 separate threads. run_server.execute() only returns when all threads were joined.
Definition at line 47 of file run_server.hh.
◆ status
Enumerator |
---|
k_initialized | |
k_starting | |
k_running | |
k_done | |
k_error | |
Definition at line 79 of file run_server.hh.
◆ run_server()
◆ ~run_server()
◆ do_cancellation()
void do_cancellation |
( |
int |
a_code | ) |
|
|
privatevirtual |
◆ execute()
void execute |
( |
const scarab::param_node & |
a_config | ) |
|
◆ get_return()
◆ get_status()
◆ handle_get_server_status_request()
dripline::reply_ptr_t handle_get_server_status_request |
( |
const dripline::request_ptr_t |
a_request | ) |
|
◆ handle_quit_server_request()
dripline::reply_ptr_t handle_quit_server_request |
( |
const dripline::request_ptr_t |
a_request | ) |
|
◆ handle_stop_all_request()
dripline::reply_ptr_t handle_stop_all_request |
( |
const dripline::request_ptr_t |
a_request | ) |
|
◆ interpret_status()
std::string interpret_status |
( |
status |
a_status | ) |
|
|
static |
◆ quit_server()
◆ set_status()
void set_status |
( |
status |
a_status | ) |
|
|
inline |
◆ f_batch_executor
◆ f_component_mutex
std::mutex f_component_mutex |
|
private |
◆ f_daq_control
◆ f_request_receiver
◆ f_return
◆ f_status
std::atomic< status > f_status |
|
private |
◆ f_stream_manager
The documentation for this class was generated from the following files: