Psyllid
v1.12.4
Project 8 Data Acquisisition Software
|
Receives request from a amqp broker. More...
#include <request_receiver.hh>
Public Types | |
enum | status { k_initialized = 0, k_starting = 1, k_listening = 5, k_canceled = 9, k_done = 10, k_error = 100 } |
![]() | |
typedef std::shared_ptr< daq_control > | dc_ptr_t |
Public Member Functions | |
request_receiver (const scarab::param_node &a_master_config) | |
virtual | ~request_receiver () |
void | execute (std::condition_variable &a_daq_control_ready_cv, std::mutex &a_daq_control_ready_mutex) |
mv_referrable_const (scarab::param_node, set_conditions) | |
status | get_status () const |
void | set_status (status a_status) |
![]() | |
control_access () | |
virtual | ~control_access () |
Static Public Member Functions | |
static std::string | interpret_status (status a_status) |
![]() | |
static void | set_daq_control (std::weak_ptr< daq_control > a_daq_control) |
Private Member Functions | |
virtual void | do_cancellation (int a_code) |
virtual dripline::reply_ptr_t | __do_handle_set_condition_request (const dripline::request_ptr_t a_request) |
Private Attributes | |
std::atomic< status > | f_status |
Additional Inherited Members | |
![]() | |
dc_ptr_t | use_daq_control () |
bool | daq_control_expired () |
![]() | |
static std::weak_ptr< daq_control > | f_daq_control = std::weak_ptr< daq_control >() |
Receives request from a amqp broker.
A request_receiver instance is initialized by run_server. request_receiver holds maps for set, get, cmd and run requests. When a request is received the handle_function registered with this request gets called. The registration of requests and functions is done in dripline::hub.
Definition at line 35 of file request_receiver.hh.
enum status |
Enumerator | |
---|---|
k_initialized | |
k_starting | |
k_listening | |
k_canceled | |
k_done | |
k_error |
Definition at line 48 of file request_receiver.hh.
request_receiver | ( | const scarab::param_node & | a_master_config | ) |
Definition at line 29 of file request_receiver.cc.
|
virtual |
Definition at line 37 of file request_receiver.cc.
|
privatevirtual |
Definition at line 123 of file request_receiver.cc.
|
privatevirtual |
Definition at line 89 of file request_receiver.cc.
void execute | ( | std::condition_variable & | a_daq_control_ready_cv, |
std::mutex & | a_daq_control_ready_mutex | ||
) |
Definition at line 41 of file request_receiver.cc.
|
inline |
Definition at line 70 of file request_receiver.hh.
|
static |
Definition at line 96 of file request_receiver.cc.
mv_referrable_const | ( | scarab::param_node | , |
set_conditions | |||
) |
|
inline |
Definition at line 75 of file request_receiver.hh.
|
private |
Definition at line 64 of file request_receiver.hh.