Changeset 15469 for trunk/FACT++


Ignore:
Timestamp:
05/01/13 10:57:07 (12 years ago)
Author:
tbretz
Message:
Replaced all previosuly assigned IDs (previosly pointing to the entry in the mBuffer) by the loop index k0
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/FACT++/src/EventBuilder.c

    r15468 r15469  
    14051405      for (int k0=evtCtrl_frstPtr; k0!=evtCtrl_lastPtr; k0++, k0 %= MAX_EVT*MAX_RUN)
    14061406      {
    1407           /*
    1408           if (k0==evtCtrl_frstPtr && evtCtrl[k0].evtStat<0)
    1409           {
    1410               evtCtrl_frstPtr++;
    1411               evtCtrl_frstPtr %= MAX_EVT * MAX_RUN;
    1412 
    1413               // Continue because evtCtrl.evtStat[k0] must be <0
    1414               continue;
    1415           }*/
    1416 
    14171407          // Check the more likely case first: incomplete events
    14181408          if (evtCtrl[k0].evtStat>0 && evtCtrl[k0].evtStat<92)
     
    14211411
    14221412              // Event has not yet timed out or was reported already
    1423               const int id = k0;//vtCtrl[k0].mBuffer_idx;
    1424 
    1425               if (evtCtrl[k0].evtStat>=90 || evtCtrl[id].pcTime[0]/*evtCtrl[k0].lastRecv*/>=g_actTime - 30)
     1413              if (evtCtrl[k0].evtStat>=90 || evtCtrl[k0].pcTime[0]/*evtCtrl[k0].lastRecv*/>=g_actTime - 30)
    14261414                  continue;
    14271415
    1428               reportIncomplete(id);
     1416              reportIncomplete(k0);
    14291417
    14301418              //timeout for incomplete events
     
    14421430          if (evtCtrl[k0].evtStat==0 || evtCtrl[k0].evtStat >= 9000)
    14431431          {
    1444               const int id = k0;//evtCtrl[k0].mBuffer_idx;
    1445 #ifdef EVTDEBUG
    1446               factPrintf(kDebug, -1, "%5d free event buffer, nb=%3d", evtCtrl[id].evNum, evtCtrl[id].nBoard);
    1447 #endif
    1448               mBufFree (id);   //event written--> free memory
     1432              mBufFree(k0);   //event written--> free memory
    14491433              evtCtrl[k0].evtStat = -1;
    14501434
     
    14561440              else
    14571441                  factPrintf(kDebug, -1, "Freed a non-first slot");
    1458 
    14591442
    14601443              gj.evtWrite++;
     
    15691552             if (evtCtrl[k0].evtStat > minclear)
    15701553             {
    1571                  const int id = k0;//evtCtrl[k0].mBuffer_idx;
    1572 #ifdef EVTDEBUG
    1573                  factPrintf(kDebug, -1, "ev %5d free event buffer, nb=%3d", evtCtrl[id].evNum, evtCtrl[id].nBoard);
    1574 #endif
    1575                  mBufFree (id);   //event written--> free memory
     1554                 mBufFree(k0);   //event written--> free memory
    15761555                 evtCtrl[k0].evtStat = -1;
    15771556
    1578               if (k0==evtCtrl_frstPtr)
    1579               {
    1580                   evtCtrl_frstPtr++;
    1581                   evtCtrl_frstPtr %= MAX_EVT * MAX_RUN;
    1582               }
    1583               else
    1584                   factPrintf(kDebug, -1, "Freed a non-first slot");
     1557                 if (k0==evtCtrl_frstPtr)
     1558                 {
     1559                     evtCtrl_frstPtr++;
     1560                     evtCtrl_frstPtr %= MAX_EVT * MAX_RUN;
     1561                 }
     1562                 else
     1563                     factPrintf(kDebug, -1, "Freed a non-first slot");
    15851564             }
    15861565             else
    15871566                 if (evtCtrl[k0].evtStat > 0)
    15881567                     numclear++;      //writing is still ongoing...
    1589 
    1590              /*
    1591              if (k0 == evtCtrl_frstPtr && evtCtrl[k0].evtStat < 0)
    1592              {
    1593                  evtCtrl_frstPtr++;
    1594                  evtCtrl_frstPtr %= MAX_EVT * MAX_RUN;
    1595              }*/
    15961568         }
    15971569
     
    16541626            }
    16551627
    1656             /*** if (evtCtrl.evtStat[k0] == 1000 + threadID) ****/
    1657 
    16581628            int jret = 9100; // flag to be deleted (gi_resetR>1 : flush buffers asap)
    16591629
    16601630            if (gi_resetR<=1)
    16611631            {
    1662                 const int id = k0;//evtCtrl[k0].mBuffer_idx;
    1663 
    1664                 jret = subProcEvt(threadID, evtCtrl[id].FADhead,
    1665                                   evtCtrl[id].fEvent, NULL/*mBuffer[id].buffer*/);
     1632                jret = subProcEvt(threadID, evtCtrl[k0].FADhead,
     1633                                  evtCtrl[k0].fEvent, NULL/*mBuffer[id].buffer*/);
    16661634
    16671635
     
    17621730           //-------- it is better to open the run already here, so call can be used to initialize
    17631731           //-------- buffers etc. needed to interprete run (e.g. DRS calibration)
    1764            const int id = k0;//evtCtrl[k0].mBuffer_idx;
    1765 
    1766            const uint32_t irun = evtCtrl[id].runNum;
    1767            const int32_t  ievt = evtCtrl[id].evNum;
     1732           const uint32_t irun = evtCtrl[k0].runNum;
     1733           const int32_t  ievt = evtCtrl[k0].evNum;
    17681734
    17691735           // Find entry in runCtrl which belongs to the event mBuffer[id]
     
    17791745               if (j>=MAX_RUN)
    17801746               {
    1781                    factPrintf(kFatal, 901, "writeEvt: Can not find run %d for event %d in %d", irun, ievt, id);
     1747                   factPrintf(kFatal, 901, "writeEvt: Can not find run %d for event %d in %d", irun, ievt, k0);
    17821748                   // FIXME: What is the right action? (Flag event for deletion?)
    17831749                   continue;
     
    18081774               actRun.Version =  1;
    18091775               actRun.RunType = -1;  //to be adapted
    1810                actRun.Nroi    = evtCtrl[id].nRoi;      //runCtrl[lastRun].roi0;
    1811                actRun.NroiTM  = evtCtrl[id].nRoiTM;    //runCtrl[lastRun].roi8;
    1812                actRun.RunTime = evtCtrl[id].pcTime[0]; //runCtrl[lastRun].firstTime;
    1813                actRun.RunUsec = evtCtrl[id].pcTime[1]; //runCtrl[lastRun].firstUsec;
     1776               actRun.Nroi    = evtCtrl[k0].nRoi;      //runCtrl[lastRun].roi0;
     1777               actRun.NroiTM  = evtCtrl[k0].nRoiTM;    //runCtrl[lastRun].roi8;
     1778               actRun.RunTime = evtCtrl[k0].pcTime[0]; //runCtrl[lastRun].firstTime;
     1779               actRun.RunUsec = evtCtrl[k0].pcTime[1]; //runCtrl[lastRun].firstUsec;
    18141780               actRun.NBoard  = NBOARDS;
    18151781               actRun.NPix    = NPIX;
    18161782               actRun.NTm     = NTMARK;
    18171783
    1818                memcpy(actRun.FADhead, evtCtrl[id].FADhead, NBOARDS*sizeof(PEVNT_HEADER));
     1784               memcpy(actRun.FADhead, evtCtrl[k0].FADhead, NBOARDS*sizeof(PEVNT_HEADER));
    18191785
    18201786               runCtrl[lastRun].fileHd = runOpen (irun, &actRun, sizeof (actRun));
     
    18561822           //--------
    18571823
    1858            //const int roi = mBuffer[id].nRoi;
    1859            //const int roiTM = mBuffer[id].nRoiTM;
    1860 
    1861            //make sure unused pixels/tmarks are cleared to zero
    1862            //ETIENNE don't reset it to zero as it is taken care of in DataWriteFits
    1863            //                  if (roiTM == roi)
    1864            //                     roiTM = 0;
    1865            /*
    1866            for (int ip=0; ip<NPIX; ip++)
    1867            {
    1868                if (mBuffer[id].fEvent->StartPix[ip] == -1)
    1869                {
    1870                    const int dest = ip * roi;
    1871                    memset(&mBuffer[id].fEvent->Adc_Data[dest], 0, roi * 2);
    1872                }
    1873            }
    1874 
    1875            for (int it=0; it<NTMARK; it++)
    1876            {
    1877                if (mBuffer[id].fEvent->StartTM[it] == -1)
    1878                {
    1879                    const int dest = it * roi + NPIX * roi;
    1880                    memset(&mBuffer[id].fEvent->Adc_Data[dest], 0, roi * 2);
    1881                }
    1882            }*/
    1883 
    18841824           //and set correct event header ; also check for consistency in event (not yet)
    1885            evtCtrl[id].fEvent->Roi         = evtCtrl[id].nRoi;
    1886            evtCtrl[id].fEvent->RoiTM       = evtCtrl[id].nRoiTM;
    1887            evtCtrl[id].fEvent->EventNum    = evtCtrl[id].evNum;
    1888            evtCtrl[id].fEvent->TriggerNum  = evtCtrl[id].trgNum;
    1889            evtCtrl[id].fEvent->TriggerType = evtCtrl[id].trgTyp;
    1890            evtCtrl[id].fEvent->Errors[0]   = evtCtrl[id].Errors[0];
    1891            evtCtrl[id].fEvent->Errors[1]   = evtCtrl[id].Errors[1];
    1892            evtCtrl[id].fEvent->Errors[2]   = evtCtrl[id].Errors[2];
    1893            evtCtrl[id].fEvent->Errors[3]   = evtCtrl[id].Errors[3];
    1894            evtCtrl[id].fEvent->SoftTrig    = 0;
     1825           evtCtrl[k0].fEvent->Roi         = evtCtrl[k0].nRoi;
     1826           evtCtrl[k0].fEvent->RoiTM       = evtCtrl[k0].nRoiTM;
     1827           evtCtrl[k0].fEvent->EventNum    = evtCtrl[k0].evNum;
     1828           evtCtrl[k0].fEvent->TriggerNum  = evtCtrl[k0].trgNum;
     1829           evtCtrl[k0].fEvent->TriggerType = evtCtrl[k0].trgTyp;
     1830           evtCtrl[k0].fEvent->Errors[0]   = evtCtrl[k0].Errors[0];
     1831           evtCtrl[k0].fEvent->Errors[1]   = evtCtrl[k0].Errors[1];
     1832           evtCtrl[k0].fEvent->Errors[2]   = evtCtrl[k0].Errors[2];
     1833           evtCtrl[k0].fEvent->Errors[3]   = evtCtrl[k0].Errors[3];
     1834           evtCtrl[k0].fEvent->SoftTrig    = 0;
    18951835
    18961836
     
    18981838           {
    18991839               // board is not read
    1900                if (evtCtrl[id].board[ib] == -1)
     1840               if (evtCtrl[k0].board[ib] == -1)
    19011841               {
    1902                    evtCtrl[id].FADhead[ib].start_package_flag = 0;
    1903                    evtCtrl[id].fEvent->BoardTime[ib] = 0;
     1842                   evtCtrl[k0].FADhead[ib].start_package_flag = 0;
     1843                   evtCtrl[k0].fEvent->BoardTime[ib] = 0;
    19041844               }
    19051845               else
    19061846               {
    1907                    evtCtrl[id].fEvent->BoardTime[ib] = evtCtrl[id].FADhead[ib].time;
     1847                   evtCtrl[k0].fEvent->BoardTime[ib] = evtCtrl[k0].FADhead[ib].time;
    19081848               }
    19091849           }
    19101850
    1911            const int rc = eventCheck(evtCtrl[id].runNum, evtCtrl[id].FADhead,
    1912                                      evtCtrl[id].fEvent);
     1851           const int rc = eventCheck(evtCtrl[k0].runNum, evtCtrl[k0].FADhead,
     1852                                     evtCtrl[k0].fEvent);
    19131853           //gi.procTot++;
    19141854           numProc++;
Note: See TracChangeset for help on using the changeset viewer.