Psyllid  v1.12.4
Project 8 Data Acquisisition Software
Classes | Typedefs | Enumerations | Functions
psyllid Namespace Reference

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_wrappermonarch_wrap_ptr
 
typedef std::shared_ptr< header_wrapperheader_wrap_ptr
 
typedef std::shared_ptr< stream_wrapperstream_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_managermidge_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 Documentation

◆ active_node_bindings

typedef std::map< std::string, std::pair< node_binding*, midge::node* > > active_node_bindings

Definition at line 45 of file stream_manager.hh.

◆ header_wrap_ptr

typedef std::shared_ptr< header_wrapper > header_wrap_ptr

Definition at line 54 of file monarch3_wrap.hh.

◆ midge_package

typedef locked_resource< midge::diptera, stream_manager > midge_package

Definition at line 42 of file stream_manager.hh.

◆ monarch_time_point_t

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.

◆ monarch_wrap_ptr

typedef std::shared_ptr< monarch_wrapper > monarch_wrap_ptr

Definition at line 51 of file monarch3_wrap.hh.

◆ stream_wrap_ptr

typedef std::shared_ptr< stream_wrapper > stream_wrap_ptr

Definition at line 57 of file monarch3_wrap.hh.

◆ unique_lock

typedef std::unique_lock< std::mutex > unique_lock

Definition at line 62 of file monarch3_wrap.hh.

Enumeration Type Documentation

◆ monarch_stage

enum monarch_stage
strong
Enumerator
initialized 
preparing 
writing 
finished 

Definition at line 40 of file monarch3_wrap.hh.

Function Documentation

◆ byteswap_inplace()

void byteswap_inplace ( raw_roach_packet a_pkt)

Definition at line 22 of file roach_packet.cc.

◆ DECLARE_PRESET() [1/3]

psyllid::DECLARE_PRESET ( streaming_1ch  )

◆ DECLARE_PRESET() [2/3]

psyllid::DECLARE_PRESET ( fmask_trigger_1ch  )

◆ DECLARE_PRESET() [3/3]

psyllid::DECLARE_PRESET ( event_builder_1ch  )

◆ eblog_hdr()

static scarab::logger psyllid::eblog_hdr ( "event_builder_h"  )
static

◆ LOGGER()

psyllid::LOGGER ( plog  ,
"egg_writer"   
)

◆ operator<<()

std::ostream & operator<< ( std::ostream &  a_os,
monarch_stage  a_stage 
)

Definition at line 38 of file monarch3_wrap.cc.

◆ plog() [1/22]

static scarab::logger psyllid::plog ( "control_access"  )
static

◆ plog() [2/22]

static scarab::logger psyllid::plog ( "stream_preset"  )
static

◆ plog() [3/22]

static scarab::logger psyllid::plog ( "event_builder"  )
static

◆ plog() [4/22]

static scarab::logger psyllid::plog ( "butterfly_house"  )
static

◆ plog() [5/22]

static scarab::logger psyllid::plog ( "terminator"  )
static

◆ plog() [6/22]

static scarab::logger psyllid::plog ( "tf_roach_monitor"  )
static

◆ plog() [7/22]

static scarab::logger psyllid::plog ( "egg3_reader"  )
static

◆ plog() [8/22]

static scarab::logger psyllid::plog ( "server_config"  )
static

◆ plog() [9/22]

static scarab::logger psyllid::plog ( "tf_roach_receiver"  )
static

◆ plog() [10/22]

static scarab::logger psyllid::plog ( "request_receiver"  )
static

◆ plog() [11/22]

static scarab::logger psyllid::plog ( "frequency_mask_trigger"  )
static

◆ plog() [12/22]

static scarab::logger psyllid::plog ( "frequency_transform"  )
static

◆ plog() [13/22]

static scarab::logger psyllid::plog ( "monarch3_wrap"  )
static

◆ plog() [14/22]

static scarab::logger psyllid::plog ( "triggered_writer"  )
static

◆ plog() [15/22]

static scarab::logger psyllid::plog ( "batch_executor"  )
static

◆ plog() [16/22]

static scarab::logger psyllid::plog ( "run_server"  )
static

◆ plog() [17/22]

