void tcp_connection::SendData ( uint32_t  triggerid )

inline

Definition at line 132 of file fad.cc.

References buffer, data, fRegionOfInterest, i, kDelimiterEnd, kNumChannels, kNumTemp, and Time::utc.

    {
        if (fOutQueue.size()>3)
            return;

        fHeader.fPackageLength = sizeof(EventHeader)/2+1;
        fHeader.fEventCounter++;
        fHeader.fTriggerCounter = triggerid;
        fHeader.fTimeStamp = uint32_t((Time(Time::utc).UnixTime()-fStartTime)*10000);
        fHeader.fFreqRefClock = 997+rand()/(RAND_MAX/7);

        /* Trigger ID

        * Byte[4]: Bit 0:    ext1
        * Byte[4]: Bit 1:    ext2
        * Byte[4]: Bit 2-7:  n/40
        * Byte[5]: Bit 0: LP_1
        * Byte[5]: Bit 1: LP_2
        * Byte[5]: Bit 2: Pedestal
        * Byte[5]: Bit 3:
        * Byte[5]: Bit 4:
        * Byte[5]: Bit 5:
        * Byte[5]: Bit 6:
        * Byte[5]: Bit 7: TIM source

        */

        for (int i=0; i<FAD::kNumTemp; i++)
            fHeader.fTempDrs[i] = (42.+fBoardId/40.+float(rand())/RAND_MAX*5)*16;

        // Header, channel header, end delimiter
        size_t sz = sizeof(fHeader) + kNumChannels*sizeof(FAD::ChannelHeader) + 2;
        // Data
        for (int i=0; i<kNumChannels; i++)
            sz += fChHeader[i].fRegionOfInterest*2;

        vector<uint16_t> evtbuf;
        evtbuf.reserve(sz);

        for (int i=0; i<kNumChannels; i++)
        {
            fChHeader[i].fStartCell = int64_t(1023)*rand()/RAND_MAX;

             vector<int16_t> data(fChHeader[i].fRegionOfInterest, -1024+0x42+i/9+fHeader.fDac[1]/32);

            for (int ii=0; ii<fChHeader[i].fRegionOfInterest; ii++)
            {
                const int rel =  ii;
                const int abs = (ii+fChHeader[i].fStartCell)%fChHeader[i].fRegionOfInterest;

                data[rel] +=  6.*rand()/RAND_MAX +  5*exp(-rel/10); // sigma=10
                data[rel] += 15*sin(2*3.1415*abs/512); // sigma=10
            }

            if (triggerid>0)
            {
                int    p    =   5.*rand()/RAND_MAX+ 20;
                double rndm = 500.*rand()/RAND_MAX+500;
                for (int ii=0; ii<fChHeader[i].fRegionOfInterest; ii++)
                    data[ii] += rndm*exp(-0.5*(ii-p)*(ii-p)/25); // sigma=10
            }

            const vector<uint16_t> buf = fChHeader[i].HtoN();

            evtbuf.insert(evtbuf.end(), buf.begin(), buf.end());
            evtbuf.insert(evtbuf.end(), data.begin(), data.end());

            fHeader.fPackageLength += sizeof(ChannelHeader)/2;
            fHeader.fPackageLength += fChHeader[i].fRegionOfInterest;
        }

        evtbuf.push_back(htons(FAD::kDelimiterEnd));

        const vector<uint16_t> h = fHeader.HtoN();

        evtbuf.insert(evtbuf.begin(), h.begin(), h.end());

        fOutQueue.push_back(evtbuf);

        if (fCommandSocket)
            AsyncWrite(this, ba::buffer(ba::const_buffer(fOutQueue.back().data(), fOutQueue.back().size()*2)));
        else
        {
            if (fSockets.size()==0)
                return;

            fSocket++;
            fSocket %= fSockets.size();

            AsyncWrite(fSockets[fSocket].get(), ba::buffer(ba::const_buffer(fOutQueue.back().data(), fOutQueue.back().size()*2)));
        }
    }