TGo4MBSViewer.cpp

Go to the documentation of this file.

// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------

#include "TGo4MBSViewer.h"

#include  <iostream>

#include "TH1.h"

#include "TGo4Slot.h"
#include "TGo4BrowserProxy.h"
#include "TGo4QSettings.h"

#include <QTimer>
#include <QDateTime>
#include <QButtonGroup>
#include <QMovie>

extern "C"
{
   #include "f_stccomm.h"
   #include "f_mbs_status.h"
   #include "f_ut_seg_show.h"
}


TGo4MBSViewer::TGo4MBSViewer(QWidget *parent, const char *name) :
   QGo4Widget(parent,name),
   fxRunMovie(nullptr)
{
   setupUi(this);

   QObject::connect(FullPrintButton, &QPushButton::clicked, this, &TGo4MBSViewer::PrintState);
   QObject::connect(MonitorButton, &QPushButton::clicked, this, &TGo4MBSViewer::TimerStart);
   QObject::connect(StopButton, &QPushButton::clicked, this, &TGo4MBSViewer::TimerStop);
   QObject::connect(RefreshButton, &QPushButton::clicked, this, &TGo4MBSViewer::RefreshButtonClick);
   QObject::connect(NodeEdit, &QGo4LineEdit::returnPressed, this, &TGo4MBSViewer::NodeEditEnter);
   QObject::connect(NodeEdit, &QGo4LineEdit::textChanged, this, &TGo4MBSViewer::NodeChanged);
   QObject::connect(TrendCheck, &QCheckBox::toggled, this, &TGo4MBSViewer::TrendSwitched);
   QObject::connect(FrequencyBox, QOverload<int>::of(&QSpinBox::valueChanged), this, &TGo4MBSViewer::FrequencyBox_valueChanged);
   QObject::connect(MoreBox, &QCheckBox::toggled, this, &TGo4MBSViewer::MoreBox_toggled);
   QObject::connect(TrendBinsBox, QOverload<int>::of(&QSpinBox::valueChanged), this, &TGo4MBSViewer::TrendBinsBox_valueChanged);

   // new JAM22:
   QObject::connect(StatusRadio, &QRadioButton::clicked, this, &TGo4MBSViewer::StateGroup_clicked);
   QObject::connect(SetupRadio, &QRadioButton::clicked, this, &TGo4MBSViewer::StateGroup_clicked);
   QObject::connect(SetupMLRadio, &QRadioButton::clicked, this, &TGo4MBSViewer::StateGroup_clicked);
   QObject::connect(SetupMORadio, &QRadioButton::clicked, this, &TGo4MBSViewer::StateGroup_clicked);

   RateEvents->setDigitCount(7);
   SumEvents->setDigitCount(12);
   RateBytes->setDigitCount(7);
   SumBytes->setDigitCount(8);
   ServerPercent->setDigitCount(3);
   SumBytesFile->setDigitCount(9);

   fbIsMonitoring=false;
   fbWarningState=false;
   fbRunning=false;
   fbGetStatus=true;
   fbGetSetup=false;
   fbGetSetML=false;
   fbGetSetMO=false;
   fbTrending=false;
   fbTrendingInit=true;
   fbShowMore=false;
   fbSingleRefresh=false;
   fbTrendingForward=false; // define moving direction of trend histograms
   fiTrendBins=1000;
   // now overwrite some settings:
   SetNode(go4sett->getMbsMonitorNode());
   fbTrending=go4sett->getMbsMonitorTrend();
   TrendCheck->setChecked(fbTrending);
   fiTrendBins=go4sett->getMbsMonitorBins();
   TrendBinsBox->setValue(fiTrendBins);
   fbShowMore=go4sett->getMbsMonitorMore();
   MoreBox->setChecked(fbShowMore);
   FrequencyBox->setValue(go4sett->getMbsMonitorFreq());
   fbTrendingForward=!(go4sett->getMbsMonitorBackwardsTrending());

   fxHistoAccessName = "nosuchobject";
   fxHistokBAccessName = "nosuchobject";
   fxHistoEvRatioAccessName = "nosuchobject";
   fxServerLabel = "NO SERVER";
   fxTimer = new QTimer(this);
   fxMovieResetTimer = new QTimer(this);
   QString moviepath = ":/icons/mbslogorun.gif";
   fxRunMovie = new QMovie(moviepath);
   memset(&fxDaqStat, 0, sizeof(fxDaqStat));
   fiCalcedEventRate = 0;
   fiCalcedDataRate = 0;
   fiCalcedServDataRate = 0;
   fiLastServDataNum = 0;
   fiLastEventNum = 0;
   fiLastDataNum = 0;
   fxDeltaClock.start();
   QObject::connect(fxTimer, &QTimer::timeout, this, &TGo4MBSViewer::Refresh);
   QObject::connect(fxMovieResetTimer, &QTimer::timeout, this, &TGo4MBSViewer::ResetRunIcon);
   Display();

}

