template<class T>

StateMachineFAD< T >::StateMachineFAD ( ostream &  out = cout )

inline

Definition at line 1658 of file fadctrl.cc.

References StateMachineFAD< T >::AbortConnection(), StateMachineFAD< T >::AddAddress(), StateMachineFAD< T >::CloseOpenFiles(), StateMachineFAD< T >::Cmd(), StateMachineFAD< T >::CmdEnable(), zofits::DefaultMaxMemory(), zofits::DefaultMaxNumTiles(), zofits::DefaultNumRowsPerTile(), zofits::DefaultNumThreads(), StateMachineFAD< T >::EnableSlot(), kCmdBusyOff, kCmdBusyOn, kCmdContTrigger, kCmdDrsEnable, kCmdDwrite, kCmdResetEventCounter, kCmdSclk, kCmdSocket, kCmdSrclk, kCmdTriggerLine, MCP::State::kConfigured, FTM::State::kConfiguring1, FTM::State::kConfiguring2, MCP::State::kConfiguring3, Agilent::State::kConnected, BIAS::State::kConnecting, Agilent::State::kDisconnected, kNone, StateMachineFAD< T >::ListSlots(), StateMachineFAD< T >::LoadDrsCalibration(), StateMachineFAD< T >::PhaseShift(), StateMachineFAD< T >::PrintEvent(), StateMachineFAD< T >::RemoveSlot(), StateMachineFAD< T >::Reset(), StateMachineFAD< T >::ResetConfig(), StateMachineFAD< T >::ResetSecondaryDrsBaseline(), StateMachineFAD< T >::SendCmd(), StateMachineFAD< T >::SendCmdData(), StateMachineFAD< T >::SendTriggers(), StateMachineFAD< T >::SetBlockTransmission(), StateMachineFAD< T >::SetBlockTransmissionRange(), StateMachineFAD< T >::SetDac(), StateMachineFAD< T >::SetDataOutput(), StateMachineFAD< T >::SetDebugTx(), StateMachineFAD< T >::SetEventTimeoutSec(), StateMachineFAD< T >::SetFileFormat(), StateMachineFAD< T >::SetHexOutput(), StateMachineFAD< T >::SetIgnoreSlot(), StateMachineFAD< T >::SetIgnoreSlots(), StateMachineFAD< T >::SetMaxMemoryBuffer(), StateMachineFAD< T >::SetRegister(), StateMachineFAD< T >::SetRoi(), StateMachineFAD< T >::SetRunNumber(), StateMachineFAD< T >::SetTriggerRate(), StateMachineFAD< T >::SetupZFits(), StateMachineFAD< T >::SetVerbosity(), StateMachineFAD< T >::StartConfigure(), StateMachineFAD< T >::StartConnection(), StateMachineFAD< T >::StartDrsCalibration(), StateMachineFAD< T >::StopConnection(), StateMachineFAD< T >::ToggleSlot(), and StateMachineFAD< T >::Trigger().

                                       :
        StateMachineAsio<T>(out, "FAD_CONTROL"),
        EventBuilderWrapper(*static_cast<MessageImp*>(this)),
        fStatus1(40), fStatus2(40), fStatusT(false),
        fDimStartRun("FAD_CONTROL/START_RUN", "X:1;X:1",
                                              "Run numbers"
                                              "|run[idx]:Run no of last conf'd run (-1 if reset or none config'd yet)"
                                              "|next[idx]:Run number which will be assigned to next configuration"),
        fDimConnection("FAD_CONTROL/CONNECTIONS", "C:40;C:1",
                                                  "Connection status of FAD boards"
                                                  "|status[bitpattern]:lower bits stat1, upper bits stat2, for every board. 40=thread"
                                                  "|thread[bool]:true or false whether the event builder threads are running")
    {
        ResetConfig();
        SetOutputFormat(FAD::kNone);

        // State names
        T::AddStateName(FAD::State::kOffline, "Disengaged",
                        "All enabled FAD boards are disconnected and the event-builer thread is not running.");

        T::AddStateName(FAD::State::kDisconnected, "Disconnected",
                        "All enabled FAD boards are disconnected, but the event-builder thread is running.");

        T::AddStateName(FAD::State::kConnecting, "Connecting",
                        "Only some enabled FAD boards are connected.");

        T::AddStateName(FAD::State::kConnected, "Connected",
                        "All enabled FAD boards are connected..");

        T::AddStateName(FAD::State::kConfiguring1, "Configuring1",
                        "Waiting 3 seconds for all FADs to be configured before requesting configuration.");

        T::AddStateName(FAD::State::kConfiguring2, "Configuring2",
                        "Waiting until all boards returned their configuration and they are valid.");

        T::AddStateName(FAD::State::kConfiguring3, "Configuring3",
                        "Waiting until 'enable trigger line' was sent to all boards.");

        T::AddStateName(FAD::State::kConfigured, "Configured",
                        "The configuration of all boards was successfully cross checked. Waiting for events with a new run number to receive.");

        T::AddStateName(FAD::State::kRunInProgress, "RunInProgress",
                        "Events currently received by the event builder will be flagged to be written, no end-of-run event occured yet.");

        // FAD Commands
        T::AddEvent("SEND_CMD", "I:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SendCmd, this, placeholders::_1))
            ("Send a command to the FADs. Values between 0 and 0xffff are allowed."
             "|command[uint16]:Command to be transmittted.");
        T::AddEvent("SEND_DATA", "I:2", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SendCmdData, this, placeholders::_1))
            ("Send a command with data to the FADs. Values between 0 and 0xffff are allowed."
             "|command[uint16]:Command to be transmittted."
             "|data[uint16]:Data to be sent with the command.");

        T::AddEvent("ENABLE_SRCLK", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdSrclk))
            ("Set SRCLK");
        T::AddEvent("ENABLE_BUSY_OFF", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdBusyOff))
            ("Set BUSY continously low");
        T::AddEvent("ENABLE_BUSY_ON", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdBusyOn))
            ("Set BUSY constantly high (has priority over BUSY_OFF)");
        T::AddEvent("ENABLE_SCLK", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdSclk))
            ("Set SCLK");
        T::AddEvent("ENABLE_DRS", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdDrsEnable))
            ("Switch Domino wave");
        T::AddEvent("ENABLE_DWRITE", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdDwrite))
            ("Set Dwrite (possibly high / always low)");
        T::AddEvent("ENABLE_CONTINOUS_TRIGGER", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdContTrigger))
            ("Enable continous (internal) trigger.");
        T::AddEvent("ENABLE_TRIGGER_LINE", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdTriggerLine))
            ("Incoming triggers can be accepted/will not be accepted");
        T::AddEvent("ENABLE_COMMAND_SOCKET_MODE", "B:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CmdEnable, this, placeholders::_1, FAD::kCmdSocket))
            ("Set debug mode (yes: dump events through command socket, no=dump events through other sockets)");

        T::AddEvent("SET_TRIGGER_RATE", "I:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SetTriggerRate, this, placeholders::_1))
            ("Enable continous trigger");
        T::AddEvent("SEND_SINGLE_TRIGGER")
            (bind(&StateMachineFAD::Trigger, this, 1))
            ("Issue software triggers");
        T::AddEvent("SEND_N_TRIGGERS", "I", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SendTriggers, this, placeholders::_1))
            ("Issue N software triggers (note that these are the triggers sent, not the triggers executed)"
             "|N[int]: Number of triggers to be sent to the board.");
        /*
        T::AddEvent("START_RUN", "", FAD::kConnecting, FAD::kConnected, FAD::kRunInProgress)
            (bind(&StateMachineFAD::StartRun, this, placeholders::_1, true))
            ("Set FAD DAQ mode. when started, no configurations must be send.");
        T::AddEvent("STOP_RUN", FAD::kConnecting, FAD::kConnected, FAD::kRunInProgress)
            (bind(&StateMachineFAD::StartRun, this, placeholders::_1, false))
            ("");
            */
        T::AddEvent("PHASE_SHIFT", "S:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::PhaseShift, this, placeholders::_1))
            ("Adjust ADC phase (in 'steps')"
             "|phase[short]");

        T::AddEvent("RESET_EVENT_COUNTER", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::Cmd, this, FAD::kCmdResetEventCounter))
            ("Reset the FAD boards' event counter to 0.");

        T::AddEvent("SET_RUN_NUMBER", "X:1", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SetRunNumber, this, placeholders::_1))
            ("Sent a new run-number to the boards"
             "|num[int]:Run number");

        T::AddEvent("SET_MAX_MEMORY", "S:1")
            (bind(&StateMachineFAD::SetMaxMemoryBuffer, this, placeholders::_1))
            ("Set maximum memory buffer size allowed to be consumed by the EventBuilder to buffer events."
             "|memory[short]:Buffer size in Mega-bytes.");

        T::AddEvent("SET_EVENT_TIMEOUT", "S:1")
            (bind(&StateMachineFAD::SetEventTimeoutSec, this, placeholders::_1))
            ("Set the timeout after which an event expires which was not completely received yet."
             "|timeout[sec]:Timeout in seconds [1;32767]");

        T::AddEvent("SET_REGISTER", "I:2", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SetRegister, this, placeholders::_1))
            ("set register to value"
            "|addr[short]:Address of register"
            "|val[short]:Value to be set");

        // FIXME:  Maybe add a mask which channels should be set?
        T::AddEvent("SET_REGION_OF_INTEREST", "I:2", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SetRoi, this, placeholders::_1))
            ("Set region-of-interest to value"
            "|channel[short]:Channel on each chip for which the ROI is set (0-8), -1 for all"
            "|val[short]:Value to be set");

        // FIXME:  Maybe add a mask which channels should be set?
        T::AddEvent("SET_DAC_VALUE", "I:2", FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::SetDac, this, placeholders::_1))
            ("Set DAC numbers in range to value"
            "|addr[short]:Address of register (-1 for all)"
            "|val[short]:Value to be set");

        T::AddEvent("CONFIGURE", "X:2;C", FAD::State::kConnected, FAD::State::kConfigured, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::StartConfigure, this, placeholders::_1))
            ("Configure a new run. If the internla trigger is enabled this might even start a new run."
             "|time_max[s]:Maximum time before the run is closed in seconds (0: unlimited)"
             "|num_max[int]:Maximum number of events before the run is closed in seconds (0: unlimited)"
             "|run_type[string]:Run type which describes the runs");

        T::AddEvent("RESET_CONFIGURE", FAD::State::kConfiguring1, FAD::State::kConfiguring2, FAD::State::kConfiguring3, FAD::State::kConfigured)
            (bind(&StateMachineFAD::ResetConfig, this))
            ("If configuration failed and the fadctrl is waiting for something, use this to reset the state.");

        // Verbosity commands
        T::AddEvent("SET_VERBOSE", "B:1")
            (bind(&StateMachineFAD::SetVerbosity, this, placeholders::_1))
            ("Set verbosity state"
             "|verbosity[bool]:disable or enable verbosity for received data (yes/no), except dynamic data");

        T::AddEvent("SET_HEX_OUTPUT", "B:1")
            (bind(&StateMachineFAD::SetHexOutput, this, placeholders::_1))
            ("Enable or disable hex output for received data"
             "|hexout[bool]:disable or enable hex output for received data (yes/no)");

        T::AddEvent("SET_DATA_OUTPUT", "B:1")
            (bind(&StateMachineFAD::SetDataOutput, this, placeholders::_1))
            ("Enable or disable printing of the received adc data to the console"
             "|dataout[bool]:disable or enable data output for received data (yes/no)");

        T::AddEvent("SET_DEBUG_TX", "B:1")
            (bind(&StateMachineFAD::SetDebugTx, this, placeholders::_1))
            ("Enable or disable the output of messages in case of successfull data transmission to the boards."
             "|debug[bool]:disable or enable debug output for transmitted data (yes/no)");

        T::AddEvent("PRINT_EVENT", "S:1")
            (bind(&StateMachineFAD::PrintEvent, this, placeholders::_1))
            ("Print (last) event"
             "|board[short]:slot from which the event should be printed (-1 for all)");

        T::AddEvent("BLOCK_TRANSMISSION", "S:1;B:1")
            (bind(&StateMachineFAD::SetBlockTransmission, this, placeholders::_1))
            ("Blocks the transmission of commands to the given slot. Use with care! For debugging pupose only!"
             "|slot[short]:Slot to which the command transmission should be blocked (0-39)"
             "|enable[bool]:Whether the command transmission should be blockes (yes) or allowed (no)");

        T::AddEvent("BLOCK_TRANSMISSION_RANGE", "S:2;B:1")
            (bind(&StateMachineFAD::SetBlockTransmissionRange, this, placeholders::_1))
            ("Blocks the transmission of commands to the given range of slots. Use with care! For debugging pupose only!"
             "|first[short]:First slot to which the command transmission should be blocked (0-39)"
             "|last[short]:Last slot to which the command transmission should be blocked (0-39)"
             "|enable[bool]:Whether the command transmission should be blockes (yes) or allowed (no)");

        T::AddEvent("IGNORE_EVENTS", "S:1;B:1")
            (bind(&StateMachineFAD::SetIgnoreSlot, this, placeholders::_1))
            ("Instructs the event-builder to ignore events from the given slot but still read the data from the socket."
             "|slot[short]:Slot from which the data should be ignored when building events"
             "|enable[bool]:Whether the event builder should ignore data from this slot (yes) or allowed (no)");

        T::AddEvent("IGNORE_EVENTS_RANGE", "S:2;B:1")
            (bind(&StateMachineFAD::SetIgnoreSlots, this, placeholders::_1))
            ("Instructs the event-builder to ignore events from the given slot but still read the data from the socket."
             "|first[short]:First slot from which the data should be ignored when building events"
             "|last[short]:Last slot from which the data should be ignored when building events"
             "|enable[bool]:Whether the event builder should ignore data from this slot (yes) or allowed (no)");

        T::AddEvent("CLOSE_OPEN_FILES", FAD::State::kDisconnected, FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::CloseOpenFiles, this))
            ("Close all run files opened by the EventBuilder.");

        //T::AddEvent("TEST", "S:1")
        //   (bind(&StateMachineFAD::Test, this, placeholders::_1))
        //    ("");



        // Conenction commands
        T::AddEvent("START", FAD::State::kOffline)
            (bind(&StateMachineFAD::StartConnection, this))
            ("Start EventBuilder thread and connect all valid slots.");

        T::AddEvent("STOP",  FAD::State::kDisconnected, FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::StopConnection, this))
            ("Stop EventBuilder thread (still write buffered events) and disconnect all slots.");

        T::AddEvent("ABORT", FAD::State::kDisconnected, FAD::State::kConnecting, FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::AbortConnection, this))
            ("Immediately abort EventBuilder thread and disconnect all slots.");

        T::AddEvent("SOFT_RESET", FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::Reset, this, true))
            ("Wait for buffers to drain, close all files and reinitialize event builder thread.");

        T::AddEvent("HARD_RESET", FAD::State::kConnected, FAD::State::kRunInProgress)
            (bind(&StateMachineFAD::Reset, this, false))
            ("Free all buffers, close all files and reinitialize event builder thread.");

        T::AddEvent("CONNECT", "S:1", FAD::State::kDisconnected, FAD::State::kConnecting, FAD::State::kConnected)
            (bind(&StateMachineFAD::EnableSlot, this, placeholders::_1, true))
            ("Connect a disconnected slot.");

        T::AddEvent("DISCONNECT", "S:1", FAD::State::kConnecting, FAD::State::kConnected)
            (bind(&StateMachineFAD::EnableSlot, this, placeholders::_1, false))
            ("Disconnect a connected slot.");

        T::AddEvent("TOGGLE", "S:1", FAD::State::kDisconnected, FAD::State::kConnecting, FAD::State::kConnected)
            (bind(&StateMachineFAD::ToggleSlot, this, placeholders::_1))
            ("Toggle the status of a slot.");

        T::AddEvent("SET_FILE_FORMAT", "S:1")
            (bind(&StateMachineFAD::SetFileFormat, this, placeholders::_1))
            ("Set the output file format (see FAD::FileFormat_t)");

        T::AddEvent("START_DRS_CALIBRATION")
            (bind(&StateMachineFAD::StartDrsCalibration, this))
            ("Start a drs calibration (shortcut for SET_FILEFORMAT 4)");

        T::AddEvent("RESET_SECONDARY_DRS_BASELINE")
            (bind(&StateMachineFAD::ResetSecondaryDrsBaseline, this))
            ("Reset the secondary drs baseline (e.g. to change roi)");

        T::AddEvent("LOAD_DRS_CALIBRATION", "C")
            (bind(&StateMachineFAD::LoadDrsCalibration, this, placeholders::_1))
            ("Load a DRS calibration file"
             "|absolute path");


        // --------- Setup compression of FITS files -----------
        T::AddEvent("SET_ZFITS_DEFAULT_NUM_THREADS", "S")
            (bind(&StateMachineFAD::SetupZFits, this, placeholders::_1, zofits::DefaultNumThreads))
            ("Set the number of compression threads to use (+1 for writing)"
             "|num[int]:Number of threads");
        T::AddEvent("SET_ZFITS_DEFAULT_MAX_MEMORY", "S")
            (bind(&StateMachineFAD::SetupZFits, this, placeholders::_1, zofits::DefaultMaxMemory))
            ("Set the maximum amount of memory zfits will use for compression"
             "|mem[int]:Memory in MB");
        T::AddEvent("SET_ZFITS_DEFAULT_NUM_TILES", "S")
            (bind(&StateMachineFAD::SetupZFits, this, placeholders::_1, zofits::DefaultMaxNumTiles))
            ("Set the number of tiles with which the catalog is initialized"
             "|num[int]:Number of tiles");
        T::AddEvent("SET_ZFITS_DEFAULT_ROWS_PER_TILE", "S")
            (bind(&StateMachineFAD::SetupZFits, this, placeholders::_1, zofits::DefaultNumRowsPerTile))
            ("Set the number of rows which are compressed into one tile"
             "|num[int]:Number of rows per tile");


        T::AddEvent("ADD_ADDRESS", "C", FAD::State::kOffline)
            (bind(&StateMachineFAD::AddAddress, this, placeholders::_1))
            ("Add the address of a DRS4 board to the first free slot"
             "|IP[string]:address in the format <address:port>");
        T::AddEvent("REMOVE_SLOT", "S:1", FAD::State::kOffline)
            (bind(&StateMachineFAD::RemoveSlot, this, placeholders::_1))
            ("Remove the Iaddress in slot n. For a list see LIST"
             "|slot[short]:Remove the address in slot n from the list");
        T::AddEvent("LIST_SLOTS")
            (bind(&StateMachineFAD::ListSlots, this))
            ("Print a list of all available board addressesa and whether they are enabled");
    }

Here is the call graph for this function: