TGo4DabcMonitor.cpp

Go to the documentation of this file.

// $Id: TGo4DabcMonitor.cpp 1483 2015-06-03 14:19:49Z linev $
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum für 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 "TGo4DabcMonitor.h"

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

#include <QDateTime>
#include <QtCore/QTimer>

#include "TH1.h"

#include <iostream>


void TGo4DabcInfo::infoHandler()
{
   fxOwner->infoUpdated(this);
}

void TGo4DabcNodesInfo::infoHandler()
{
   fxOwner->nodesUpdated(this);
}


void TGo4DabcServiceInfo::infoHandler()
{
   fxOwner->servicesUpdated(this);
}

void TGo4DabcStateInfo::infoHandler()
{
   fxOwner->stateUpdated(this);
}

void TGo4DabcRateInfo::infoHandler()
{
   fxOwner->rateUpdated(this);
}


TGo4DabcMonitor::TGo4DabcMonitor( QWidget* parent, const char* name)
   : QGo4Widget(parent,name)
{
   setupUi(this);


   strncpy(gNolinkStateRecord.status,"not available",16);
   gNolinkRateRecord.value=-1.0;
   fxServerInfo = 0;
   fxLastTimestamp = 0;
   fbRebuildNodeTable=true;
   fbDisplayNodeTable=false;
   fbRebuildRateTable=true;
   fbDisplayRateTable=false;

   fbTableBeingCreated=false;


   NodeTable->setColumnCount(5);
   //NodeTable->setLeftMargin(0);

   NodeTable->setColumnHidden( DABCMON_NODE_INDEXCOL, true) ;
   NodeTable->setColumnWidth ( DABCMON_NODE_INDEXCOL, 1) ;

   //NodeTable->setColumnReadOnly (DABCMON_NODE_NODECOL,true );
   //NodeTable->setColumnReadOnly (DABCMON_NODE_STATECOL,true );
   //NodeTable->setColumnReadOnly (DABCMON_NODE_INDEXCOL,true );
   NodeTable->setHorizontalHeaderItem(DABCMON_NODE_NODECOL, new QTableWidgetItem(tr( "Context" ) ));
   NodeTable->setHorizontalHeaderItem(DABCMON_NODE_STATECOL, new QTableWidgetItem( tr( "State" ) ));
   NodeTable->setHorizontalHeaderItem(DABCMON_NODE_CHECKCOL , new QTableWidgetItem( tr( "Ratemeters" ) ));
   NodeTable->setHorizontalHeaderItem(DABCMON_NODE_LOGCOL, new QTableWidgetItem( tr( "Service list" ) ));

   RateTable->setColumnCount(5);
   //RateTable->setLeftMargin(0);
   RateTable->setColumnHidden( DABCMON_RATE_INDEXCOL, true) ;
   RateTable->setColumnWidth ( DABCMON_RATE_INDEXCOL,1) ;
   //RateTable->setColumnReadOnly (DABCMON_RATE_NAMECOL,true );
   //RateTable->setColumnReadOnly (DABCMON_RATE_RATECOL,true );
   //RateTable->setColumnReadOnly (DABCMON_RATE_INDEXCOL,true );
   RateTable->setHorizontalHeaderItem(DABCMON_RATE_NAMECOL, new QTableWidgetItem(tr( "Name" ) ));
   RateTable->setHorizontalHeaderItem(DABCMON_RATE_RATECOL, new QTableWidgetItem(tr( "Value" ) ));
   RateTable->setHorizontalHeaderItem(DABCMON_RATE_TRENDCOL, new QTableWidgetItem(tr( "Trending" ) ));
   RateTable->setHorizontalHeaderItem(DABCMON_RATE_STATSCOL, new QTableWidgetItem(tr( "Statistics" ) ));
   FullPrintDIMButton->setDisabled(true);
   dimServiceFilterEdit->setDisabled(true);




   fxDabcNodes.clear();
   fxServices.clear();
   fxRates.clear();
   fxStates.clear();
   fxShowRateFlags.clear();
   fxShowLogFlags.clear();
   fxTrendingFlags.clear();
   fbTrendingInit.clear();
   fxStatsFlags.clear();
   fbStatsInit.clear();
   fxRateQueues.clear();
   fxTrendHistoRefnames.clear();
   fxStatHistoRefnames.clear();
   fxStateRecords.clear();
   fxRateRecords.clear();
   fxRateSum.clear();
   fxRateCount.clear();
   fxDisplayTimer=new QTimer(this);
   fxDisplayTimer->connect( fxDisplayTimer, SIGNAL(timeout()), this, SLOT(displayAll()) );
   fxDisplayTimer->start(500); // ms period
   fxAverageTimer=new QTimer(this);
   fxAverageTimer->connect( fxAverageTimer, SIGNAL(timeout()), this, SLOT(displayAverageHistograms()));


   fiTrendBins=100;
   fiStatBins=100;
   //TrendBinsBox->setValue(fiTrendBins);
   fbTrendingForward=false;
   fbHistogramming=false;
   fbDisplayHistograms=false;


   QString node=go4sett->getDabcMonitorNode();

   dimDnsNodeEdit->setText(node);
   fiTrendBins=go4sett->getDabcMonitorBins();
   fiStatBins=fiTrendBins;
   TrendBinsBox->setValue(fiTrendBins);
   FrequencyBox->setValue(go4sett->getDabcMonitorFreq());
   fbTrendingForward=!(go4sett->getMbsMonitorBackwardsTrending());


   controlBox->setVisible(false);
   //std::cout<<"found settings: node="<<node<<", bins="<<fiTrendBins<<", forward="<<fbTrendingForward <<std::endl;

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


TGo4DabcMonitor::~TGo4DabcMonitor()
{
}





void TGo4DabcMonitor::storeSettings()
{
   //std::cout<<"storeSettings" <<std::endl;
   go4sett->setDabcMonitorNode(fxDnsNode);
   go4sett->setDabcMonitorBins(fiTrendBins);
   go4sett->setDabcMonitorFreq(FrequencyBox->value());
   go4sett->setDabcMonitorBackwardsTrending(!fbTrendingForward);
}


void TGo4DabcMonitor::refreshDIMSlot()
{
   TGo4LockGuard gard;
   //std::cout<<"refreshDIMSlot()" <<std::endl;
   // first get list of dabc nodes from DIM server
   fxDnsNode = dimDnsNodeEdit->text().trimmed();
   if(fxDnsNode.isEmpty()) return; // avoid crash of DIM with fatal error ;-)
   DimClient::setDnsNode(fxDnsNode.toLatin1().constData());
   if (fxServerInfo!=0) {
      delete fxServerInfo;
      fxServerInfo = 0;
   }

   FullPrintDIMButton->setDisabled(true);
   dimServiceFilterEdit->setDisabled(true);
   fxServerInfo = new TGo4DabcNodesInfo("DIS_DNS/SERVER_LIST",0,"Name server not available", this);
   storeSettings();
}


void TGo4DabcMonitor::logDIMSlot()
{
   TGo4LockGuard gard;
   //std::cout<<"logDIMSlot()" <<std::endl;
   for(int nix=0; nix<fxDabcNodes.size(); ++nix)
   {
      if(fxShowLogFlags[nix] )
      {
         // std::cout<<std::endl<< "retrieving current DIM variables from node "<<fxDabcNodes[nix]<<" ..." <<std::endl;
         createLogServices(nix);
      }
   }
}


void TGo4DabcMonitor::histogramCheckToggled( bool val )
{
   TGo4LockGuard gard;
   //std::cout <<"---------------- histogramCheckToggled to "<<val<< std::endl;
   fbHistogramming=val;
   // better: reset all existing init flags of services!
   if(val)
   {
      for(int nodeix=0;nodeix<fbTrendingInit.size();++nodeix) // dim node index
      {
         std::vector <std::vector <bool> > & nodevec=fbTrendingInit[nodeix];
         for(int rateix=0; rateix<nodevec.size();++rateix) // raterecord index
         {
            std::vector <bool>  & hisvec= nodevec[rateix];
            for (int hisix=0; hisix<hisvec.size();++hisix) // histogram index
            {
               hisvec[hisix]=val;
            }
         }
      }
      for(int nodeix=0;nodeix<fbStatsInit.size();++nodeix)
      {
         std::vector <std::vector <bool> > & nodevec=fbStatsInit[nodeix];
         for(int rateix=0; rateix<nodevec.size();++rateix)
         {
            std::vector <bool>  & hisvec= nodevec[rateix];
            for (int hisix=0; hisix<hisvec.size();++hisix)
            {
               hisvec[hisix]=val;
            }
         }
      }
   } // if val
   // reset average counters:
   for (int nodeix=0;nodeix<fxRateSum.size();++nodeix)
   {
      std::vector<float> & nodevec=fxRateSum[nodeix];
      for(int rateix=0; rateix<nodevec.size();++rateix)
      {
         nodevec[rateix]=0;
      }
   }
   for(int nodeix=0;nodeix<fxRateCount.size();++nodeix)
   {
      std::vector<unsigned int> & nodevec=fxRateCount[nodeix];
      for(int rateix=0; rateix<nodevec.size();++rateix)
      {
         nodevec[rateix]=0;
      }
   }
   TrendBinsBox->setDisabled(val);
   storeSettings();
}


void TGo4DabcMonitor::averageCheckToggled( bool val )
{
   //std::cout <<"---------------- averageCheckToggled to "<<val<< std::endl;
   FrequencyBox->setDisabled(val);
   if(val)
   {
      //std::cout <<"---------------- start timer here"<< std::endl;
      float milsecs=1000*FrequencyBox->value();
      fxAverageTimer->start(milsecs);

   }
   else
   {
      //std::cout <<"---------------- stop timer here"<< std::endl;
      fxAverageTimer->stop();
   }
   storeSettings();
}


void TGo4DabcMonitor::binsizeChanged( int val )
{
   //std::cout <<"---------------- binsizeChanged to "<<val<< std::endl;
   fiTrendBins=val;
   fiStatBins=val;
   //storeSettings();
}





void TGo4DabcMonitor::nodeTableChangedSlot( int row, int column )
{
   TGo4LockGuard gard;
   if(fbTableBeingCreated) return;
   //std::cout<<"nodeTableChangedSlot for " << row<<","<<column <<std::endl;
   // get index from table:
   QString ixtext;
   if (NodeTable->item(row,  DABCMON_NODE_INDEXCOL))
      ixtext = NodeTable->item(row,  DABCMON_NODE_INDEXCOL)->text();
   int ix=ixtext.toInt();
   //std::cout<<"nodeTableChangedSlot for row:"<<row<<" index: " << ix<<", ixtext:"<<ixtext.toLatin1().constData() <<std::endl;
   if(column==DABCMON_NODE_CHECKCOL)
   {
      // get value from table:
      bool on=false;
      QTableWidgetItem* checkitem = NodeTable->item(row,  DABCMON_NODE_CHECKCOL);
      if(checkitem)
         on = (checkitem->checkState() == Qt::Checked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong rate checktableitem at tablerow "<<row <<std::endl;

      // set value to vector
      fxShowRateFlags[ix]=on;
      // now create/delete rate services for this node:
      if(on)
         createRateServices(ix);
      else
         deleteRateServices(ix);
   }
   else if (column==DABCMON_NODE_LOGCOL)
   {
      QTableWidgetItem* checkitem = NodeTable->item(row,  DABCMON_NODE_LOGCOL);
      bool on=false;
      if(checkitem)
         on = (checkitem->checkState() == Qt::Checked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong log checktableitem at tablerow "<<row <<std::endl;
      // set value to vector
      fxShowLogFlags[ix]=on;
      // switch filter and log buttons:
      bool disablebutton=true;
      for(int t=0;t<fxShowLogFlags.size();++t)
      {
         if(fxShowLogFlags[t])
         {
            disablebutton=false;
            break;
         }
      }
      FullPrintDIMButton->setDisabled(disablebutton);
      dimServiceFilterEdit->setDisabled(disablebutton);

   }
}


void TGo4DabcMonitor::rateTableChangedSlot(int row, int column)
{
   TGo4LockGuard gard;
   if(fbTableBeingCreated) return;
   //std::cout<<"rateTableChangedSlot for " << row<<","<<column <<std::endl;
   if(column==DABCMON_RATE_TRENDCOL)
   {
      // get value from table:
      bool on=false;
      QTableWidgetItem* checkitem= RateTable->item(row,  DABCMON_RATE_TRENDCOL);
      if(checkitem)
         on = (checkitem->checkState() == Qt::Checked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong checktableitem at tablerow "<<row <<std::endl;
      // get index from table:
      int  nix=0;
      int rix=0;
      if(!getRateIndices(row, nix, rix))
         std::cout<<"!!!!!!!!!! NEVER COME HERE: get RateIndices could not get indices for row "<<row <<std::endl;
      fxTrendingFlags[nix].at(rix)=on;
      //std::cout<<"  rrrrrrrrrrrr set fxTrendingFlags["<<nix<<"]["<<rix<<"] to" << on<<std::endl;
      fbTrendingInit[nix].at(rix).at(0)=on; // sample trending init
      fbTrendingInit[nix].at(rix).at(1)=on; // average trending init
   }
   else if(column==DABCMON_RATE_STATSCOL)
   {
      // get value from table:
      bool on=false;
      QTableWidgetItem* checkitem = RateTable->item(row,  DABCMON_RATE_STATSCOL);
      if(checkitem)
         on = (checkitem->checkState() == Qt::Checked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong checktableitem at tablerow "<<row <<std::endl;
      // get index from table:
      int  nix=0;
      int rix=0;
      if(!getRateIndices(row, nix, rix))
         std::cout<<"!!!!!!!!!! NEVER COME HERE: get RateIndices could not get indices for row "<<row <<std::endl;
      // set value to vector
      fxStatsFlags[nix].at(rix)=on;
      //std::cout<<"  rrrrrrrrrrrr set fxStatsFlags["<<nix<<"]["<<rix<<"] to" << on<<std::endl;
      fbStatsInit[nix].at(rix).at(0)=on; // direct sample
      fbStatsInit[nix].at(rix).at(1)=on; // average
   }
}



void TGo4DabcMonitor::infoUpdated( TGo4DabcInfo * info )
{
   // handle log printout of all services here:
   TGo4LockGuard gard;
   //std::cout<"iiiiiiiiiii infoUpdated() for " << info->getName() <<std::endl;
   QDateTime timestamp;
   timestamp.setTime_t (info->getTimestamp());
   std::cout<<"DIM service " << info->getName() <<":"<<std::endl;
   //" at "<<timestamp.toString()<<":" <<std::endl;
   if(info->getServiceType()=="int")
      std::cout<<"  - "<< info->getInt();//<<std::endl;
   else if (info->getServiceType()=="float")
      std::cout<<"  - "<< info->getFloat();//<<std::endl;
   else if (info->getServiceType()=="double")
      std::cout<<"  - "<< info->getDouble();//<<std::endl;
   else if (info->getServiceType()=="char")
      std::cout<<"  - "<< info->getString();//<<std::endl;
   else
   {
      // service is structure, parse the format string:
      char* ptr=(char*) info->getData();
      int size=info->getSize();
      QString format=info->getServiceType();
      std::cout<<" - structure of format " << format.toLatin1().constData() <<std::endl;
      QStringList elements = format.split(";",QString::SkipEmptyParts);
      for ( QStringList::Iterator it = elements.begin(); it != elements.end(); ++it )
      {
         QString component=*it;
         QString type=component.section(':',0,0);
         QString slen=component.section(':',1,1);
         int length=slen.toInt();
         //std::cout<<" - found member:"  <<type<<" of length "<<slen<<" (value="<<length<<")"<<std::endl;
         QString content="";
         QString prompt="  - "+type+" ("+slen+") \t>";
         if(type=="C")
         {
            content=ptr;
            content.truncate(length);
            ptr+=length;
         }
         else if(type=="L")
         {
            int* cursor= (int*) ptr;
            for(int t=0; t<length; ++t)
            {
               QString val;
               content+= val.setNum(*cursor,10); // decimal base
               cursor++;
            }
            ptr= (char*) cursor;
         }
         else if(type=="F")
         {
            float* cursor= (float*) ptr;
            for(int t=0; t<length; ++t)
            {
               QString val;
               content+= val.setNum( *cursor, 'g',5);
               cursor++;
            }
            ptr= (char*) cursor;
         }

         else
         {
            // treat unknown type as list of char values:
            for(int t=0; t<length; ++t)
            {
               QString val;
               content+= val.setNum(*ptr,10);
               content+=":";
               ptr++;
            }
         }// if(type==)
         std::cout<<prompt.toLatin1().constData()<<content.toLatin1().constData() << "< "<<std::endl;;
         int currentposition= (long) ptr - (long) info->getData();
         if(currentposition > size)
         {
            std::cout<<"    !!!!!!!!!!!!!!!! structure iterator exceeds service size "<<size <<std::endl;
            break;
         }
      }//  for ( QStringList::Iterator it
   }//   if(info->getType()=="int")
   std::cout<<" - (timestamp:"<<timestamp.toString().toLatin1().constData()<<")" <<std::endl;
   delete info; // discard service after first update!
}


void TGo4DabcMonitor::nodesUpdated( TGo4DabcNodesInfo * info )
{
   TGo4LockGuard gard;
   //std::cout<<"nodes Updated()" <<std::endl;
   QString servers=info->getString();
   fxNodelist = servers.split("|", QString::SkipEmptyParts);
   refreshNodes();
   fbDisplayNodeTable=true;
   fbDisplayRateTable=true;
}

void TGo4DabcMonitor::servicesUpdated( TGo4DabcServiceInfo * info )
{
   TGo4LockGuard gard;
   //std::cout<<"servicesUpdated() for " << info->getName() <<std::endl;
   //first find out index of this service:
   unsigned int index=-1;
   for(unsigned int ix=0; ix<fxServices.size(); ++ix)
   {
      if(info==fxServices[ix])
      {
         index=ix;
         break;
      }
   }
   if(index<0)
   {
      std::cout<<"!!!!!!!!!!!servicesUpdated: unknown service info" << (int*) info<<std::endl;
   }
   else
   {
      if(index>fxStates.size() )
      {
         std::cout<<"!!!!!!!!!!!NEVER COME HERE: services updated out of bounds, index=" << index<<std::endl;
         return;
      }
      QString services=info->getString();
      //std::cout<<"+++ got service list: " << services.toLatin1().constData() <<std::endl;

      // find full name of nodestate in services:
      QStringList servlist = services.split(0x0A, QString::SkipEmptyParts);
      QString stateservice="";
      for ( QStringList::Iterator sit = servlist.begin(); sit != servlist.end(); ++sit )
      {
         QString service=*sit;
         //std::cout<<"++++++ scanning service" << service.toLatin1().constData() <<std::endl;
         if(service.contains("RunStatus") || service.contains("Acquisition") )
         {
            stateservice=service.section('|',0,0); // strip additional service info from name
            break;
         }
      } // for
      // now create info for node's state:
      if(!stateservice.isEmpty())
      {
         // check if we already have state info for index:
         bool recreate=false;
         if(fxStates[index]!=0)
         {
            //std::cout<<"found existing state service("<<index<<"): " << fxStates[index]->getName() <<std::endl;
            if(stateservice==fxStates[index]->getName())
            {
               //std::cout<<"-------Name is the same, do nothing."<<std::endl;
               recreate=false;
            }
            else
            {
               //std::cout<<"-------Name has changed, recreate service!"<<std::endl;
               delete fxStates[index];
               fxStates[index]=0;
               recreate=true;
            }

         }
         else
         {
            //std::cout<<"------ Service not existing, create it!."<<std::endl;
            recreate= true;
         } // if(fxStates[index]!=0)

         if(recreate)
         {
            //std::cout<<"+++ creating state service: " << stateservice.toLatin1().constData() <<std::endl;
            TGo4DabcStateInfo* sinfo=    new TGo4DabcStateInfo(stateservice.toLatin1().constData(), 0,  &gNolinkStateRecord,    sizeof(dabc::StatusRec), this);
            fxStates[index]=sinfo;
         } //if recreate
      } // if(!stateservice.isEmpty())
      else
      {
         //std::cout<<"+++ empty state service for index  " << index<<", ignored."<<std::endl;
         //std::cout<<"+++ empty state service for index  " << index<<", clear old entry" <<std::endl;
         //delete fxStates[index];
         //fxStates[index]=0;
         //<- problematic if by some glitch state service is temporarily not found in service list!
      }  // if(!stateservice.isEmpty())
   }//if(index<0)
}


void TGo4DabcMonitor::stateUpdated( TGo4DabcStateInfo * info )
{
   TGo4LockGuard gard;
   //std::cout<<"stateUpdated() for " << info->getName() <<std::endl;
   // first find out index of this state:
   unsigned int index=-1;
   for(unsigned int ix=0; ix<fxStates.size(); ++ix)
   {
      if(info==fxStates[ix])
      {
         index=ix;
         break;
      }
   }
   //std::cout<<"- state index= " << index  <<std::endl;
   if(index<0)
   {
      std::cout<<"ERROR in stateUpdated(): object not in list, pointer " << (int*) info<<std::endl;
   }
   else
   {
      dabc::StatusRec* currentstate=(dabc::StatusRec*) info->getData();
      if(index>fxStateRecords.size())
      {
         std::cout<<"!!!!!!!!!!!NEVER COME HERE: state updated out of bounds, index=" << index<<std::endl;
         return;
      }
      fxStateRecords[index]=TGo4DabcState(currentstate);
      fbDisplayNodeTable=true;
      fxLastTimestamp=info->getTimestamp( );
   }
}


void TGo4DabcMonitor::rateUpdated( TGo4DabcRateInfo * info )
{
   TGo4LockGuard gard;
   //std::cout<<"rateUpdated() for " << info->getName() <<std::endl;

   // first find out indexes for this rate info
   unsigned int nodeindex=-1;
   unsigned int rateindex=-1;
   for(unsigned int ix=0; ix<fxRates.size(); ++ix)
   {
      std::vector<TGo4DabcRateInfo*> & rvec=fxRates[ix];
      for(unsigned int rix=0;rix< rvec.size();++rix)
      {

         if(info==rvec[rix])
         {
            nodeindex=ix;
            rateindex=rix;
            break;
         }
      } // for rix
   }// for ix
   //std::cout<<"- state index= " << index  <<std::endl;
   if(nodeindex<0)
   {
      std::cout<<"ERROR in rateUpdated(): object not in list, pointer " << (int*) info<<std::endl;
   }
   else
   {
      dabc::RateRec* currentrate=(dabc::RateRec*) info->getData();
      if(nodeindex>fxRateRecords.size())
      {
         std::cout<<"!!!!!!!!!!!NEVER COME HERE: rate updated out of bounds, nodeindex=" << nodeindex<<std::endl;
         return;
      }
      std::vector<TGo4DabcRate> & recordvec= fxRateRecords[nodeindex];
      if(rateindex>recordvec.size())
      {
         std::cout<<"!!!!!!!!!!!NEVER COME HERE: rate updated out of bounds, rateindex=" << rateindex<<std::endl;
         return;
      }
      recordvec[rateindex]=TGo4DabcRate(currentrate, info->getName());
      bool trendon=fxTrendingFlags[nodeindex].at(rateindex);
      bool statson=fxStatsFlags[nodeindex].at(rateindex);
      if(fbHistogramming && (trendon || statson))
      {
         std::vector< std::deque <float> > & qvec= fxRateQueues[nodeindex];
         if(rateindex>qvec.size())
         {
            std::cout<<"!!!!!!!!!!!NEVER COME HERE: rate queue vector out of bounds, rateindex=" << rateindex<<std::endl;
            return;
         }
         qvec[rateindex].push_back(currentrate->value); // aquire values, display later!
         fbDisplayHistograms=true;
      }
      fxLastTimestamp=info->getTimestamp( );
      fbDisplayRateTable=true;
   } //if(nodeindex<0)
}



void TGo4DabcMonitor::refreshNodes()
{
   TGo4LockGuard gard;
   //std::cout<<"*********refreshNodes()" <<std::endl;
   fbRebuildNodeTable=true;
   fbRebuildRateTable=true;
   fxDabcNodes.clear();

   clearRates();
   clearServices();
   clearStates();
   for ( QStringList::Iterator it = fxNodelist.begin(); it != fxNodelist.end(); ++it )
   {
      QString current=*it;
      if(current.contains("DIS_DNS")) continue; // skip name server
      //std::cout<<"+++ processing node entry " << current.toLatin1().constData() <<std::endl;
      QString prefix=current.section('/', 0, 0 );
      QString rest=current.section('/', 1, 1 );
      QString reducednode=rest.section('@',0,0); // include port number into node name!
      //std::cout<<"+++ prefix is " << prefix.toLatin1().constData() <<std::endl;
      //if(prefix=="DABC")
      if(prefix==current)
      {
         // no dabcnode (i.e. mbs)
         reducednode=current.section('@',0,0);;
      }
      //std::cout<<"++++ found reduced node "<<reducednode.toLatin1().constData() <<std::endl;

      //std::cout<<"++++ found DABC prefix " <<std::endl;

      fxDabcNodes.push_back(reducednode);
      // get full service list for this node:
      QString sinfoname=current.section('@',0,0) + "/SERVICE_LIST";
      //std::cout<<"++++ creating service info "<<sinfoname <<std::endl;
      TGo4DabcServiceInfo* servinfo= new TGo4DabcServiceInfo(sinfoname.toLatin1().constData(), 0, "not available", this);
      fxServices.push_back(servinfo);
      fxStates.push_back(0); // make sure that for our index a slot in state service vector exists!
      fxStateRecords.push_back(TGo4DabcState()); // dito for state record vector
      // provide empty vectors of rateinfos and raterecords etc for this node:
      std::vector<TGo4DabcRateInfo*> rinfovec;
      rinfovec.clear();
      fxRates.push_back(rinfovec);
      std::vector<TGo4DabcRate> ratevec;
      ratevec.clear();
      fxRateRecords.push_back(ratevec);
      fxShowRateFlags.push_back(false);
      std::vector<float> sumvec;
      fxRateSum.push_back(sumvec);
      std::vector<unsigned int> countvec;
      fxRateCount.push_back(countvec);
      std::vector<bool> trendvec;
      trendvec.clear();
      fxTrendingFlags.push_back(trendvec);
      std::vector <std::vector<bool> >initvec;
      fbTrendingInit.push_back(initvec);
      fxStatsFlags.push_back(trendvec);
      fbStatsInit.push_back(initvec);
      std::vector < std::vector <QString>  >namesvec;
      fxTrendHistoRefnames.push_back(namesvec);
      fxStatHistoRefnames.push_back(namesvec);
      fxShowLogFlags.push_back(false);
      std::vector< std::deque <float> > rateqvec;
      fxRateQueues.push_back(rateqvec);
      //} // if XDAQ
   } // for
}




void TGo4DabcMonitor::clearStates()
{
   TGo4LockGuard gard;
   std::vector<TGo4DabcStateInfo*>::iterator iter;
   for(iter=fxStates.begin(); iter!=fxStates.end(); ++iter)
   {
      delete *iter;
   }
   fxStates.clear();
   fxStateRecords.clear();
   fxShowRateFlags.clear();
   fxShowLogFlags.clear();
}

void TGo4DabcMonitor::clearServices()
{
   TGo4LockGuard gard;
   std::vector<TGo4DabcServiceInfo*>::iterator iter;
   for(iter=fxServices.begin(); iter!=fxServices.end(); ++iter)
   {
      delete *iter;
   }
   fxServices.clear();
}


void TGo4DabcMonitor::clearRates()
{
   TGo4LockGuard gard;
   std::vector<std::vector<TGo4DabcRateInfo*> >::iterator nodeiter;
   for(nodeiter=fxRates.begin(); nodeiter!=fxRates.end(); ++nodeiter)
   {
      std::vector<TGo4DabcRateInfo*> nodevec=*nodeiter; // each node has vector of rate services!
      std::vector<TGo4DabcRateInfo*>::iterator iter;
      for(iter=nodevec.begin(); iter!=nodevec.end(); ++iter)
      {
         delete *iter;
      }
   }
   fxRates.clear();
   fxTrendingFlags.clear();
   fbTrendingInit.clear();
   fxStatsFlags.clear();
   fbStatsInit.clear();
   fxTrendHistoRefnames.clear();
   fxStatHistoRefnames.clear();
   fxRateRecords.clear();
   fxRateQueues.clear();
   fxRateSum.clear();
   fxRateCount.clear();
}


void TGo4DabcMonitor::createRateServices( int nodeindex )
{
   TGo4LockGuard gard;
   //std::cout<<"rrrrrrrr createRateServices for "<<nodeindex <<std::endl;
   //search the service list for our node for all rate services:
   QString services=fxServices[nodeindex]->getString();
   // std::cout<<"+++ createRateServices got service list: " << services.toLatin1().constData() <<std::endl;

   // find full name of nodestate in services:
   QStringList servlist = services.split(0x0A, QString::SkipEmptyParts);
   QString rateservice="";
   for ( QStringList::Iterator sit = servlist.begin(); sit != servlist.end(); ++sit )
   {
      QString service = *sit;
      // std::cout<<"++++++ scanning service" << service.toLatin1().constData() <<std::endl;
      //if(service.contains("F:1;L:1;F:1;F:1;F:1;F:1;C:16;C:16;C:16")
      if(service.contains("F:1;L:1;F:1;F:1;F:1;F:1;C:16;C:16;C")) //check for dabc rate structure info
      {
         // provide slots for aux vectors first, since dim info may call update on creation time!
         fxRateRecords[nodeindex].push_back(TGo4DabcRate()); // need initial dummy record
         std::deque <float> ratequeue;
         fxRateQueues[nodeindex].push_back(ratequeue);
         fxRateSum[nodeindex].push_back(0); // init average rate variables
         fxRateCount[nodeindex].push_back(0);

         fxTrendingFlags[nodeindex].push_back(false); // initial value for trending flag
         std::vector <bool> hisvec;
         hisvec.push_back(false); // flags for 2 histograms each rate
         hisvec.push_back(false);
         fbTrendingInit[nodeindex].push_back(hisvec);
         std::vector <QString> namesvec;
         namesvec.push_back("undefined histogram"); // dito for reference names
         namesvec.push_back("undefined histogram");
         fxTrendHistoRefnames[nodeindex].push_back(namesvec);

         fxStatsFlags[nodeindex].push_back(false); // initial value for statistic hisot flag
         fbStatsInit[nodeindex].push_back(hisvec);
         fxStatHistoRefnames[nodeindex].push_back(namesvec);
         QString rname=service.section('|',0,0); // strip additional service info from name
         //std::cout<<"++++++ creating rate info " << rname <<std::endl;
         TGo4DabcRateInfo* rinfo=new TGo4DabcRateInfo(rname.toLatin1().constData(), 0,  &gNolinkRateRecord , sizeof(dabc:: RateRec), this);
         fxRates[nodeindex].push_back(rinfo); // keep dim info here
      }
   } // for
}


void TGo4DabcMonitor::deleteRateServices( int nodeindex )
{
   TGo4LockGuard gard;
   //std::cout<<"rrrrrrrr deleteRateServices for "<<nodeindex <<std::endl;
   std::vector<TGo4DabcRateInfo*> &  nodevec=fxRates[nodeindex];
   std::vector<TGo4DabcRateInfo*>::iterator iter;
   for(iter=nodevec.begin(); iter!=nodevec.end(); ++iter)
   {
      delete *iter;
   }
   nodevec.clear();
   fxTrendingFlags[nodeindex].clear();
   fbTrendingInit[nodeindex].clear();
   fxTrendHistoRefnames[nodeindex].clear();
   fxStatsFlags[nodeindex].clear();
   fbStatsInit[nodeindex].clear();
   fxStatHistoRefnames[nodeindex].clear();
   fxRateRecords[nodeindex].clear();
   fxRateSum[nodeindex].clear();
   fxRateCount[nodeindex].clear();
   fbDisplayRateTable=true; // update view in case of last service is gone!

}

void TGo4DabcMonitor::createLogServices(int nodeindex)
{
   TGo4LockGuard gard;
   //std::cout<<"rrrrrrrr createLogServices for "<<nodeindex <<std::endl;
   QRegExp filter(dimServiceFilterEdit->text().trimmed());
   filter.setPatternSyntax(QRegExp::Wildcard); // use simple wildcard matching, like shell
   std::cout<<std::endl<< "---- Retrieving current DIM variables from node "<<fxDabcNodes[nodeindex].toLatin1().constData()<<" with filter:"<<filter.pattern().toLatin1().constData() <<std::endl;

   //search the service list for our node for all rate services:
   QString services=fxServices[nodeindex]->getString();
   //std::cout<<"+++ createLogServices got service list: " << services <<std::endl;

   // find full name of nodestate in services:
   QStringList servlist = services.split(0x0A, QString::SkipEmptyParts);
   QString logservice="";
   for ( QStringList::Iterator sit = servlist.begin(); sit != servlist.end(); ++sit )
   {
      QString service=*sit;
      QString sformat=service.section('|',1,1);
      QString sname=service.section('|',0,0); // strip additional service info from name
      QString scom=service.section('|',2,2); // command indicator
      if(sname.contains("SERVICE_LIST")) continue; // skip service list
      if(scom.contains("CMD")) continue; // skip command services
      if(filter.indexIn(sname)<0) continue; // regexp does not match name, skip

      //std::cout<<"++++++ creating log info " << sname <<" for format "<<sformat <<std::endl;
      if(sformat=="C")
      {
         TGo4DabcInfo* info= new TGo4DabcInfo(sname.toLatin1().constData(),1,"not available", this);
      }
      else if(sformat=="L")
      {
         TGo4DabcInfo* info= new TGo4DabcInfo(sname.toLatin1().constData(),1, (int) -1, this);
      }
      else
      {
         TGo4DabcInfo* info= new TGo4DabcInfo(sname.toLatin1().constData(),1,  &gNolinkRateRecord , sizeof(dabc:: RateRec), sformat.toLatin1().constData(), this);
      }
   } //   for ( QStringList::Iterator sit =
}









void TGo4DabcMonitor::displayNodeTable()
{
   TGo4LockGuard gard;
   fbTableBeingCreated=true;
   //std::cout<<"*********displayNodeTable()" <<std::endl;
   if(fbRebuildNodeTable)
   {
      //std::cout<<"*********                               - rebuild table" <<std::endl;
      // first case: create table completely new
      NodeTable->setRowCount(0);
      int maxnodes = fxDabcNodes.size();
      NodeTable->setRowCount(maxnodes);
      for(int ix=0; ix<maxnodes; ++ix)
         fillNodeTableRow(ix, ix, true);
      fbRebuildNodeTable=false;
   } //    if(fbRebuildNodeTable)
   else
   {
      //std::cout<<"*********                               - update table contents" <<std::endl;
      int tablesize  = NodeTable->rowCount();
      int maxnodes = fxDabcNodes.size();
      if(maxnodes!=tablesize)
      {
         std::cout<<"!!!!!!!!!! NEVER COME HERE: table size "<<tablesize<<" does not match number of nodes "<<maxnodes <<std::endl;
         return;
      }

      for(int ix=0; ix<maxnodes; ++ix)
      {
         int tableindex=-1;
         for(int j=0; j<tablesize;++j)
         {
            QString ixtext;
            if (NodeTable->item(j,  DABCMON_NODE_INDEXCOL))
               ixtext = NodeTable->item(j,  DABCMON_NODE_INDEXCOL)->text();
            int tix=ixtext.toInt();
            if(tix==ix)
            {
               tableindex=j;
               break;
            }
         }
         if(tableindex<0)
         {
            std::cout<<"!!!!!!!!!! NEVER COME HERE: could not find tableindex for "<<ix <<std::endl;
            continue;
         }
         else
         {
            //std::cout<<"***********tableindex for "<<ix<<" is "<<tableindex <<std::endl;
         }
         fillNodeTableRow(tableindex, ix, false);
      }//for(int ix=0; ix<maxnodes; ++ix)
   }//if(fbRebuildNodeTable)
   ensurePolished();
   update();
   show();
   fbTableBeingCreated=false;
}


void TGo4DabcMonitor::fillNodeTableRow( int tableindex, int nodeindex, bool createnew )
{
   NodeTable->setSortingEnabled(false);
   //std::cout<<"***fillNodeTableRow - tableindex:"<<tableindex<<", nodeindex:"<<nodeindex<<", createnew:"<<createnew <<std::endl;

   //std::cout<<"        nodename is "<<fxDabcNodes[nodeindex].toLatin1().constData()<<std::endl;
   NodeTable->setItem(tableindex, DABCMON_NODE_NODECOL, new QTableWidgetItem(fxDabcNodes[nodeindex]));

   QPixmap pixmap = QPixmap(":/icons/eventitem.png").scaledToHeight(NodeTable->rowHeight(tableindex),Qt::SmoothTransformation);

   QTableWidgetItem* item = 0;
   if(nodeindex>fxStateRecords.size())
      std::cout<<"    !!!!!!!!!! nodeindex exceeds size of states "<<fxStateRecords.size()<<std::endl;
   QString col =fxStateRecords[nodeindex].fxColor.toLower();
   //std::cout<<"        color is "<<fxStateRecords[nodeindex].fxColor.toLatin1().constData()<<std::endl;
   //std::cout<<"        state is "<<fxStateRecords[nodeindex].fxState.toLatin1().constData()<<std::endl;



   //  NodeTable->setItem(tableindex, DABCMON_NODE_STATECOL, new QTableWidgetItem(fxStateRecords[nodeindex].fxState));
   pixmap.fill(fxStateRecords[nodeindex].fxColor.toLower());
   item = new QTableWidgetItem(pixmap, fxStateRecords[nodeindex].fxState);
   item->setFlags(item->flags() & ~Qt::ItemIsEditable);
   NodeTable->setItem(tableindex, DABCMON_NODE_STATECOL, item);
   if(createnew) {
      item = new QTableWidgetItem(QString::number(nodeindex));
      //std::cout<<"        nodeindextext is "<< QString::number(nodeindex).toLatin1().constData()<<std::endl;
      //std::cout<<"        item text is "<< item->text().toLatin1().constData()<<std::endl;

      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      NodeTable->setItem(tableindex,  DABCMON_NODE_INDEXCOL, item);

      item = new QTableWidgetItem("Show" );
      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      item->setCheckState(fxShowRateFlags[nodeindex] ? Qt::Checked : Qt::Unchecked);
      NodeTable->setItem( tableindex,DABCMON_NODE_CHECKCOL, item);

      item= new QTableWidgetItem("Dump");
      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      item->setCheckState(fxShowLogFlags[nodeindex] ? Qt::Checked : Qt::Unchecked);
      NodeTable->setItem(tableindex,DABCMON_NODE_LOGCOL, item);
   } else {
      QTableWidgetItem* checkitem= NodeTable->item(tableindex,  DABCMON_NODE_CHECKCOL);
      if(checkitem)
         checkitem->setCheckState(fxShowRateFlags[nodeindex] ? Qt::Checked : Qt::Unchecked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong rate checktableitem at index "<<nodeindex <<std::endl;
      QTableWidgetItem* checklogitem = NodeTable->item(tableindex,  DABCMON_NODE_LOGCOL);
      if(checklogitem)
         checklogitem->setCheckState(fxShowLogFlags[nodeindex] ? Qt::Checked : Qt::Unchecked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong logchecktableitem at index "<<nodeindex <<std::endl;
   }
   NodeTable->setSortingEnabled(true);
}




void TGo4DabcMonitor::displayRateTable()
{
   TGo4LockGuard gard;
   fbTableBeingCreated=true;
   //std::cout<<"*********displayRateTable()" <<std::endl;
   // find number of existing rate services
   int numrates=0;
   int maxnodes=fxRateRecords.size();
   for(int ix=0; ix<maxnodes; ++ix)
   {
      numrates+=fxRateRecords[ix].size();
   }
   int tablesize  = RateTable->rowCount();
   int tablecursor = -1;
   if(fbRebuildRateTable)
   {
      //std::cout<<"*********                               - rebuild table" <<std::endl;
      // first case: create table completely new
      //std::cout<<"*                    inserting "<<numrates<<" rows" <<std::endl;
      RateTable->setRowCount(0);
      RateTable->setRowCount(numrates);
      int tableindex=0;
      // now fill table with services:
      for(int ix=0; ix<maxnodes; ++ix)
      {
         std::vector<TGo4DabcRate> & rvec=fxRateRecords[ix];
         //std::cout<<"*                    looping rvec[ "<<ix<<"] with "<<rvec.size()<<" rate entries" <<std::endl;
         for(int rix=0; rix<rvec.size();++rix)
         {
            //std::cout<<"*                    found rvec[ "<<ix<<"]["<<rix <<"] with name "<< rvec[rix].fxName<< std::endl;
            fillRateTableRow(tableindex, ix, rix, true);
            tableindex++;
            //std::cout<<"*                    tableindex gets "<<tableindex<<std::endl;
         } // for rix
      }// for ix
      //std::cout<<"*                    after loop over maxnodes="<<maxnodes<<std::endl;
      fbRebuildRateTable=false;
   } //    if(fbRebuildRateTable)
   else
   {
      //std::cout<<"*********                               - update table contents" <<std::endl;
      if(numrates>tablesize)
      {
         //std::cout<<"table size "<<tablesize<<" smaller than number of rate records "<<numrates <<std::endl;
         // int diff=numrates-tablesize;
         tablecursor=tablesize;
         //std::cout<<"*                    inserting "<<diff<<" rows" <<std::endl;
         RateTable->setRowCount(numrates);
      }
      else if(numrates<tablesize)
      {
         //std::cout<<"table size "<<tablesize<<" bigger than number of rate records "<<numrates <<std::endl;
         // here we have to find the obsolete rows and remove it! do this after updating contents
      }
      else
      {
         // size is the same, do nothing
      }
      tablesize = RateTable->rowCount();
      bool usedrows[tablesize]; // keep track of unused table rows for cleanup
      for(int t=0;t<tablesize;++t){usedrows[t]=false;}
      for(int nix=0; nix<maxnodes; ++nix)
      {
         std::vector<TGo4DabcRate> & rvec=fxRateRecords[nix];
         for(int rix=0; rix<rvec.size();++rix)
         {
            // find tableindex for nix and rix:
            int tableindex=-1;
            for(int j=0; j<tablesize;++j)
            {
               int tablenodeix=-1;
               int tablerateix=-1;
               if(!getRateIndices(j, tablenodeix, tablerateix)) continue; // skip newly created empty rows
               if(tablenodeix==nix && tablerateix==rix)
               {
                  tableindex=j;
                  break;
               }
            }// for j
            if(tableindex<0)
            {
               //std::cout<<"!!!!!!!!!! could not find tableindex for ("<<nix<<","<<rix<<")" <<std::endl;
               //std::cout<<"*********creating new table entry at "<<tablecursor;
               if(tablecursor<0)
               {
                  std::cout<<"!!!!!!!!!! NEVER COME HERE: tablecursor undefined for new entry ("<<nix<<","<<rix<<")" <<std::endl;
                  continue;
               }
               fillRateTableRow(tablecursor, nix, rix, true);
               usedrows[tablecursor]=true;
               tablecursor++;
            }
            else
            {
               //std::cout<<"***********tableindex for ("<<nix<<","<<rix<<") was "<<tableindex <<std::endl;
               usedrows[tableindex]=true;
               fillRateTableRow(tableindex, nix, rix, false);
            } //  if(tableindex<0)
         }// for rix
      }// for nix
      int offset=0;
      for(int rownum=0;rownum<tablesize;++rownum)
      {
         if(usedrows[rownum]==false)
         {
            //std::cout<<"***********displayRateTable found unused row "<<rownum<<", remove it!"<<std::endl;
            RateTable->removeRow(rownum-offset);
            //std::cout<<"*********** removed at"<<rownum-offset<<std::endl;
            offset++; // correct index for already removed rows above!
         }
      }// for rownum
   }//if(fbRebuildRateTable)
   ensurePolished();
   update();
   show();
   fbTableBeingCreated=false;
}

void TGo4DabcMonitor::fillRateTableRow( int tableindex, int nodeindex, int rateindex, bool createnew )
{
   RateTable->setSortingEnabled(false);
   //std::cout<<":fillRateTableRow for "<<tableindex<<std::endl;
   std::vector<TGo4DabcRate> & rvec=fxRateRecords[nodeindex];
   QString val;
   val.setNum(rvec[rateindex].fxRate);//setNum ( float n, char f = 'g', int prec = 6 )
   val+=" "+rvec[rateindex].fxUnits;

   QTableWidgetItem* item = 0;
   if(rvec[rateindex].fxRate<0) {
      QPixmap pixmap = QPixmap(":/icons/info1.png").scaledToHeight(RateTable->rowHeight(tableindex),Qt::SmoothTransformation);
      item = new QTableWidgetItem( QIcon(pixmap), val);
   } else
      item = new QTableWidgetItem(val);
   item->setFlags(item->flags() & ~Qt::ItemIsEditable);
   RateTable->setItem(tableindex,  DABCMON_RATE_RATECOL, item);

   if(createnew) {
      QString namestring=rvec[rateindex].fxName.section('/',1); // strip DABC prefix
      QTableWidgetItem* item = new QTableWidgetItem(namestring);
      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      RateTable->setItem(tableindex,  DABCMON_RATE_NAMECOL, item);

      QString indexstring = QString::number(nodeindex)+":"+QString::number(rateindex);
      item = new QTableWidgetItem(indexstring);
      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      RateTable->setItem(tableindex,  DABCMON_RATE_INDEXCOL, item);

      item = new QTableWidgetItem("histogram" );
      item->setCheckState(fxTrendingFlags[nodeindex].at(rateindex) ? Qt::Checked : Qt::Unchecked);
      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      RateTable->setItem( tableindex,DABCMON_RATE_TRENDCOL, item);

      item = new QTableWidgetItem ("histogram" );
      item->setCheckState(fxStatsFlags[nodeindex].at(rateindex) ? Qt::Checked : Qt::Unchecked );
      item->setFlags(item->flags() & ~Qt::ItemIsEditable);
      RateTable->setItem( tableindex,DABCMON_RATE_STATSCOL, item);
   } else {
      QTableWidgetItem* trendcheckitem= RateTable->item(tableindex,  DABCMON_RATE_TRENDCOL);
      if(trendcheckitem)
         trendcheckitem->setCheckState(fxTrendingFlags[nodeindex].at(rateindex) ? Qt::Checked : Qt::Unchecked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong trend checktableitem at table index "<<tableindex <<std::endl;
      QTableWidgetItem* statcheckitem = RateTable->item(tableindex,  DABCMON_RATE_STATSCOL);
      if(statcheckitem)
         statcheckitem->setCheckState(fxStatsFlags[nodeindex].at(rateindex) ? Qt::Checked : Qt::Unchecked);
      else
         std::cout<<"!!!!!!!!!! NEVER COME HERE: wrong stat checktableitem at table index "<<tableindex <<std::endl;
   } // if(createnew)
   RateTable->setSortingEnabled(true);
}


bool TGo4DabcMonitor::getRateIndices( int tablerow, int & nodeix, int & rateix )
{
   if (RateTable->item(tablerow,  DABCMON_RATE_INDEXCOL)==0) return false;

   QString ixtext= RateTable->item(tablerow,  DABCMON_RATE_INDEXCOL)->text();
   QString nstring=ixtext.section( ':', 0,0);
   if(nstring.isEmpty()) return false; // for newly created empty row, we would get 0,0 indices!
   nodeix=nstring.toInt();
   QString rstring=ixtext.section( ':', 1,1);
   rateix=rstring.toInt();
   return true;
}




void TGo4DabcMonitor::displaySampleHistograms()
{
   TGo4LockGuard gard;
   // iterate all rate indices:
   for(int nodeix=0;nodeix<fxTrendingFlags.size();++nodeix)
   {
      std::vector<bool> & trendvec=fxTrendingFlags[nodeix];
      if(nodeix>fxStatsFlags.size())
      {
         std::cout <<"--NEVER COME HERE: node index mismatch in displaySampleHistograms for nix="<< nodeix<<std::endl;
         return;
      }
      std::vector<bool> & statsvec=fxStatsFlags[nodeix];
      for(int rateix=0; rateix<trendvec.size();++rateix)
      {
         bool trending=trendvec[rateix];
         if(rateix>statsvec.size())
         {
            std::cout <<"--NEVER COME HERE: rate index mismatch in displaySampleHistograms for rix)"<< rateix<<std::endl;;
            return;
         }
         bool statisting=statsvec[rateix];
         if(trending ||  statisting)
         {
            // check if value queue for this index exists
            if(nodeix>fxRateQueues.size())
            {
               std::cout <<"--NEVER COME HERE: node index mismatch in displaySampleHistograms queues for nix="<< nodeix<<std::endl;
               return;
            }
            std::vector< std::deque <float> > & qvec =fxRateQueues[nodeix];
            if(rateix>qvec.size())
            {
               std::cout <<"--NEVER COME HERE: rate index mismatch in displaySampleHistograms queues for rix)"<< rateix<<std::endl;;
               return;
            }
            std::deque<float> &ratequeue = qvec[rateix];
            // read all values from queue and display in histogram
            while (!ratequeue.empty())
            {
               float val=ratequeue.front();
               ratequeue.pop_front();
               //  sum value and update counter:
               fxRateSum[nodeix].at(rateix)+=val;
               fxRateCount[nodeix].at(rateix)++;
               if(!TrendSampleCheck->isChecked()) continue; // clear queue, but do not display sample histograms
               if(trending)
                  updateTrending(nodeix,rateix, 0, val);
               if(statisting)
                  updateStats(nodeix,rateix,0, val);
            }// while ratequeue
         } // if trending or statisting
      } // for rateix
   }//for nodeix
}


void TGo4DabcMonitor::displayAverageHistograms()
{
   TGo4LockGuard gard;
   if(!fbHistogramming) return;
   // iterate all rate indices:
   for(int nodeix=0;nodeix<fxTrendingFlags.size();++nodeix)
   {
      std::vector<bool> & trendvec=fxTrendingFlags[nodeix];
      if(nodeix>fxStatsFlags.size())
      {
         std::cout <<"--NEVER COME HERE: node index mismatch in displaySampleHistograms for nix="<< nodeix<<std::endl;
         return;
      }
      std::vector<bool> & statsvec=fxStatsFlags[nodeix];
      for(int rateix=0; rateix<trendvec.size();++rateix)
      {
         bool trending=trendvec[rateix];
         if(rateix>statsvec.size())
         {
            std::cout <<"--NEVER COME HERE: rate index mismatch in displaySampleHistograms for rix)"<< rateix<<std::endl;;
            return;
         }
         bool statisting=statsvec[rateix];
         if(trending ||  statisting)
         {
            float val=-2;
            float sum= fxRateSum[nodeix].at(rateix);
            unsigned int count= fxRateCount[nodeix].at(rateix);
            if(count!=0) val=sum/count;
            fxRateSum[nodeix].at(rateix)=0.;
            fxRateCount[nodeix].at(rateix)=0;
            if(trending)
               updateTrending(nodeix,rateix,1, val);
            if(statisting)
               updateStats(nodeix,rateix,1,val);
         }
      }// for rateix
   }// for nodeix
}



void TGo4DabcMonitor::displayAll()
{
   //std::cout<<"ttttttt timer fired displayAll()" <<std::endl;
   TGo4LockGuard gard;
   QDateTime timestamp;
   timestamp.setTime_t (fxLastTimestamp);
   //DateLabel->setText(timestamp.toString(Qt::ISODate));
   DateLabel->setText(timestamp.toString());
   if(fbDisplayNodeTable)
   {
      displayNodeTable();
      fbDisplayNodeTable=false;
   }
   if(fbDisplayRateTable)
   {
      displayRateTable();
      fbDisplayRateTable=false;
   }

   // now treat direct sample histograms:
   if(fbDisplayHistograms)
   {
      displaySampleHistograms();
      fbDisplayHistograms=false;
   }

}




void TGo4DabcMonitor::updateTrending( int nodeix, int rateix, int hisix, double value)
{
   QString & refname= fxTrendHistoRefnames[nodeix].at(rateix).at(hisix);
   QString name=fxRateRecords[nodeix].at(rateix).fxName;
   QString foldername=name.section( '/', 1,2);
   name=name.section( '/', 3);
   name.replace( QChar('/'), "-" );
   switch(hisix)
   {
      case 0:
      default:
         name=name+"-TrendingFast";
         break;
      case 1:
         name=name+"-TrendingAverage";
         break;
   };
   foldername.replace( QChar('/'), "-" );
   QString  & title=fxRateRecords[nodeix].at(rateix).fxUnits;

   //std::cout<<"    val="<<value<<", name="<<name<<", refname="<<refname <<", folder="<<foldername<<std::endl;
   TH1* his=0;
   TGo4Slot* histoslot=0;
   if(!fbTrendingInit[nodeix].at(rateix).at(hisix)) histoslot=Browser()->BrowserSlot(refname.toLatin1().constData());
   if(histoslot==0)
   {
      Axis_t lo,up;
      if(fbTrendingForward)
      {
         lo=0;
         switch(hisix)
         {
            case 0:
            default:
               up=1*fiTrendBins;
               break;
            case 1:
               up=1*fiTrendBins*FrequencyBox->value();
               break;
         };
      }
      else
      {
         switch(hisix)
         {
            case 0:
            default:
               lo=-1*fiTrendBins;
               break;
            case 1:
               lo=-1*fiTrendBins*FrequencyBox->value();
               break;
         };
         up=0;
      }
      his=new TH1F(name.toLatin1().constData(), title.toLatin1().constData(), fiTrendBins,lo,up);
      TAxis* xax=his->GetXaxis();
      switch(hisix)
      {
         case 0:
         default:
            xax->SetTitle("updates");
            break;
         case 1:
            xax->SetTitle("s");
            break;
      };
      xax->CenterTitle();
      //xax->SetLimits(0,lo,up);

      TGo4Slot* hisdataslot=Browser()->DataSlot(refname.toLatin1().constData());
      if(hisdataslot)
      {
         hisdataslot->AssignObject(his,true);
      }
      else
      {
         //QString folder="Dabc/"+fxNodelist[nodeix];
         QString folder="DABC/"+foldername;
         refname=Browser()->SaveToMemory(folder.toLatin1().constData(), his, true);
      }
      histoslot=Browser()->BrowserSlot(refname.toLatin1().constData());
   }
   else
   {
      his=dynamic_cast<TH1*>(histoslot->GetAssignedObject());
   }
   IncTrending(his,value,fbTrendingForward);
   if(histoslot)
   {
      histoslot->ForwardEvent(histoslot, TGo4Slot::evObjUpdated);
      Browser()->SetItemTimeDate(histoslot);
      fbTrendingInit[nodeix].at(rateix).at(hisix)=false;
   }
}


void TGo4DabcMonitor::IncTrending( TH1 * histo, double value, bool forwards )
{
   if(histo==0) 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;
      double oldval=histo->GetBinContent(j+dj);
      histo->SetBinContent(j,oldval);
   }
   histo->SetBinContent(j+dj,value);
}



void TGo4DabcMonitor::updateStats( int nodeix, int rateix, int hix , double value)
{

   QString & refname= fxStatHistoRefnames[nodeix].at(rateix).at(hix);
   QString name=fxRateRecords[nodeix].at(rateix).fxName;
   QString foldername=name.section( '/', 1,2);
   name=name.section( '/', 3);
   name.replace( QChar('/'), "-" );
   switch(hix)
   {
      case 0:
      default:
         name=name+"-StatsFast";
         break;
      case 1:
         name=name+"-StatsAverage";
         break;
   };
   foldername.replace( QChar('/'), "-" );
   QString title="counts";
   QString  & xtitle=fxRateRecords[nodeix].at(rateix).fxUnits;
   //std::cout<<"    val="<<value<<", name="<<name<<", refname="<<refname <<", folder="<<foldername<<std::endl;
   TH1* his=0;
   TGo4Slot* histoslot=0;
   if(! fbStatsInit[nodeix].at(rateix).at(hix)) histoslot=Browser()->BrowserSlot(refname.toLatin1().constData());
   if(histoslot==0)
   {
      Axis_t lo,up;
      lo=fxRateRecords[nodeix].at(rateix).fxLower;
      up=fxRateRecords[nodeix].at(rateix).fxUpper;
      if(lo==up)
      {
         lo=0;
         up=100;
         //std::cout <<"using default histogram range for name: "<<name.toLatin1().constData()<<" ["<<lo<<","<<up<<"]" << std::endl;
      }
      his=new TH1F(name.toLatin1().constData(),title.toLatin1().constData(),fiStatBins,lo,up);
      TAxis* xax=his->GetXaxis();
      xax->SetTitle(xtitle.toLatin1().constData());
      xax->CenterTitle();
      TGo4Slot* hisdataslot=Browser()->DataSlot(refname.toLatin1().constData());
      if(hisdataslot)
      {
         hisdataslot->AssignObject(his,true);
      }
      else
      {
         //QString folder="Dabc/"+fxNodelist[nodeix];
         QString folder="DABC/"+foldername;
         refname=Browser()->SaveToMemory(folder.toLatin1().constData(), his, true);
      }
      histoslot=Browser()->BrowserSlot(refname.toLatin1().constData());
   }
   else
   {
      his=dynamic_cast<TH1*>(histoslot->GetAssignedObject());
   } // if(histoslot==0)
   his->Fill(value);
   if(histoslot)
   {
      histoslot->ForwardEvent(histoslot, TGo4Slot::evObjUpdated);
      Browser()->SetItemTimeDate(histoslot);
      fbStatsInit[nodeix].at(rateix).at(hix)=false;
   }
}


//#endif