TGo4MBSViewer::~TGo4MBSViewer()
{
   delete fxRunMovie;
}


void TGo4MBSViewer::StoreSettings()
{
   // save  settings:
   go4sett->setMbsMonitorNode(fxNode);
   go4sett->setMbsMonitorTrend(fbTrending);
   go4sett->setMbsMonitorBins(fiTrendBins);
   go4sett->setMbsMonitorMore(fbShowMore);
   go4sett->setMbsMonitorFreq(FrequencyBox->value());
   go4sett->setMbsMonitorMonitorActive(fbIsMonitoring);
   go4sett->setMbsMonitorBackwardsTrending(!fbTrendingForward);
}


void TGo4MBSViewer::TimerStart()
{
   fbIsMonitoring = true;
   fbTrendingInit = true;
   fiLastEventNum = 0;
   fiLastDataNum = 0;
   fiLastServDataNum = 0;
   Refresh();
   fxTimer->start(1000 * FrequencyBox->value());
   Display();
   StoreSettings();
}

void TGo4MBSViewer::TimerStop()
{
   fbIsMonitoring=false;
   fxTimer->stop();
   StartMovieReset();
   Display();
   StoreSettings();
}


void TGo4MBSViewer::Display()
{
   setWindowTitle("MBS Status - "+NodeEdit->text());
   if(!fbSingleRefresh)
   {
      NodeEdit->setEnabled(!fbIsMonitoring);
      MonitorButton->setEnabled(!fbIsMonitoring);
      StopButton->setEnabled(fbIsMonitoring);
      FrequencyBox->setEnabled(!fbIsMonitoring);
      //TrendCheck->setEnabled(!fbIsMonitoring);
      TrendBinsBox->setEnabled(!fbTrending);
   }
   MoreFrame->setVisible(fbShowMore);
   SumEvents->display((double) fxDaqStat.bl_n_events);
   //RateEvents->display((double) fxDaqStat.bl_r_events);
   RateEvents->display((double) fiCalcedEventRate);
   SumBytes->display((double) ((unsigned int) fxDaqStat.bl_n_kbyte/1024));
   //RateBytes->display((double) fxDaqStat.bl_r_kbyte);
   RateBytes->display((double) fiCalcedDataRate);
   DateLabel->setText(fxRefTime);
   SumBytesFile->display((double) ((unsigned int) fxDaqStat.bl_n_kbyte_file/1024));

   if(fxDaqStat.l_open_file)
      OutfileLabel->setText(fxDaqStat.c_file_name);
   else
      OutfileLabel->setText("- file closed -");

   ServerLabel->setText(fxServerLabel);
   ServerPercent->display((int) fiEvRatio);
   if(fbRunning && !fbWarningState){
      RunPix->clear();
      RunPix->setMovie(fxRunMovie);
      fxRunMovie->start();
   }
   else{
      RunPix->setWindowIcon(QIcon( ":/icons/mbsbutton.png" ));
      if(fxRunMovie) fxRunMovie->stop();
   }
   WarnPix->setVisible(fbWarningState);

   // put here enable/disable setup buttons:
   SetupRadio->setEnabled(fxDaqStat.bh_setup_loaded);
   SetupMLRadio->setEnabled(fxDaqStat.bh_set_ml_loaded);
   SetupMORadio->setEnabled(fxDaqStat.bh_set_mo_loaded);
   if(fbWarningState)
      std::cerr <<fxMessage.toLatin1().constData() << std::endl;

   ensurePolished();
   update();
   show();
}