static scarab::logger psyllid::plog ( "streaming_frequency_writer"  )
static

◆ plog() [18/22]

static scarab::logger psyllid::plog ( "streaming_writer"  )
static

◆ plog() [19/22]

static scarab::logger psyllid::plog ( "stream_manager"  )
static

◆ plog() [20/22]

static scarab::logger psyllid::plog ( "packet_receiver_socket"  )
static

◆ plog() [21/22]

static scarab::logger psyllid::plog ( "daq_control"  )
static

◆ plog() [22/22]

static scarab::logger psyllid::plog ( "packet_receiver_fpa"  )
static

◆ REGISTER_NODE_AND_BUILDER() [1/16]

psyllid::REGISTER_NODE_AND_BUILDER ( event_builder  ,
"event-builder"  ,
event_builder_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [2/16]

psyllid::REGISTER_NODE_AND_BUILDER ( terminator_time_data  ,
"term-time-data"  ,
terminator_time_data_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [3/16]

psyllid::REGISTER_NODE_AND_BUILDER ( terminator_freq_data  ,
"term-freq-data"  ,
terminator_freq_data_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [4/16]

psyllid::REGISTER_NODE_AND_BUILDER ( data_producer  ,
"data-producer"  ,
data_producer_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [5/16]

psyllid::REGISTER_NODE_AND_BUILDER ( terminator_trigger_flag  ,
"term-trig-flag"  ,
terminator_trigger_flag_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [6/16]

psyllid::REGISTER_NODE_AND_BUILDER ( roach_time_monitor  ,
"roach-time-monitor"  ,
roach_time_monitor_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [7/16]

psyllid::REGISTER_NODE_AND_BUILDER ( roach_freq_monitor  ,
"roach-freq-monitor"  ,
roach_freq_monitor_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [8/16]

psyllid::REGISTER_NODE_AND_BUILDER ( egg3_reader  ,
"egg3-reader"  ,
egg3_reader_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [9/16]

psyllid::REGISTER_NODE_AND_BUILDER ( tf_roach_receiver  ,
"tf-roach-receiver"  ,
tf_roach_receiver_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [10/16]

psyllid::REGISTER_NODE_AND_BUILDER ( frequency_transform  ,
"frequency-transform"  ,
frequency_transform_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [11/16]

psyllid::REGISTER_NODE_AND_BUILDER ( frequency_mask_trigger  ,
"frequency-mask-trigger"  ,
frequency_mask_trigger_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [12/16]

psyllid::REGISTER_NODE_AND_BUILDER ( triggered_writer  ,
"triggered-writer"  ,
triggered_writer_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [13/16]

psyllid::REGISTER_NODE_AND_BUILDER ( streaming_frequency_writer  ,
"streaming-frequency-writer"  ,
streaming_frequency_writer_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [14/16]

psyllid::REGISTER_NODE_AND_BUILDER ( streaming_writer  ,
"streaming-writer"  ,
streaming_writer_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [15/16]

psyllid::REGISTER_NODE_AND_BUILDER ( packet_receiver_socket  ,
"packet-receiver-socket"  ,
packet_receiver_socket_binding   
)

◆ REGISTER_NODE_AND_BUILDER() [16/16]

psyllid::REGISTER_NODE_AND_BUILDER ( packet_receiver_fpa  ,
"packet-receiver-fpa"  ,
packet_receiver_fpa_binding   
)

◆ REGISTER_PRESET() [1/3]

psyllid::REGISTER_PRESET ( streaming_1ch  ,
"str-1ch"   
)

◆ REGISTER_PRESET() [2/3]

psyllid::REGISTER_PRESET ( fmask_trigger_1ch  ,
"fmask-1ch"   
)

◆ REGISTER_PRESET() [3/3]

psyllid::REGISTER_PRESET ( event_builder_1ch  ,
"events-1ch"   
)

◆ to_op_t()

monarch_stage psyllid::to_op_t ( uint32_t  a_stage_uint)

Definition at line 34 of file monarch3_wrap.cc.

◆ to_stage()

monarch_stage psyllid::to_stage ( uint32_t  a_stage_uint)

◆ to_uint()

uint32_t to_uint ( monarch_stage  a_stage)

Definition at line 30 of file monarch3_wrap.cc.