Psyllid
v1.12.4
Project 8 Data Acquisisition Software
|
Classes | |
class | _node_binding |
class | _node_builder |
struct | action_info |
class | batch_executor |
A class sequentially execute a list of actions, equivalent to a sequence of dripline requests. More... | |
struct | block_desc |
class | butterfly_house |
Responsible for starting files. Holds pointer to monarch. More... | |
class | control_access |
Gives other classes access to daq_control. More... | |
class | daq_control |
Controls psyllid's status and forwards requests to the DAQ nodes. More... | |
class | data_producer |
A producer to use for debugging: continously outputss identical blank data. More... | |
class | data_producer_binding |
class | egg3_reader |
A producer to read time-domain slices from an egg file and place them in time data buffers. More... | |
class | egg3_reader_binding |
class | egg_writer |
Base class for all writers. More... | |
class | error |
class | event_builder |
A transformer that considers a sequence of triggered packets and decides what constitutes a contiguous event. More... | |
class | event_builder_binding |
class | freq_data |
class | frequency_mask_trigger |
A basic FMT. More... | |
class | frequency_mask_trigger_binding |
class | frequency_transform |
A transformer to receive time data, compute an FFT, and distribute as time and frequency ROACH packets. More... | |
class | frequency_transform_binding |
class | header_wrapper |
Wrapper class for a monarch3::M3Header object. More... | |
class | id_range_event |
class | locked_resource |
class | memory_block |
class | message_relayer |
class | monarch_on_deck_manager |
Handles asynchronous creation of on-deck monarch files and finishing of completed files. More... | |
class | monarch_wrapper |
Wrapper class for a monarch3::M3Monarch object. More... | |
class | node_binding |
Allows access to midge nodes. More... | |
class | node_builder |
Holds node configuration and can be used to create node classes and node binding classes. More... | |
class | packet_receiver_fpa |
A producer to receive UDP packets via the fast-packet-acquisition interface and write them as raw blocks of memory. More... | |
class | packet_receiver_fpa_binding |
class | packet_receiver_socket |
A producer to receive UDP packets via the standard socket interface and write them as raw blocks of memory. More... | |
class | packet_receiver_socket_binding |
class | persistent_store |
struct | raw_roach_packet |
struct | receive_ring |
class | request_receiver |
Receives request from a amqp broker. More... | |
class | roach_freq_monitor |
A consumer to check the continuity of the freq-packet stream from a ROACH. More... | |
class | roach_freq_monitor_binding |
class | roach_packet |
class | roach_packet_data |
class | roach_time_monitor |
A consumer to check the continuity of the time-packet stream from a ROACH. More... | |
class | roach_time_monitor_binding |
class | run_server |
Sets up daq_control, strea_manager and request_receiver. Registers request handles. More... | |
class | runtime_stream_preset |
class | server_config |
Contains default server configuration. More... | |
class | stream_manager |
Manages one or multiple sets of midge-nodes. More... | |
class | stream_preset |
class | stream_wrapper |
Wrapper class for a monarch3::M3Stream object. More... | |
class | streaming_frequency_writer |
A consumer to that writes all frequency ROACH packets to an egg file. More... | |
class | streaming_frequency_writer_binding |
class | streaming_writer |
A consumer to that writes all time ROACH packets to an egg file. More... | |
class | streaming_writer_binding |
class | terminator_freq_data |
class | terminator_freq_data_binding |
class | terminator_time_data |
class | terminator_time_data_binding |
class | terminator_trigger_flag |
class | terminator_trigger_flag_binding |
class | test_producer |
class | tf_roach_receiver |
A transformer to receive raw blocks of memory, parse them, and distribute them as time and frequency ROACH packets. More... | |
class | tf_roach_receiver_binding |
class | time_data |
class | trigger_flag |
class | triggered_writer |
A consumer to that writes triggered time ROACH packets to an egg file. More... | |
class | triggered_writer_binding |
class | version |
Typedefs | |
typedef std::shared_ptr< monarch_wrapper > | monarch_wrap_ptr |
typedef std::shared_ptr< header_wrapper > | header_wrap_ptr |
typedef std::shared_ptr< stream_wrapper > | stream_wrap_ptr |
typedef std::chrono::time_point< std::chrono::steady_clock, std::chrono::nanoseconds > | monarch_time_point_t |
typedef std::unique_lock< std::mutex > | unique_lock |
typedef locked_resource< midge::diptera, stream_manager > | midge_package |
typedef std::map< std::string, std::pair< node_binding *, midge::node *> > | active_node_bindings |
Enumerations | |
enum | monarch_stage { initialized = 0, preparing = 1, writing = 2, finished = 3 } |
Functions | |
static scarab::logger | plog ("batch_executor") |
static scarab::logger | plog ("butterfly_house") |
static scarab::logger | plog ("control_access") |
static scarab::logger | plog ("daq_control") |
LOGGER (plog, "egg_writer") | |
static scarab::logger | plog ("monarch3_wrap") |
uint32_t | to_uint (monarch_stage a_stage) |
monarch_stage | to_op_t (uint32_t a_stage_uint) |
std::ostream & | operator<< (std::ostream &a_os, monarch_stage a_stage) |
monarch_stage | to_stage (uint32_t a_stage_uint) |
static scarab::logger | plog ("request_receiver") |
static scarab::logger | plog ("run_server") |
static scarab::logger | plog ("server_config") |
static scarab::logger | plog ("stream_manager") |
static scarab::logger | plog ("stream_preset") |
REGISTER_NODE_AND_BUILDER (data_producer, "data-producer", data_producer_binding) | |
REGISTER_NODE_AND_BUILDER (egg3_reader, "egg3-reader", egg3_reader_binding) | |
static scarab::logger | plog ("egg3_reader") |
REGISTER_NODE_AND_BUILDER (event_builder, "event-builder", event_builder_binding) | |
static scarab::logger | plog ("event_builder") |
static scarab::logger | eblog_hdr ("event_builder_h") |
REGISTER_NODE_AND_BUILDER (frequency_mask_trigger, "frequency-mask-trigger", frequency_mask_trigger_binding) | |
static scarab::logger | plog ("frequency_mask_trigger") |
REGISTER_NODE_AND_BUILDER (frequency_transform, "frequency-transform", frequency_transform_binding) | |
static scarab::logger | plog ("frequency_transform") |
REGISTER_NODE_AND_BUILDER (packet_receiver_fpa, "packet-receiver-fpa", packet_receiver_fpa_binding) | |
static scarab::logger | plog ("packet_receiver_fpa") |
REGISTER_NODE_AND_BUILDER (packet_receiver_socket, "packet-receiver-socket", packet_receiver_socket_binding) | |
static scarab::logger | plog ("packet_receiver_socket") |
REGISTER_PRESET (streaming_1ch, "str-1ch") | |
REGISTER_PRESET (fmask_trigger_1ch,"fmask-1ch") | |
REGISTER_PRESET (event_builder_1ch,"events-1ch") | |
DECLARE_PRESET (streaming_1ch) | |
DECLARE_PRESET (fmask_trigger_1ch) | |
DECLARE_PRESET (event_builder_1ch) | |
REGISTER_NODE_AND_BUILDER (streaming_frequency_writer, "streaming-frequency-writer", streaming_frequency_writer_binding) | |
static scarab::logger | plog ("streaming_frequency_writer") |
REGISTER_NODE_AND_BUILDER (streaming_writer, "streaming-writer", streaming_writer_binding) | |
static scarab::logger | plog ("streaming_writer") |
REGISTER_NODE_AND_BUILDER (terminator_time_data, "term-time-data", terminator_time_data_binding) | |
REGISTER_NODE_AND_BUILDER (terminator_freq_data, "term-freq-data", terminator_freq_data_binding) | |
REGISTER_NODE_AND_BUILDER (terminator_trigger_flag, "term-trig-flag", terminator_trigger_flag_binding) | |
static scarab::logger | plog ("terminator") |
REGISTER_NODE_AND_BUILDER (roach_time_monitor, "roach-time-monitor", roach_time_monitor_binding) | |
REGISTER_NODE_AND_BUILDER (roach_freq_monitor, "roach-freq-monitor", roach_freq_monitor_binding) | |
static scarab::logger | plog ("tf_roach_monitor") |
REGISTER_NODE_AND_BUILDER (tf_roach_receiver, "tf-roach-receiver", tf_roach_receiver_binding) | |
static scarab::logger | plog ("tf_roach_receiver") |
REGISTER_NODE_AND_BUILDER (triggered_writer, "triggered-writer", triggered_writer_binding) | |
static scarab::logger | plog ("triggered_writer") |
void | byteswap_inplace (raw_roach_packet *a_pkt) |
typedef std::map< std::string, std::pair< node_binding*, midge::node* > > active_node_bindings |
Definition at line 45 of file stream_manager.hh.
typedef std::shared_ptr< header_wrapper > header_wrap_ptr |
Definition at line 54 of file monarch3_wrap.hh.
typedef locked_resource< midge::diptera, stream_manager > midge_package |
Definition at line 42 of file stream_manager.hh.
typedef std::chrono::time_point< std::chrono::steady_clock, std::chrono::nanoseconds > monarch_time_point_t |
Definition at line 60 of file monarch3_wrap.hh.
typedef std::shared_ptr< monarch_wrapper > monarch_wrap_ptr |
Definition at line 51 of file monarch3_wrap.hh.
typedef std::shared_ptr< stream_wrapper > stream_wrap_ptr |
Definition at line 57 of file monarch3_wrap.hh.
typedef std::unique_lock< std::mutex > unique_lock |
Definition at line 62 of file monarch3_wrap.hh.
|
strong |
Enumerator | |
---|---|
initialized | |
preparing | |
writing | |
finished |
Definition at line 40 of file monarch3_wrap.hh.
void byteswap_inplace | ( | raw_roach_packet * | a_pkt | ) |
Definition at line 22 of file roach_packet.cc.
psyllid::DECLARE_PRESET | ( | streaming_1ch | ) |
psyllid::DECLARE_PRESET | ( | fmask_trigger_1ch | ) |
psyllid::DECLARE_PRESET | ( | event_builder_1ch | ) |
|
static |
psyllid::LOGGER | ( | plog | , |
"egg_writer" | |||
) |
std::ostream & operator<< | ( | std::ostream & | a_os, |
monarch_stage | a_stage | ||
) |
Definition at line 38 of file monarch3_wrap.cc.
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
psyllid::REGISTER_NODE_AND_BUILDER | ( | event_builder | , |
"event-builder" | , | ||
event_builder_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | terminator_time_data | , |
"term-time-data" | , | ||
terminator_time_data_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | terminator_freq_data | , |
"term-freq-data" | , | ||
terminator_freq_data_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | data_producer | , |
"data-producer" | , | ||
data_producer_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | terminator_trigger_flag | , |
"term-trig-flag" | , | ||
terminator_trigger_flag_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | roach_time_monitor | , |
"roach-time-monitor" | , | ||
roach_time_monitor_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | roach_freq_monitor | , |
"roach-freq-monitor" | , | ||
roach_freq_monitor_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | egg3_reader | , |
"egg3-reader" | , | ||
egg3_reader_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | tf_roach_receiver | , |
"tf-roach-receiver" | , | ||
tf_roach_receiver_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | frequency_transform | , |
"frequency-transform" | , | ||
frequency_transform_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | frequency_mask_trigger | , |
"frequency-mask-trigger" | , | ||
frequency_mask_trigger_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | triggered_writer | , |
"triggered-writer" | , | ||
triggered_writer_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | streaming_frequency_writer | , |
"streaming-frequency-writer" | , | ||
streaming_frequency_writer_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | streaming_writer | , |
"streaming-writer" | , | ||
streaming_writer_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | packet_receiver_socket | , |
"packet-receiver-socket" | , | ||
packet_receiver_socket_binding | |||
) |
psyllid::REGISTER_NODE_AND_BUILDER | ( | packet_receiver_fpa | , |
"packet-receiver-fpa" | , | ||
packet_receiver_fpa_binding | |||
) |
psyllid::REGISTER_PRESET | ( | streaming_1ch | , |
"str-1ch" | |||
) |
psyllid::REGISTER_PRESET | ( | fmask_trigger_1ch | , |
"fmask-1ch" | |||
) |
psyllid::REGISTER_PRESET | ( | event_builder_1ch | , |
"events-1ch" | |||
) |
monarch_stage psyllid::to_op_t | ( | uint32_t | a_stage_uint | ) |
Definition at line 34 of file monarch3_wrap.cc.
monarch_stage psyllid::to_stage | ( | uint32_t | a_stage_uint | ) |
uint32_t to_uint | ( | monarch_stage | a_stage | ) |
Definition at line 30 of file monarch3_wrap.cc.