void TGo4MBSViewer::Refresh()
{
   // for the ratemeter and running state, we always get status block
   if(fxNode.isEmpty()) return;
   int state=f_mbs_status(const_cast<char *>(fxNode.toLatin1().constData()), &fxDaqStat);
   if(state!=STC__SUCCESS) {
      fxMessage = QString("MBS Status refresh node %1 returned error %2 at ").arg(fxNode).arg(state);
      fxMessage += QDateTime::currentDateTime().toString();
      fbWarningState = true;
   } else
      fbWarningState = false;
   //fxRefTime=QDateTime::currentDateTime ().toString();
   fxRefTime=fxDaqStat.c_date;
   fbRunning=fxDaqStat.bh_acqui_running;
   int deltat=FrequencyBox->value();
   int numperiods=1;
   int deltamilsecs=deltat*1000.0; // default
   if(fbIsMonitoring)
   {
      // only in monitoring mode: calculate rates ourselves, independent of mbs ratemter:
      // NEW: first check real time diff since last call and correct rates:
      deltamilsecs=fxDeltaClock.elapsed();
      fxDeltaClock.restart();
      int deltasecs=deltamilsecs/1000;
      if(!fbTrendingInit && (deltasecs>=deltat*2))
         //if((deltasecs>=deltat*2)) // this one was for testing JAM
      {
         std::cout <<"Warning: MBS monitor found measuring interval:"<<deltasecs<<" s ("<<deltamilsecs <<" ms) exceeding timer period "<<deltat<<" s" << std::endl;
         std::cout <<" Maybe timer was skipped?" << std::endl;
         deltat=deltasecs;
         numperiods=(deltat/ (int) FrequencyBox->value());
         std::cout <<" Correcting number of measuring periods to:"<<numperiods << std::endl;
      }
      if(fiLastEventNum && deltamilsecs)
         fiCalcedEventRate = 1000.*(fxDaqStat.bl_n_events-fiLastEventNum)/deltamilsecs;
      else
         fiCalcedEventRate = 0;
      fiLastEventNum=fxDaqStat.bl_n_events;

      if(fiLastDataNum && deltamilsecs)
      {
         fiDataDelta = (fxDaqStat.bl_n_kbyte-fiLastDataNum);
         fiCalcedDataRate = 1000.*fiDataDelta/deltamilsecs;
      }
      else
      {
         fiDataDelta = 0;
         fiCalcedDataRate = 0;
      }
      fiLastDataNum=fxDaqStat.bl_n_kbyte;
      //    std::cout <<"Data rate:"<<fiCalcedDataRate << std::endl;
      //    std::cout <<"Data total:"<<fiLastDataNum << std::endl;
   }
   else
   {
      // single refresh on button press: use momentary mbs rate
      fiCalcedEventRate = fxDaqStat.bl_r_events;
      fiCalcedDataRate = fxDaqStat.bl_r_kbyte;
   }

   if(fxDaqStat.bh_running[SYS__stream_serv])
   {
      fxServerLabel = QString("streamserver %1%2").arg((int)(fxDaqStat.bl_strsrv_scale != 0 ? 100/fxDaqStat.bl_strsrv_scale : 0)).arg("%");

      if(fbIsMonitoring)
      {
         // own rate calculation for monitoring on:
         if(fiLastServDataNum && deltamilsecs)
         {
            fiServDataDelta=(fxDaqStat.bl_n_strserv_kbytes-fiLastServDataNum);
            fiCalcedServDataRate=1000.*fiServDataDelta/deltamilsecs;
         }
         else
         {
            fiServDataDelta = 0;
            fiCalcedServDataRate = 0;
         }
         //            std::cout <<"Streamserver rate:"<<fiCalcedServDataRate << std::endl;
         //            std::cout <<"Streamserver data:"<<fxDaqStat.bl_n_strserv_kbytes << std::endl;
         //            std::cout <<"Streamserver last data:"<<fiLastServDataNum << std::endl;
         //            std::cout <<"dt:"<<deltat << std::endl;
         fiLastServDataNum=fxDaqStat.bl_n_strserv_kbytes;
      }
      else
      {
         // single refresh: use ratio from current mbs calculated rates
         fiCalcedServDataRate = fxDaqStat.bl_r_strserv_kbytes;
         fiDataDelta = 0;
      }
      //fiEvRatio= (fiCalcedDataRate != 0 ? 100* fiCalcedServDataRate /fiCalcedDataRate : 0);
      //int curentratio=(fiCalcedDataRate != 0 ? 100* fiCalcedServDataRate /fiCalcedDataRate : 0);
      fiEvRatio = (fiDataDelta != 0 ? 100* fiServDataDelta /fiDataDelta : 0);
   }
   else if(fxDaqStat.bh_running[SYS__event_serv])
   {
      // calculate momentary rate for eventserver:

      fxServerLabel = QString("eventserver %1 %2%3")
            .arg(fxDaqStat.bh_event_serv_ready ? "R" : "S")
            .arg((int)(fxDaqStat.bl_evtsrv_scale != 0 ? 100/fxDaqStat.bl_evtsrv_scale : 0)).arg("%");
      if(fbIsMonitoring)
      {
         // own rate calculation for monitoring on:
         if(fiLastServDataNum && deltamilsecs)
         {
            fiServDataDelta=(fxDaqStat.bl_n_evserv_kbytes-fiLastServDataNum);
            fiCalcedServDataRate=1000.0*fiServDataDelta/deltamilsecs;
         }
         else
         {
            fiServDataDelta = 0;
            fiCalcedServDataRate = 0;
         }
         fiLastServDataNum = fxDaqStat.bl_n_evserv_kbytes;
      }
      else
      {
         // single refresh: use ratio from current mbs calculated rates
         fiCalcedServDataRate = fxDaqStat.bl_r_evserv_kbytes;
         fiDataDelta = 0;
      }
      //fiEvRatio= (fiCalcedDataRate != 0 ? 100* fiCalcedServDataRate /fiCalcedDataRate : 0);
      fiEvRatio= (fiDataDelta != 0 ? 100* fiServDataDelta /fiDataDelta : 0);

   }
   else
   {
      fxServerLabel = "NO SERVER";
      fiEvRatio = 0;
   }

   if(fbTrending && !fbWarningState && fbIsMonitoring)
   {
      while((numperiods--) > 0)
      {
         UpdateTrending(); // use same values for all skipped periods
      }
   }
   StartMovieReset();
   Display();
   //f_ut_seg_show (&fxDaqStat,0,0,0);
}

