Psyllid  v1.12.4
Project 8 Data Acquisisition Software
Public Types | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | List of all members
request_receiver Class Reference

Receives request from a amqp broker. More...

#include <request_receiver.hh>

Inheritance diagram for request_receiver:
Inheritance graph

Public Types

enum  status {
  k_initialized = 0, k_starting = 1, k_listening = 5, k_canceled = 9,
  k_done = 10, k_error = 100
}
 
- Public Types inherited from control_access
typedef std::shared_ptr< daq_controldc_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)
 
- Public Member Functions inherited from control_access
 control_access ()
 
virtual ~control_access ()
 

Static Public Member Functions

static std::string interpret_status (status a_status)
 
- Static Public Member Functions inherited from control_access
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< statusf_status
 

Additional Inherited Members

- Protected Member Functions inherited from control_access
dc_ptr_t use_daq_control ()
 
bool daq_control_expired ()
 
- Static Protected Attributes inherited from control_access
static std::weak_ptr< daq_controlf_daq_control = std::weak_ptr< daq_control >()
 

Detailed Description

Receives request from a amqp broker.

Author
N. S. Oblath

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.

Member Enumeration Documentation

◆ status

enum status
Enumerator
k_initialized 
k_starting 
k_listening 
k_canceled 
k_done 
k_error 

Definition at line 48 of file request_receiver.hh.

Constructor & Destructor Documentation

◆ request_receiver()

request_receiver ( const scarab::param_node &  a_master_config)

Definition at line 29 of file request_receiver.cc.

◆ ~request_receiver()

~request_receiver ( )
virtual

Definition at line 37 of file request_receiver.cc.

Member Function Documentation

◆ __do_handle_set_condition_request()

dripline::reply_ptr_t __do_handle_set_condition_request ( const dripline::request_ptr_t  a_request)
privatevirtual

Definition at line 123 of file request_receiver.cc.

◆ do_cancellation()

void do_cancellation ( int  a_code)
privatevirtual

Definition at line 89 of file request_receiver.cc.

◆ execute()

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.

◆ get_status()

request_receiver::status get_status ( ) const
inline

Definition at line 70 of file request_receiver.hh.

◆ interpret_status()

std::string interpret_status ( status  a_status)
static

Definition at line 96 of file request_receiver.cc.

◆ mv_referrable_const()

mv_referrable_const ( scarab::param_node  ,
set_conditions   
)

◆ set_status()

void set_status ( status  a_status)
inline

Definition at line 75 of file request_receiver.hh.

Member Data Documentation

◆ f_status

std::atomic< status > f_status
private

Definition at line 64 of file request_receiver.hh.


The documentation for this class was generated from the following files: