template<class T>

int StateMachineFAD< T >::Execute ( )

inlineprivatevirtual

Implements StateMachineAsio< T >.

Definition at line 1399 of file fadctrl.cc.

References ConnectionFAD::Cmd(), ConnectionFAD::IsConfigured(), Connection::IsConnected(), Connection::IsConnecting(), Connection::IsDisconnected(), kCmdBusyOn, kCmdContTrigger, kCmdResetEventCounter, kCmdSingleTrigger, kCmdSocket, MCP::State::kConfigured, FTM::State::kConfiguring1, FTM::State::kConfiguring2, MCP::State::kConfiguring3, Agilent::State::kConnected, BIAS::State::kConnecting, and Agilent::State::kDisconnected.

    {
        // ===== Evaluate connection status =====

        uint16_t nclosed1     = 0;
        uint16_t nconnecting1 = 0;
        uint16_t nconnecting2 = 0;
        uint16_t nconnected1  = 0;
        uint16_t nconnected2  = 0;
        uint16_t nconfigured  = 0;

        vector<uint8_t> stat1(40);
        vector<uint8_t> stat2(40);

        int cnt = 0; // counter for enabled board

        const bool runs = IsThreadRunning();

        for (int idx=0; idx<40; idx++)
        {
            // ----- Command socket -----
            const BoardList::const_iterator &slot = fBoards.find(idx);
            if (slot!=fBoards.end())
            {
                const ConnectionFAD *c = slot->second;
                if (c->IsDisconnected())
                {
                    stat1[idx] = 0;
                    nclosed1++;

                    //DisconnectSlot(idx);
                }
                if (c->IsConnecting())
                {
                    stat1[idx] = 1;
                    nconnecting1++;
                }
                if (c->IsConnected())
                {
                    stat1[idx] = 2;
                    nconnected1++;

                    if (c->IsConfigured())
                    {
                        stat1[idx] = 3;
                        nconfigured++;
                    }
                }

                cnt++;
            }

            // ----- Event builder -----

            stat2[idx] = 0; // disconnected
            if (!runs)
                continue;

            if (IsConnecting(idx))
            {
                nconnecting2++;
                stat2[idx] = 1; // connecting
            }

            if (IsConnected(idx))
            {
                nconnected2++;
                stat2[idx] = 8; // connected
            }
        }

        // ===== Send connection status via dim =====

        if (fStatus1!=stat1 || fStatus2!=stat2 || fStatusT!=runs)
        {
            fStatus1 = stat1;
            fStatus2 = stat2;
            fStatusT = runs;
            UpdateConnectionStatus(stat1, stat2, runs);
        }

        // ===== Return connection status =====

        // Keep the state during reconnection (theoretically, can only be WritingData)
/*        if (fReconnectionList.size()>0)
        {
            bool isnew = true;
            for (auto it=fReconnectionList.begin(); it!=fReconnectionList.end(); it++)
                if (it->state>0)
                {
                    isnew = false;
                    break;
                }

            if (isnew)
            {
                for (BoardList::iterator it=fBoards.begin(); it!=fBoards.end(); it++)
                    it->second->Cmd(FAD::kCmdBusyOn, true);  // continously on
            }

            // Loop over all scheduled re-connections
            for (auto it=fReconnectionList.begin(); it!=fReconnectionList.end(); it++)
            {
                if (ProcessReconnection(it))
                    continue;

                const lock_guard<mutex> guard(fMutexReconnect);
                fReconnectionList.erase(it);
            }

            if (fReconnectionList.size()==0)
            {
                for (BoardList::iterator it=fBoards.begin(); it!=fBoards.end(); it++)
                    it->second->Cmd(FAD::kCmdBusyOff, false);
            }

            return T::GetCurrentState();
        }
*/
        // fadctrl:       Always connecting if not disabled
        // event builder:
        if (nconnecting1==0 && nconnected1>0 && nconnected2==nconnected1)
        {
            if (T::GetCurrentState()==FAD::State::kConfiguring1)
            {
                // Wait until the configuration commands to all boards
                // have been sent and achknowledged
                for (BoardList::iterator it=fBoards.begin(); it!=fBoards.end(); it++)
                    if (!it->second->IsTxQueueEmpty())
                        return FAD::State::kConfiguring1;

                // Note that if there are less than 40 boards, this
                // can be so fast that the single trigger still
                // comes to early, and a short watiting is necessary :(

                // Now we can sent the trigger
                for (BoardList::iterator it=fBoards.begin(); it!=fBoards.end(); it++)
                    it->second->Cmd(FAD::kCmdSingleTrigger);

                return FAD::State::kConfiguring2;
            }

            // If all boards are configured and we are configuring
            // go on and start the FADs
            if (T::GetCurrentState()==FAD::State::kConfiguring2)
            {
                // If not all boards have yet received the proper
                // configuration
                if (nconfigured!=nconnected1)
                    return FAD::State::kConfiguring2;

                // FIXME: Distinguish between not all boards have received
                // the configuration and the configuration is not consistent

                for (BoardList::iterator it=fBoards.begin(); it!=fBoards.end(); it++)
                {
                    ConnectionFAD &fad  = *it->second;

                    // Make sure that after switching on the trigger line
                    // there needs to be some waiting before all boards
                    // can be assumed to be listening
                    fad.Cmd(FAD::kCmdResetEventCounter);
                    fad.Cmd(FAD::kCmdSocket,      false);
                    //fad.Cmd(FAD::kCmdTriggerLine, true);
                    if (fTargetConfig->second.fContinousTrigger)
                        fad.Cmd(FAD::kCmdContTrigger, true);
                    fad.Cmd(FAD::kCmdBusyOn,      false);  // continously on

                    // FIXME: How do we find out when the FADs
                    //        successfully enabled the trigger lines?
                }

//                const lock_guard<mutex> guard(fMutexReconnect);
//                fReconnectionList.clear();

                return FAD::State::kConfiguring3;
            }

            if (T::GetCurrentState()==FAD::State::kConfiguring3)
            {
                // Wait until the configuration commands to all boards
                // have been sent and achknowledged
                for (BoardList::iterator it=fBoards.begin(); it!=fBoards.end(); it++)
                    if (!it->second->IsTxQueueEmpty())
                        return FAD::State::kConfiguring3;

                return FAD::State::kConfigured;
            }

            if (T::GetCurrentState()==FAD::State::kConfigured)
            {
                // Stay in Configured as long as we have a valid
                // configuration and the run has not yet been started
                // (means the the event builder has received its
                // first event)
                if (IsRunWaiting() && nconfigured==nconnected1)
                    return FAD::State::kConfigured;

                if (!IsRunWaiting())
                    T::Message("Run successfully started... first data received.");
                if (nconfigured!=nconnected1)
                    T::Message("Configuration of some boards changed.");
            }

            // FIXME: Rename WritingData to TakingData
            return IsRunInProgress() ? FAD::State::kRunInProgress : FAD::State::kConnected;
        }

        if (nconnecting1>0 || nconnecting2>0 || nconnected1!=nconnected2)
            return FAD::State::kConnecting;

        // nconnected1 == nconnected2 == 0
        return runs ? FAD::State::kDisconnected : FAD::State::kOffline;
    }

Here is the call graph for this function: