Changeset 15379


Ignore:
Timestamp:
04/19/13 14:20:33 (12 years ago)
Author:
tbretz
Message:
Removed STATISTICS2 dim service; shortened STATISTICS1 a bit
Location:
trunk/FACT++/src
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • trunk/FACT++/src/EventBuilder.c

    r15360 r15379  
    866866   evtCtrl.lastPtr %= MAX_EVT * MAX_RUN;
    867867
    868    gi.evtGet++;
     868   //gi.evtGet++;
    869869
    870870   return i;
    … …  
    939939} /*-----------------------------------------------------------------*/
    940940
    941 
     941/*
    942942void
    943943resetEvtStat ()
    … …  
    973973
    974974   return;
    975 } /*-----------------------------------------------------------------*/
     975}*/ /*-----------------------------------------------------------------*/
    976976
    977977void reportIncomplete(int k0)
    … …  
    12231223      for (int k = 0; k < NBOARDS; k++) {
    12241224         gi_NumConnect[k] = 0;
    1225          gi.numConn[k] = 0;
     1225         //gi.numConn[k] = 0;
    12261226         gj.numConn[k] = 0;
    1227          gj.errConn[k] = 0;
     1227         //gj.errConn[k] = 0;
    12281228         gj.rateBytes[k] = 0;
    12291229         gj.totBytes[k] = 0;
    … …  
    12341234
    12351235   if (gi_resetR > 0) {
    1236       resetEvtStat ();
     1236      //resetEvtStat ();
    12371237      gj.bufTot = gj.maxEvt = gj.xxxEvt = 0;
    12381238      gj.usdMem = gj.maxMem = gj.xxxMem = 0;
    … …  
    12761276
    12771277          gi_NumConnect[b] = 0;       //must close all connections
    1278           gi.numConn[b] = 0;
     1278          //gi.numConn[b] = 0;
    12791279          gj.numConn[b] = 0;
    12801280
    … …  
    13031303
    13041304      //count number of succesfull actions
    1305       int numok = 0;               
     1305//      int numok = 0;
    13061306
    13071307/*
    … …  
    13631363              gi_NumConnect[b] += cntsock;
    13641364
    1365               gi.numConn[b]++;
     1365              //gi.numConn[b]++;
    13661366              gj.numConn[b]++;
    13671367
    1368               factPrintf(kInfo, -1, "New connection %d (number of connections: %d)", b, gi.numConn[b]);
     1368              factPrintf(kInfo, -1, "New connection %d (number of connections: %d)", b, gj.numConn[b]);
    13691369          }
    13701370
    … …  
    13731373              continue;
    13741374
    1375           numok++;
     1375          //numok++;
    13761376
    13771377          const int32_t jrd =
    … …  
    13851385              if (errno==EWOULDBLOCK || errno==EAGAIN)
    13861386              {
    1387                   numok--;
     1387                  //numok--;
    13881388                  continue;
    13891389              }
    13901390
    13911391              factPrintf(kError, 442, "Reading from socket %d failed: %m (recv,rc=%d)", i, errno);
    1392               gi.gotErr[b]++;
     1392              //gi.gotErr[b]++;
    13931393              continue;
    13941394          }
    … …  
    14021402              GenSock(s0, i, 0, NULL, &rd[i]);
    14031403
    1404               gi.gotErr[b]++;
     1404              //gi.gotErr[b]++;
    14051405
    14061406              gi_NumConnect[b]-= cntsock ;
    1407               gi.numConn[b]--;
     1407              //gi.numConn[b]--;
    14081408              gj.numConn[b]--;
    14091409
    … …  
    14131413          // Success (jrd > 0)
    14141414
    1415           gi.gotByte[b]   += jrd;
     1415          //gi.gotByte[b]   += jrd;
    14161416          gj.rateBytes[b] += jrd;
    14171417
    … …  
    14381438                  rd[i].rBuf->B[rd[i].fadLen - 2] != stop.B[1])
    14391439              {
    1440                   gi.evtErr++;
     1440                  //gi.evtErr++;
    14411441                  factPrintf(kError, 301, "End-of-event flag wrong on socket %3d for event %4d (len=%5d), expected %3d %3d, got %3d %3d",
    14421442                             i, rd[i].evtID, rd[i].fadLen, stop.B[0], stop.B[1],
    … …  
    15311531              {
    15321532                  evtCtrl.evtStat[iDx] = 99;
    1533                   gi.evtTot++;
     1533                  //gi.evtTot++;
    15341534              }
    15351535          }
    … …  
    16241624      } // end for loop over all sockets
    16251625
    1626       gi.numRead[numok]++;
     1626      //gi.numRead[numok]++;
    16271627
    16281628      g_actTime = time (NULL);
    … …  
    16611661
    16621662              evtCtrl.evtStat[k0] = 91;     //timeout for incomplete events
    1663               gi.evtSkp++;
    1664               gi.evtTot++;
     1663              //gi.evtSkp++;
     1664              //gi.evtTot++;
    16651665              gj.evtSkip++;
    16661666
    … …  
    17531753
    17541754           gi_NumConnect[i / 7]-= cntsock ;
    1755            gi.numConn[i / 7]--;
     1755           //gi.numConn[i / 7]--;
    17561756           gj.numConn[i / 7]--;
    17571757           sockDef[i / 7] = 0;      //flag ro recreate the sockets ...
    … …  
    17691769           {
    17701770               evtCtrl.evtStat[k0] = 91;
    1771                gi.evtSkp++;
    1772                gi.evtTot++;
     1771               //gi.evtSkp++;
     1772               //gi.evtTot++;
    17731773           }
    17741774       }
    … …  
    21232123           const int rc = eventCheck(mBuffer[id].runNum, mBuffer[id].FADhead,
    21242124                                     mBuffer[id].fEvent);
    2125            gi.procTot++;
     2125           //gi.procTot++;
    21262126           numProc++;
    21272127
    … …  
    21292129           {
    21302130               evtCtrl.evtStat[k0] = 9999;        //flag event to be skipped
    2131                gi.procErr++;
     2131               //gi.procErr++;
    21322132           }
    21332133           else
    … …  
    23072307           const int32_t  ievt = mBuffer[id].evNum;
    23082308
    2309            gi.wrtTot++;
     2309           //gi.wrtTot++;
    23102310
    23112311           int j = lastRun;
    … …  
    23232323               {
    23242324                   factPrintf(kFatal, 901, "writeEvt: Can not find run %d for event %d in %d", irun, ievt, id);
    2325                    gi.wrtErr++;
     2325                   //gi.wrtErr++;
    23262326               }
    23272327
    … …  
    23712371               }
    23722372               evtCtrl.evtStat[k0] = 9903;
    2373                gi.wrtErr++;
     2373               //gi.wrtErr++;
    23742374           } else {
    23752375               // snprintf (str, MXSTR,"write event %d size %d",ievt,sizeof (mBuffer[id]));
    … …  
    23882388                   factPrintf(kError, 503, "writeEvt: Writing event for run %d failed (runWrite)", irun);
    23892389                   evtCtrl.evtStat[k0] = 9902;
    2390                    gi.wrtErr++;
     2390                   //gi.wrtErr++;
    23912391               }
    23922392

  • trunk/FACT++/src/EventBuilderWrapper.h

    r15355 r15379  
    102102    DimDescribedService fDimDrsCalibration;
    103103    DimDescribedService fDimStatistics1;
    104     DimDescribedService fDimStatistics2;
     104    //DimDescribedService fDimStatistics2;
    105105    DimDescribedService fDimFileFormat;
    106106    DimDescribedService fDimIncomplete;
    … …  
    233233                                                           "|roi:Region of interest of secondary baseline"
    234234                                                           "|run:Run numbers of DRS runs (0=none)"),
    235         fDimStatistics1 ("FAD_CONTROL/STATISTICS1",        "I:3;I:5;X:4;I:3;I:3;I:40;I:1;I:2;C:40;I:40;I:40;X:40",
     235        fDimStatistics1 ("FAD_CONTROL/STATISTICS1",        "I:3;I:5;X:4;I:3;I:3;I:40;I:1;I:2;C:40;I:40;X:40",
    236236                                                           "Event Builder status for GUI display"
    237237                                                           "|threadInfo[int]:Number of read, proc and writes"
    … …  
    244244                                                           "|rateNew[int]:Number of new start events received"
    245245                                                           "|numConn[int]:Number of connections per board"
    246                                                            "|errConn[int]:IO errors per board"
    247246                                                           "|rateBytes[int]:Bytes read this cycle"
    248247                                                           "|totBytes[int]:Bytes read (counter)"),
    249         fDimStatistics2 ("FAD_CONTROL/STATISTICS2",        "I:1;I:280;X:40;I:40;I:4;I:4;I:2;I:2;I:3;C:40",
     248        /*fDimStatistics2 ("FAD_CONTROL/STATISTICS2",        "I:1;I:280;X:40;I:40;I:4;I:4;I:2;I:2;I:3;C:40",
    250249                                                           "Event Builder status, events oriented"
    251250                                                           "|reset[int]:If increased, reset all counters"
    … …  
    258257                                                           "|wrtStat[int]:number of evts written to disk, with errors"
    259258                                                           "|runStat[int]:number of run opened, closed, with open or close errors"
    260                                                            "|numConn[int]:number of sockets successfully opened per board"),
     259                                                           "|numConn[int]:number of sockets successfully opened per board"),*/
    261260        fDimFileFormat("FAD_CONTROL/FILE_FORMAT",          "S:1", "|format[int]:Current file format"),
    262261        fDimIncomplete("FAD_CONTROL/INCOMPLETE",           "X:1", "|incomplete[bits]:One bit per board"),
    … …  
    12391238    void factStat(const EVT_STAT &stat)
    12401239    {
    1241         fDimStatistics2.Update(stat);
     1240        //fDimStatistics2.Update(stat);
    12421241    }
    12431242

  • trunk/FACT++/src/FAD.h

    r12267 r15379  
    336336  //connections
    337337   int8_t   numConn[NBOARDS] ;  //#connections per board (at the moment)
    338    int32_t  errConn[NBOARDS] ;  //#I/O errors per board (counter)
     338   //int32_t  errConn[NBOARDS] ;  //#I/O errors per board (counter)
    339339   int32_t  rateBytes[NBOARDS]; //#Bytes read this cycle  **
    340340   int64_t  totBytes[NBOARDS];  //#Bytes read (counter)
Note: See TracChangeset for help on using the changeset viewer.