void TGo4MBSViewer::NodeEditEnter()
{
   Refresh();
}


void TGo4MBSViewer::NodeChanged( const QString & txt )
{
   fxNode = txt.trimmed();
}

void TGo4MBSViewer::ShowStatus()
{
   if(fbWarningState)
   {
      std::cout <<fxMessage.toLatin1().constData()  << std::endl;
   }
   else
   {
      std::cout <<"\n------------------------------------------------" << std::endl;
      if(fbGetStatus)
         f_ut_seg_show (&fxDaqStat,nullptr,nullptr,nullptr);
      if(fbGetSetup)
         f_ut_seg_show (nullptr,&fxSetup,nullptr,nullptr);
      else if(fbGetSetML)
         f_ut_seg_show (nullptr,nullptr,&fxSetupML,nullptr);
      else if(fbGetSetMO)
         f_ut_seg_show (nullptr,nullptr,nullptr,&fxSetupMO);
   }
}

void TGo4MBSViewer::StateGroup_clicked( int id)
{
   // JAM23-11-2022: do the old complicated attempt a bit better:
   fbGetStatus=StatusRadio->isChecked();
   fbGetSetup=SetupRadio->isChecked();
   fbGetSetML=SetupMLRadio->isChecked();
   fbGetSetMO=SetupMORadio->isChecked();
//   printf("StateGroup_clicked: fbGetStatus=%d, fbGetSetup=%d, fbGetSetML=%d, fbGetSetMO=%d\n",
//       fbGetStatus,fbGetSetup, fbGetSetML, fbGetSetMO);
}


void TGo4MBSViewer::PrintState()
{
   if(fxNode.isEmpty()) return;
   if(fbGetSetup)
   {
      // request setup if selected

      int state = f_mbs_setup(const_cast<char *>(fxNode.toLatin1().constData()), &fxSetup);
      if(state)
      {
         fxMessage = QString("MBS Setup refresh returned error %1 at %2").arg(state).arg(QDateTime::currentDateTime().toString());
         fbWarningState = true;
      }
      else
         fbWarningState=false;
   }

   else if(fbGetSetML)
   {
      // request setup multilayer if selected
      int state = f_mbs_ml_setup(const_cast<char *>(fxNode.toLatin1().constData()), &fxSetupML);
      if(state != 0)
      {
         fxMessage = QString("MBS Setup ML refresh returned error %1 at %2").arg(state).arg(QDateTime::currentDateTime().toString());
         fbWarningState = true;
      }
      else
         fbWarningState = false;
   }
   else if(fbGetSetMO)
   {
      // request setup MO if selected
      int state = f_mbs_mo_setup(const_cast<char *>(fxNode.toLatin1().constData()), &fxSetupMO);
      if(state != 0)
      {
         fxMessage = QString("MBS Setup MO refresh returned error %1 at %2").arg(state).arg(QDateTime::currentDateTime().toString());
         fbWarningState = true;
      }
      else
         fbWarningState = false;
   }

   else {}
   RefreshButtonClick(); // always get new status structure and display on window
   ShowStatus();
}


