Ignore:
Timestamp:
07/18/11 16:24:29 (13 years ago)
Author:
tbretz
Message:
Latest updates.
File:
1 edited

Legend:

Unmodified
Added
Removed

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

    r11343 r11443  
    4141extern int  runClose(FileHandle_t fileHd ,  RUN_TAIL *runth, size_t len ) ;
    4242extern void factOut(int severity, int err, char* message ) ;
     43extern void gotNewRun( int runnr, PEVNT_HEADER *headers );
     44
    4345
    4446extern void factStat(GUI_STAT gj) ;
    … …  
    5860
    5961uint g_actTime   ;
     62uint g_actUsec   ;
    6063int  g_runStat   ;
    6164int  g_reset     ;
    … …  
    7780 int gi_memStat = +1 ;
    7881
    79  uint32_t gi_myRun ;
    80 
     82 uint32_t gi_myRun = 9876789 ;
     83 uint32_t actrun ;
    8184
    8285
    … …  
    118121
    119122typedef union {
    120   int8_t  B[MAX_LEN/8];
    121   int16_t S[MAX_LEN/4];
    122   int32_t I[MAX_LEN/2];
    123   int64_t L[MAX_LEN  ];
     123  int8_t  B[MAX_LEN  ];
     124  int16_t S[MAX_LEN/2];
     125  int32_t I[MAX_LEN/4];
     126  int64_t L[MAX_LEN/8];
    124127} CNV_FACT ;
    125128
    … …  
    137140  int  runID  ;          // run       "
    138141  int  ftmID  ;          // event ID from FTM
    139   uint  fadLen ;         // FADlength of event currently read
     142  uint fadLen ;         // FADlength of event currently read
    140143  int  fadVers ;         // Version of FAD
    141144  int  board ;           // boardID (softwareID: 0..40 )
    142145  int  Port ;
    143146
     147  CNV_FACT *xBuf ;      //a copy of rBuf (temporary for debuging)
    144148  CNV_FACT *rBuf ;
     149
    145150
    146151} READ_STRUCT ;
    … …  
    199204  if (flag < 0) {
    200205     free(rd->rBuf) ;   //and never open again
     206     free(rd->xBuf) ;   //and never open again
    201207     rd->rBuf = NULL ;     
    202208     rd->sockStat = 99 ; 
    … …  
    211217     rd->SockAddr.sin_addr = sockAddr->sin_addr ;
    212218
     219     rd->xBuf = malloc(sizeof(CNV_FACT) ) ;
    213220     rd->rBuf = malloc(sizeof(CNV_FACT) ) ;
    214221     if ( rd->rBuf == NULL ) {
    … …  
    270277
    271278
    272 int mBufEvt( int evID, uint runID, int nRoi) {
     279int mBufEvt( int evID, uint runID, int nRoi, int sk, int fadlen) {
    273280// generate a new Event into mBuffer:   
    274281// make sure only complete Event are possible, so 'free' will always work
    … …  
    316323        if (gi_memStat>0 ) {
    317324           gi_memStat = -99 ;
    318            snprintf(str,MXSTR,"no memory left to keep event %d",evID) ;
     325           snprintf(str,MXSTR,"no memory left to keep event %6d sock %3d",evID,sk) ;
    319326           factOut(kError,882, str ) ;
     327        } else {
     328           snprintf(str,MXSTR,"no memory left to keep event %6d sock %3d",evID,sk) ;
     329           factOut(kDebug,882, str ) ;
    320330        }
    321331        return -11 ;
    … …  
    354364   }
    355365
     366   mBuffer[i].fEvent->PCTime[0] = g_actTime ;
     367   mBuffer[i].fEvent->PCTime[1] = g_actUsec ;
    356368   mBuffer[i].pcTime  = g_actTime ;
    357369   mBuffer[i].nRoi    = nRoi ;
    … …  
    373385
    374386
    375 snprintf(str,MXSTR,"%5d start new evt  %8d %8d %2d",evID,i,evtCtrl.lastPtr,0);
    376 factOut(kDebug,-11, str ) ;
     387   snprintf(str,MXSTR,"%5d start new evt  %8d %8d sock %3d len %5d t %10d",
     388      evID,i,evtCtrl.lastPtr,sk,fadlen,mBuffer[i].pcTime);
     389   factOut(kDebug,-11, str ) ;
    377390   evtCtrl.lastPtr++ ;
    378391   if (evtCtrl.lastPtr == MAX_EVT*MAX_RUN ) evtCtrl.lastPtr = 0;
    … …  
    393406      runCtrl[evFree].runId = runID ;
    394407      runCtrl[evFree].fileId = -2 ;
     408      runCtrl[evFree].lastEvt= -1 ;
    395409      runCtrl[evFree].nextEvt= 0;
    396410      runCtrl[evFree].actEvt = 0;
    … …  
    419433
    420434   int headmem=0 ;
     435   int evid ;
    421436   size_t freemem = 0 ;
    422437
     438   evid    = mBuffer[i].evNum  ;
    423439   freemem = mBuffer[i].evtLen ;
    424440
    … …  
    488504void *readFAD( void *ptr ) {
    489505/* *** main loop reading FAD data and sorting them to complete events */
    490   int head_len,frst_len,numok,numok2,dest,evID,i,k ;
     506  int head_len,frst_len,numok,numok2,numokx,dest,evID,i,k ;
    491507  int actBoards = 0, minLen ;
    492508  int32_t jrd ;
    … …  
    498514
    499515  int sockDef[NBOARDS];    //internal state of sockets
    500 
     516  int jrdx ;
    501517
    502518
    … …  
    509525
    510526
     527  gi_myRun   = g_actTime ;
    511528  snprintf(str,MXSTR,"start initializing");
    512529  factOut(kInfo,-1, str ) ;
    … …  
    546563  evtCtrl.lastPtr = 0 ;
    547564
    548   gi_myRun   = g_actTime ;
    549565  gi_SecTime = g_actTime ;
    550566  gi_runStat = g_runStat ;
    … …  
    602618          gi.numConn[ b ] = 0;
    603619          gj.numConn[ b ] = 0;
    604           if (            sockDef[b] == 0) s0= 0 ;  //sockets to be defined and opened   
    605           else if (g_port[b].sockDef == 0) s0=-1 ;  //sockets to be destroyed
    606           else                             s0=+1 ;  //sockets to be closed and reopened
     620          if (            sockDef[b] == 0) s0=  0 ;  //sockets to be defined and opened   
     621          else if (g_port[b].sockDef == 0) s0= -1 ;  //sockets to be destroyed
     622          else                             s0= +1 ;  //sockets to be closed and reopened
    607623
    608624          if (s0 == 0) p0=ntohs(g_port[b].sockAddr.sin_port);
    … …  
    625641
    626642
    627 
    628 
     643    jrdx  = 0;
     644    numokx= 0;
    629645    numok = 0 ;                       //count number of succesfull actions
    630646
    631647    for (i=0; i<MAX_SOCK; i++) {         //check all sockets if something to read
    632648      b = i / 7 ;
    633       if (sockDef[b] > 0) s0=+1 ;
    634       else                s0=-1 ;
     649      if (sockDef[b] > 0) s0= +1 ;
     650      else                s0= -1 ;
    635651
    636652      gettimeofday( tv, NULL);
    637653      g_actTime = tsec = atv.tv_sec ;
    638       tusec= atv.tv_usec ;
     654      g_actUsec = tusec= atv.tv_usec ;
    639655
    640656      if (rd[i].sockStat <0 ) {         //try to connect if not yet done
    … …  
    647663          } else {
    648664             rd[i].bufTyp = -1 ;           //  full data to be skipped
    649              rd[i].bufLen = sizeof(CNV_FACT) ; //huge for skipping
     665             rd[i].bufLen = MAX_LEN ;      //huge for skipping
    650666          }
    651667          rd[i].bufPos = 0 ;            //  no byte read so far
    … …  
    666682          if (jrd >0 ) {
    667683             debugStream(i,&rd[i].rBuf->B[ rd[i].bufPos],jrd) ;
     684             memcpy(&rd[i].xBuf->B[ rd[i].bufPos], &rd[i].rBuf->B[ rd[i].bufPos], jrd) ;
     685 snprintf(str,MXSTR,"read sock %3d bytes %5d , %5d",i,jrd,rd[i].bufLen);
     686 factOut(kDebug,301, str ) ;
    668687          }
    669688
    … …  
    685704             jrd = 0 ;
    686705          }
    687         } else jrd = 0 ;                //did read nothing as requested
     706        } else {
     707          jrd = 0 ;                //did read nothing as requested
     708          snprintf(str,MXSTR,"do not read from socket %d  %d",i,rd[i].bufLen ) ;
     709          factOut(kDebug,301, str ) ;
     710        }
    688711
    689712        gi.gotByte[ b ] += jrd ;
    690713        gj.rateBytes[b] += jrd ;
     714
     715        if (jrd>0) {numokx++ ; jrdx+= jrd; }
     716
    691717
    692718        if ( rd[i].bufTyp <0 ) { // we are skipping this board ...
    … …  
    702728             rd[i].bufPos  = rd[i].fadLen ;
    703729             if ( rd[i].rBuf->B[ rd[i].bufPos-1] != stop.B[0]
    704                && rd[i].rBuf->B[ rd[i].bufPos  ] != stop.B[1]) {
     730               || rd[i].rBuf->B[ rd[i].bufPos-2] != stop.B[1]) {
    705731                gi.evtErr++ ;
    706                 snprintf(str,MXSTR,"wrong end of buffer found %d",rd[i].bufPos);
     732                snprintf(str,MXSTR,"wrong end of buffer found sock %3d ev %4d len %5d %3d %3d - %3d %3d ",
     733                   i,rd[i].fadLen, rd[i].evtID, rd[i].rBuf->B[0], rd[i].rBuf->B[1], rd[i].rBuf->B[ rd[i].bufPos-2],
     734                   rd[i].rBuf->B[ rd[i].bufPos-1]);
    707735                factOut(kError,301, str ) ;
    708736                goto EndBuf ;
    709737
    710              }
    711              debugRead(i,jrd,rd[i].evtID,rd[i].ftmID,rd[i].runID, 1,tsec,tusec) ; // i=socket; jrd=#bytes; ievt=eventid; 1=finished event
     738//           } else {
     739//              snprintf(str,MXSTR,"good  end of buffer found sock %3d len %5d %d %d : %d %d - %d %d : %d %d",
     740//                 i,rd[i].fadLen,
     741//                 rd[i].rBuf->B[ 0 ],             rd[i].rBuf->B[ 1 ],           start.B[1],start.B[0],
     742//                 rd[i].rBuf->B[ rd[i].bufPos-2], rd[i].rBuf->B[ rd[i].bufPos-1], stop.B[1], stop.B[0]);
     743//              factOut(kDebug,301, str ) ;
     744             }
     745
     746             if (jrd>0) debugRead(i,jrd,rd[i].evtID,rd[i].ftmID,rd[i].runID, 1,tsec,tusec) ; // i=socket; jrd=#bytes; ievt=eventid; 1=finished event
    712747
    713748             //we have a complete buffer, copy to WORK area
    714749             roi = ntohs(rd[i].rBuf->S[ head_len/2 + 2 ]) ;
    715750             //get index into mBuffer for this event (create if needed)
    716              evID = mBufEvt( rd[i].evtID, rd[i].runID, roi ) ;
     751             evID = mBufEvt( rd[i].evtID, rd[i].runID, roi, i, rd[i].fadLen ) ;
    717752
    718753             if (evID <-9000) goto EndBuf ;  //illegal event, skip it ...
    719754             if (evID < 0) {
     755
     756     if ( rd[i].bufLen != 0) {
     757        snprintf(str,MXSTR,"something screwed up");
     758        factOut(kFatal, 1, str ) ;
     759     }
    720760                xwait.tv_sec = 0;
    721761                xwait.tv_nsec= 10000000 ;  // sleep for ~10 msec
    … …  
    726766
    727767             //we have a valid entry in mBuffer[]; fill it
     768
     769int xchk = memcmp(&rd[i].xBuf->B[0], &rd[i].rBuf->B[0], rd[i].fadLen   ) ;
     770if (xchk != 0) {
     771   snprintf(str,MXSTR,"ERROR OVERWRITE %d %d on port %d",xchk,rd[i].fadLen,i) ;
     772   factOut(kFatal, 1, str ) ;
     773
     774   uint iq;
     775   for (iq=0; iq < rd[i].fadLen  ; iq++) {
     776      if (rd[i].rBuf->B[iq] != rd[i].xBuf->B[iq] ) {
     777         snprintf(str,MXSTR,"ERROR %4d %4d %x %x",i,iq,rd[i].rBuf->B[iq], rd[i].xBuf->B[iq]);
     778         factOut(kFatal, 1, str ) ;
     779      }
     780   }
     781}
     782
    728783
    729784             boardId = b ;
    … …  
    735790             }
    736791             if ( mBuffer[evID].board[ boardId ] != -1) {   
    737                 snprintf(str,MXSTR,"double board %d for event %d",boardId,evID) ;
     792                snprintf(str,MXSTR,"double board: ev %5d, b %3d, %3d;  len %5d %3d %3d - %3d %3d ",
     793                   evID,boardId,i,rd[i].fadLen, rd[i].rBuf->B[0],
     794                   rd[i].rBuf->B[1], rd[i].rBuf->B[ rd[i].bufPos-2], rd[i].rBuf->B[ rd[i].bufPos-1]);
    738795                factOut(kWarn,501, str ) ;
    739796                goto EndBuf ; //--> skip Board
    … …  
    749806             tmS  = boardId*4  -1 ;   //
    750807             src  = head_len/2 ;
     808                for ( px=0; px<9; px++ ) {            //different sort in FAD board.....
    751809             for ( drs=0; drs<4; drs++ ) {
    752                 for ( px=0; px<9; px++ ) {
    753810                   pixH= ntohs(rd[i].rBuf->S[src++]) ;
    754811                   pixC= ntohs(rd[i].rBuf->S[src++]) ;
    … …  
    796853                snprintf(str,MXSTR,"%5d complete event %8d %8d %2d",mBuffer[evID].evNum,evtCtrl.evtBuf[iDx],iDx,evtCtrl.evtStat[ iDx ]);
    797854                factOut(kDebug,-1, str ) ;
     855
     856                if (mBuffer[evID].runNum != actrun ) {        // have we already reported first event of this run ???
     857                   actrun = mBuffer[i].runNum ;
     858                   int ir ;
     859                   for ( ir=0; ir<MAX_RUN; ir++) {
     860                      if ( runCtrl[ir].runId == actrun) {
     861                         if ( runCtrl[ir].lastEvt <0 ) {
     862                            runCtrl[ir].lastEvt = +1 ;
     863                            gotNewRun( actrun, mBuffer[evID].FADhead );
     864                snprintf(str,MXSTR,"gotNewRun %d (ev %d)",mBuffer[evID].runNum,mBuffer[evID].evNum);
     865                factOut(kInfo,1, str ) ;
     866                            break ;
     867                         }
     868                      }
     869                   }
     870                }
     871
    798872                //complete event read ---> flag for next processing
    799873                evtCtrl.evtStat[ iDx ] = 99;
    … …  
    821895
    822896              if (k >= rd[i].bufPos-1 ) {   //no start of header found
    823 //                 snprintf(str,MXSTR,"no start of header on port%d", i ) ;
    824 //                 factOut(kWarn,666, str ) ;
    825 
    826897                 rd[i].bufPos = 0 ;
    827898                 rd[i].bufLen = head_len ;
    … …  
    830901                 rd[i].bufLen += k ;
    831902                 memcpy(&rd[i].rBuf->B[0], &rd[i].rBuf->B[k], rd[i].bufPos ) ;
     903                 memcpy(&rd[i].xBuf->B[0], &rd[i].xBuf->B[k], rd[i].bufPos ) ;
    832904              }
    833905              if ( rd[i].bufPos >= minLen ) {
    … …  
    843915                 rd[i].ftmID  = ntohl(rd[i].rBuf->I[5]) ; //(FTMevt)
    844916                 rd[i].runID  = ntohl(rd[i].rBuf->I[11]) ;
    845                  if (rd[i].runID ==0 ) rd[i].runID = gi_myRun ;
    846917                 rd[i].bufTyp = 1 ;       //ready to read full record
    847918                 rd[i].bufLen = rd[i].fadLen - rd[i].bufPos ;
    848                  if (rd[i].bufLen <=0 ) rd[i].bufLen = 100000 ;    //?
     919
     920                 int fadboard = ntohs(rd[i].rBuf->S[12] ) ;
     921                 int fadcrate = fadboard/256 ;
     922                     fadboard = (fadcrate*10 + fadboard%256) ;
     923snprintf(str,MXSTR,"sk %3d head: %5d %5d %5d %10d %4d %6d",i,rd[i].fadLen,rd[i].evtID,rd[i].ftmID,rd[i].runID,fadboard,jrd) ;
     924factOut(kDebug,1, str ) ;
     925
     926                 if (rd[i].runID ==0 ) rd[i].runID = gi_myRun ;
     927
     928                 if (rd[i].bufLen <=head_len || rd[i].bufLen > MAX_LEN ) {
     929                    snprintf(str,MXSTR,"illegal event-length on port %d",i) ;
     930                    factOut(kFatal,881, str ) ;
     931                    rd[i].bufLen = 100000 ;    //?
     932                 }
    849933                 int fadBoard = ntohs(rd[i].rBuf->S[12] ) ;
    850934                 debugHead(i,fadBoard,rd[i].rBuf);
    … …  
    861945    } //finished trying to read all sockets
    862946
     947snprintf(str,MXSTR,"Loop ---- %3d --- %8d",numokx,jrdx);
     948factOut(kDebug,-1, str ) ;
    863949    gi.numRead[ numok ] ++ ;
    864950
    … …  
    897983
    898984             int id =evtCtrl.evtBuf[k0] ;
    899              snprintf(str,MXSTR,"%5d free event buffer (written) %3d", mBuffer[id].evNum, mBuffer[id].nBoard ) ;
     985             snprintf(str,MXSTR,"%5d free event buffer, nb=%3d", mBuffer[id].evNum, mBuffer[id].nBoard ) ;
    900986             factOut(kDebug,-1, str ) ;
    901987             mBufFree(id) ;               //event written--> free memory
    … …  
    9541040 } else {
    9551041   gi_reset  = 0;
    956    if ( g_runStat==-1 ) gi_resetR = 1 ;
     1042   if ( g_runStat== -1 ) gi_resetR = 1 ;
    9571043   else                 gi_resetR = 7 ;
    9581044   gi_resetS = 7 ; //close all sockets
    … …  
    9711057    for (i=0; i<MAX_SOCK; i++) { 
    9721058       if (rd[i].sockStat ==0 ) {
    973           GenSock(-1, i, 0, NULL, &rd[i]) ; //close and destroy socket   
    974           gi_NumConnect[ i/7 ]-- ;
    975           gi.numConn[ i/7 ]-- ;
    976           gj.numConn[ i/7 ]-- ;
     1059          GenSock(-1, i, 0, NULL, &rd[i]) ; //close and destroy open socket   
     1060          if ( i%7 == 0 ) {
     1061             gi_NumConnect[ i/7 ]-- ;
     1062             gi.numConn[ i/7 ]-- ;
     1063             gj.numConn[ i/7 ]-- ;
     1064             sockDef[i/7] = 0 ;       //flag ro recreate the sockets ...
     1065             rd[i/7].sockStat = -1;    //and try to open asap
     1066          }
    9771067       }
    9781068    }
    … …  
    10221112          if (evtCtrl.evtStat[k0] > minclear ) {
    10231113            int id =evtCtrl.evtBuf[k0] ;
     1114             snprintf(str,MXSTR,"ev %5d free event buffer, nb=%3d", mBuffer[id].evNum, mBuffer[id].nBoard ) ;
     1115             factOut(kDebug,-1, str ) ;
    10241116             mBufFree(id) ;               //event written--> free memory
    10251117             evtCtrl.evtStat[k0] = -1;
    … …  
    13091401              actRun.NTm     = NTMARK ;
    13101402              actRun.Nroi    = mBuffer[id].nRoi ;
    1311 //            actRun.FADhead = mBuffer[id].FADhead ;  //to be corrected
     1403              memcpy(actRun.FADhead, mBuffer[id].FADhead, NBOARDS* sizeof(PEVNT_HEADER) ) ;
    13121404
    13131405              runCtrl[j].fileHd = runOpen(irun,  &actRun, sizeof(actRun) ) ;
    … …  
    13151407                 snprintf(str,MXSTR,"W could not open a file for run %d",irun);
    13161408                 factOut(kError,502, str ) ;
    1317                  runCtrl[j].fileId = 99 ;
     1409                 runCtrl[j].fileId = 91 ;
    13181410              } else {
    13191411                 snprintf(str,MXSTR,"W opened new run_file %d",irun) ;
    … …  
    13251417
    13261418           if (runCtrl[j].fileId != 0 ) {
    1327               snprintf(str,MXSTR,"W no open file for this run %d",irun) ;
    1328               factOut(kWarn,123,str) ;
     1419              if (runCtrl[j].fileId < 0 ) {
     1420                 snprintf(str,MXSTR,"W never opened file for this run %d",irun) ;
     1421                 factOut(kError,123,str) ;
     1422              } else if (runCtrl[j].fileId < 100 ) {
     1423                 snprintf(str,MXSTR,"W.file for this run is closed %d",irun) ;
     1424                 factOut(kWarn,123,str) ;
     1425                 runCtrl[j].fileId += 100 ;
     1426              } else {
     1427                 snprintf(str,MXSTR,"W:file for this run is closed %d",irun) ;
     1428                 factOut(kDebug,123,str) ;
     1429              }
    13291430              evtCtrl.evtStat[k0] = 903 ;
    13301431              gi.wrtErr++ ;
    … …  
    13631464                    snprintf(str,MXSTR,"error closing run %d %d AAA",runCtrl[j].runId,i) ;
    13641465                    factOut(kError,503, str ) ;
    1365                     runCtrl[j].fileId = 9001 ;
     1466                    runCtrl[j].fileId = 92  ;
    13661467                 } else {
    13671468                    snprintf(str,MXSTR,"W closed run %d AAA %d",irun,ii) ;
    13681469                    factOut(kInfo,503, str ) ;
    1369                     runCtrl[j].fileId = 901 ;
     1470                    runCtrl[j].fileId = 93 ;
    13701471                 }
    13711472              }
    … …  
    13931494              snprintf(str,MXSTR,"error closing run %d %d BBB",runCtrl[j].runId,i) ;
    13941495              factOut(kError,506, str ) ;
    1395               runCtrl[j].fileId = 9011 ;
     1496              runCtrl[j].fileId = 94  ;
    13961497           } else {
    13971498              snprintf(str,MXSTR,"W closed run %d BBB %d",runCtrl[j].runId,ii) ;
    13981499              factOut(kInfo,507, str ) ;
    1399               runCtrl[j].fileId = 911 ;
     1500              runCtrl[j].fileId = 95 ;
    14001501           }
    14011502        }
    … …  
    14391540           snprintf(str,MXSTR,"error closing run %d %d CCC",runCtrl[j].runId,i) ;
    14401541           factOut(kError,506, str ) ;
    1441            runCtrl[j].fileId = 9021 ;
     1542           runCtrl[j].fileId = 96  ;
    14421543        } else {
    14431544           snprintf(str,MXSTR,"W closed run %d CCC %d",runCtrl[j].runId,ii) ;
    14441545           factOut(kInfo,507, str ) ;
    1445            runCtrl[j].fileId = 921 ;
     1546           runCtrl[j].fileId = 97 ;
    14461547        }
    14471548     }
    … …  
    14701571  gj.readStat= gj.procStat= gj.writStat= 0 ;
    14711572
    1472   snprintf(str,MXSTR,"Starting EventBuilder");
     1573  snprintf(str,MXSTR,"Starting EventBuilder V15.07 A");
    14731574  factOut(kInfo,-1, str ) ;
    14741575
    1475 /* initialize run control logics */
     1576//initialize run control logics
    14761577  for (i=0; i<MAX_RUN; i++) {
    14771578     runCtrl[i].runId = 0 ;
    … …  
    14791580  }
    14801581
    1481 /* partially initialize event control logics */
     1582//partially initialize event control logics
    14821583  evtCtrl.frstPtr = 0 ;
    14831584  evtCtrl.lastPtr = 0 ;
    … …  
    15011602
    15021603#ifdef BILAND
    1503          xwait.tv_sec = 20;;
     1604         xwait.tv_sec = 30;;
    15041605         xwait.tv_nsec= 0 ;  // sleep for ~20sec
    15051606         nanosleep( &xwait , NULL ) ;
    … …  
    15091610         CloseRunFile( 0, time(NULL)+2, 0) ;
    15101611
    1511          xwait.tv_sec = 5;;
     1612         xwait.tv_sec = 1;;
    15121613         xwait.tv_nsec= 0 ;  // sleep for ~20sec
    15131614         nanosleep( &xwait , NULL ) ;
    … …  
    15631664
    15641665int  runWrite(FileHandle_t fileHd ,  EVENT    *event, size_t len )
    1565 { return 1; } ;
     1666{ return 1; usleep(10000); return 1; }
     1667
     1668
     1669//{ return 1; } ;
    15661670
    15671671int  runClose(FileHandle_t fileHd ,  RUN_TAIL *runth, size_t len )
    … …  
    15741678   int i=0;
    15751679
    1576   printf("------------%d\n",ntohl(fadhd[7].fad_evt_counter) );
    1577   for (i=0; i<NBOARDS; i++) {
    1578       printf("b=%2d,=%5d\n",i,fadhd[i].board_id);
    1579   }
     1680// printf("------------%d\n",ntohl(fadhd[7].fad_evt_counter) );
     1681// for (i=0; i<NBOARDS; i++) {
     1682//    printf("b=%2d,=%5d\n",i,fadhd[i].board_id);
     1683// }
    15801684   return 0;
    15811685}
    … …  
    15851689  int i ;
    15861690
    1587   for (i=0;i<MAX_SOCK;i++) {
    1588      printf("%4d",gi.numRead[i]);
    1589      if (i%20 == 0 ) printf("\n");
    1590   }
     1691//for (i=0;i<MAX_SOCK;i++) {
     1692//   printf("%4d",gi.numRead[i]);
     1693//   if (i%20 == 0 ) printf("\n");
     1694//}
    15911695}
    15921696
     1697void gotNewRun( int runnr, PEVNT_HEADER *headers )
     1698{ printf("got new run %d\n",runnr); return; }
    15931699
    15941700void factStat(GUI_STAT gj) {
    … …  
    16351741
    16361742  g_maxMem = 1024*1024    ;        //MBytes
    1637   g_maxMem = g_maxMem * 1024 *10 ; //10GBytes
     1743//g_maxMem = g_maxMem * 1024 *10 ; //10GBytes
     1744  g_maxMem = g_maxMem *  200;      //100MBytes
    16381745
    16391746
    … …  
    16611768     for (b=0; b<10; b++) {
    16621769        sprintf(ipStr,"10.0.%d.11",128+c) ;
    1663         if (c==0) sprintf(ipStr,"10.0.100.11") ;
     1770      if (c<2) sprintf(ipStr,"10.0.%d.11",128) ;
     1771      else     sprintf(ipStr,"10.0.%d.11",131) ;
     1772//      if (c==0) sprintf(ipStr,"10.0.100.11") ;
    16641773
    16651774        inet_pton(PF_INET, ipStr, &IPaddr) ;
Note: See TracChangeset for help on using the changeset viewer.