Changeset 11199


Ignore:
Timestamp:
Jun 27, 2011, 3:06:10 PM (9 years ago)
Author:
tbretz
Message:
Removed fDimCurrentEvent; wrapped update of fDimEvents into a 1s check.
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/FACT++/src/EventBuilderWrapper.h

    r11188 r11199  
    2323    extern int CloseRunFile(uint32_t runId, uint32_t closeTime);
    2424}
     25
     26namespace ba = boost::asio;
     27namespace bs = boost::system;
     28
     29using ba::ip::tcp;
    2530
    2631class DataFileImp
     
    718723    DimDescribedService fDimRuns;
    719724    DimDescribedService fDimEvents;
    720     DimDescribedService fDimCurrentEvent;
     725//    DimDescribedService fDimCurrentEvent;
    721726    DimDescribedService fDimEventData;
    722727    DimDescribedService fDimFwVersion;
     
    739744        fDimRuns        ("FAD_CONTROL/RUNS",             "I:1", ""),
    740745        fDimEvents      ("FAD_CONTROL/EVENTS",           "I:2", ""),
    741         fDimCurrentEvent("FAD_CONTROL/CURRENT_EVENT",    "I:1", ""),
     746//        fDimCurrentEvent("FAD_CONTROL/CURRENT_EVENT",    "I:1", ""),
    742747        fDimEventData   ("FAD_CONTROL/EVENT_DATA",       "S:1;I:1;S:1;I:2;S:1;S", ""),
    743748        fDimFwVersion   ("FAD_CONTROL/FIRMWARE_VERSION", "F:43", ""),
     
    755760
    756761        fDimRuns.Update(uint32_t(0));
    757         fDimCurrentEvent.Update(uint32_t(0));
     762//        fDimCurrentEvent.Update(uint32_t(0));
    758763        fDimEvents.Update(fNumEvts);
    759764
     
    876881
    877882    bool IsConnected(int i) const     { return gi_NumConnect[i]==7; }
    878     bool IsDisconnected(int i) const  { return gi_NumConnect[i]<=0; }
     883    bool IsConnecting(int i) const    { return !IsConnected(i) && !IsDisconnected(i); }
     884    bool IsDisconnected(int i) const  { return gi_NumConnect[i]<=0 && g_port[i].sockDef==0; }
    879885    int  GetNumConnected(int i) const { return gi_NumConnect[i]; }
    880886
     
    971977            fDimRuns.Update(fMaxRun);
    972978            fDimEvents.Update(fNumEvts);
    973             fDimCurrentEvent.Update(uint32_t(0));
     979//            fDimCurrentEvent.Update(uint32_t(0));
    974980        }
    975981
     
    988994        if (file->GetRunId()==fMaxRun)
    989995        {
    990             fDimCurrentEvent.Update(e->EventNum);
     996            //fDimCurrentEvent.Update(e->EventNum);
    991997            fNumEvts[kCurrent]++;
    992998        }
    993999
    9941000        fNumEvts[kTotal]++;
    995         fDimEvents.Update(fNumEvts);
     1001
     1002        static Time oldt;
     1003        Time newt;
     1004        if (newt>oldt+boost::posix_time::seconds(1))
     1005        {
     1006            fDimEvents.Update(fNumEvts);
     1007            oldt = newt;
     1008        }
    9961009
    9971010        // ===> SignalEvtWritten(runid);
     
    11351148
    11361149        } __attribute__((__packed__));;
    1137 
     1150/*
    11381151        template<typename T>
    11391152        vector<T> CheckVals(const PEVNT_HEADER *fadhd, const T *val, bool &rc)
     
    11581171            return vec;
    11591172        }
    1160        /*
     1173
    11611174        template<typename T>
    11621175        vector<uint8_t> CheckBits(const PEVNT_HEADER *fadhd, const T &val, T &rc)
     
    11851198    int eventCheck(PEVNT_HEADER *fadhd, EVENT *event)
    11861199    {
     1200
     1201        return 0;
     1202
    11871203        /*
    11881204         fadhd[i] ist ein array mit den 40 fad-headers
     
    14661482        vector<uint> con(gi_NumConnect, gi_NumConnect+40);
    14671483
    1468         bool changed = con!=fNumConnected;
     1484        bool changed = con!=fNumConnected || !IsThreadRunning();
    14691485
    14701486        fNumConnected = con;
     
    15661582    void debugHead(int socket, void *buf)
    15671583    {
    1568         EventBuilderWrapper::This->debugHead(socket, FAD::EventHeader(vector<uint16_t>(reinterpret_cast<uint16_t*>(buf),
    1569                                                                                        reinterpret_cast<uint16_t*>(buf)+sizeof(FAD::EventHeader)/2)));
     1584        const uint16_t *ptr = reinterpret_cast<uint16_t*>(buf);
     1585
     1586        EventBuilderWrapper::This->debugHead(socket, FAD::EventHeader(ptr));
    15701587    }
    15711588
     
    15771594    void debugRead(int isock, int ibyte, int32_t event, int32_t ftmevt, int32_t runno, int state, uint32_t tsec, uint32_t tusec)
    15781595    {
    1579         return EventBuilderWrapper::This->debugRead(isock, ibyte, event, ftmevt, runno, state, tsec, tusec);
     1596        EventBuilderWrapper::This->debugRead(isock, ibyte, event, ftmevt, runno, state, tsec, tusec);
    15801597    }
    15811598
Note: See TracChangeset for help on using the changeset viewer.