void TGo4MBSViewer::TrendSwitched( bool on )
{
   if(!fbTrending) fbTrendingInit=true;
   fbTrending=on;
   go4sett->setMbsMonitorTrend(fbTrending);
   Display();
}


void TGo4MBSViewer::UpdateTrending()
{
   TrendHisto(fxHistoAccessName, "MbsEventRate", "Events/s", fiCalcedEventRate);
   TrendHisto(fxHistokBAccessName, "MbsDataRate", "kB/s", fiCalcedDataRate);
   TrendHisto(fxHistoEvRatioAccessName, fxServerLabel.section(' ',0,0), "% Events served", fiEvRatio);
   fbTrendingInit = false;
}


void TGo4MBSViewer::IncTrending( TH1 *histo, int value, bool forwards )
{
   if(!histo) return;
   int bins=histo->GetNbinsX();
   //bool forwards=true;
   int j,dj;
   if(forwards)
      dj=-1;
   else
      dj=+1;
   for (int i = 0; i < bins; i++) {
      if (forwards)
         j = bins - i;
      else
         j = i;
      int oldval = histo->GetBinContent(j + dj);
      histo->SetBinContent(j, oldval);
   }
   histo->SetBinContent(j + dj, value);
}


void TGo4MBSViewer::FrequencyBox_valueChanged(int)
{
   fbTrendingInit=true;
}


TH1 *TGo4MBSViewer::TrendHisto( QString & refname ,const QString & name, const QString & title, int value)
{
   TH1 *his = nullptr;
   TGo4Slot *histoslot = nullptr;
   if(!fbTrendingInit) histoslot = Browser()->BrowserSlot(refname.toLatin1());
   if(!histoslot) {
      Axis_t lo,up;
      if (fbTrendingForward) {
         lo = 0;
         up = 1 * fiTrendBins * FrequencyBox->value();
      } else {
         lo = -1 * fiTrendBins * FrequencyBox->value();
         up = 0;
      }
      his = new TH1F(name.toLatin1(), title.toLatin1(), fiTrendBins, lo, up);
      TAxis *xax = his->GetXaxis();
      xax->SetTitle("s");
      xax->CenterTitle();
      //xax->SetLimits(0,lo,up);

      TGo4Slot *hisdataslot=Browser()->DataSlot(refname.toLatin1());
      if (hisdataslot) {
         hisdataslot->AssignObject(his, true);
      } else {
         refname = Browser()->SaveToMemory("Mbs", his, true);
      }
      histoslot = Browser()->BrowserSlot(refname.toLatin1());
   }
   else
   {
      his = dynamic_cast<TH1 *>(histoslot->GetAssignedObject());
   }
   IncTrending(his,value,fbTrendingForward);
   if(histoslot)
   {
      histoslot->ForwardEvent(histoslot, TGo4Slot::evObjUpdated);
      Browser()->SetItemTimeDate(histoslot);
   }
   return his;
}


void TGo4MBSViewer::MoreBox_toggled( bool on)
{
   fbShowMore=on;
   go4sett->setMbsMonitorMore(fbShowMore);
   Display();
}


void TGo4MBSViewer::TrendBinsBox_valueChanged( int i)
{
   fiTrendBins=i;
   fbTrendingInit=true;
}


void TGo4MBSViewer::RefreshButtonClick()
{
   bool trend=fbTrending;
   bool monitoring=fbIsMonitoring;
   fbTrending=false; // avoid to put direct refresh into the trending histogram
   fbIsMonitoring=false; // avoid confuse rate calculations
   fbSingleRefresh=true; // avoid changing state of control buttons
   Refresh();
   fbSingleRefresh=false;
   fbIsMonitoring=monitoring;
   fbTrending=trend;

}

void TGo4MBSViewer::SetNode( const QString & txt )
{
   fxNode=txt;
   NodeEdit->setText(txt);
}


void TGo4MBSViewer::ResetRunIcon()
{
   fbRunning=false;
   Display();
}

void TGo4MBSViewer::StartMovieReset()
{
   if(!fbIsMonitoring) {
      fxMovieResetTimer->setSingleShot(true);
      fxMovieResetTimer->start(2000);
   }
}