KM3NeT_DOM.cc

Go to the documentation of this file.

#include "KM3NeT_DOM.h"
/**
 * \author fsimeone
 */


#ifdef DEBUG_KM3NET_DOM
#include <stdlib.h>
#include <iostream>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <Tools/KM3NeT_Debug.h>
#define DEBUG_MSG(str,lev) do { if (((uint8_t)lev)>=KM3NeT_DOM::DEBUG_LEVEL) { DBG_MSG << boost::posix_time::microsec_clock::local_time() << " DOM(" << (void*)this << "): "<< str << '\n'; } }while( false )
#else
#define DEBUG_MSG(str,lev) do { } while ( false )
#endif

KM3NeT_DOM::KM3NeT_DOM( boost::asio::io_service& io_service,\
                                                callback_send_toa callback,\
                                                std::string& debug_path,\
                                                std::size_t window,\
                                                std::size_t overlap\
                                                ):      strand_(io_service),\
                                                        ch_n1(io_service,callback,1,debug_path,window,overlap),\
                                                        ch_n2(io_service,callback,2,debug_path,window,overlap)
                                                        
                                
{
        DEBUG_MSG("Constructor",3);
}

KM3NeT_DOM::~KM3NeT_DOM()
{
        DEBUG_MSG("Destructor",3);
}

void KM3NeT_DOM::Add_probe(pProbe probe, std::size_t id, std::size_t threshold)
{
    ch_n1.Add_probe(probe,id,threshold);  
    ch_n2.Add_probe(probe,id,threshold);  
}

void KM3NeT_DOM::Check_time(Audio_Header header)
{
        DEBUG_MSG("CK time",1);
 
    header_=header;
        DEBUG_MSG("h seconds="<<header_.Common_Header.Time_Stamp_seconds,0);
        DEBUG_MSG("h tick="<<header_.Common_Header.Time_Stamp_ticks,0);

    ch1_=ch2_=false;
        audio_word_size_=4;
        if (header_.Info.Info.Bits.ChannelsSent==0)
        {
                ch1_=true;
                ch2_=true;
                if (header_.Info.Info.Bits.Amplitude_Resolution==1) audio_word_size_+=2;
                else if (header_.Info.Info.Bits.Amplitude_Resolution==2) audio_word_size_+=4;
        }
        else if (header_.Info.Info.Bits.ChannelsSent==1) ch1_=true;
        else ch2_=true;
    if (ch1_) ch_n1.Check_time(header_);
    if (ch2_) ch_n2.Check_time(header_);           
}

void KM3NeT_DOM::Handle_samples(uint8_t* buffer,uint32_t length)
{
        DEBUG_MSG("Hsample",1);
        uint8_t*                l_dummy=buffer;
        uint8_t                 l_shift1;
        uint8_t                 l_shift2;
        uint64_t                l_mask1;
        uint64_t                l_mask2;
        real_type               l_max=2147483648.;

        if (header_.Info.Info.Bits.Amplitude_Resolution==0)
        {
                l_mask1=0x00FFF00000000000;
                l_mask2=0x00000FFF00000000;
                l_shift1=24;
                l_shift2=12;
        }
        else if(header_.Info.Info.Bits.Amplitude_Resolution==1)
        {
                l_mask1=0x00FFFF0000000000;
                l_mask2=0x000000FFFF000000;
                l_shift1=24;
                l_shift2=8;
        }
        else
        {
                l_mask1=0x00FFFFFF00000000;
                l_mask2=0x00000000FFFFFF00;
                l_shift1=24;
                l_shift2=0;
        }

        uint32_t l_k=0;
        int64_t l_audio_w;
        if(header_.Info.Samplig_Rate != 0){
                while(l_k<header_.Common_Header.Number_of_Items)
                {
                        l_audio_w= BSWAP_64(*((int64_t*)buffer));
                        if(ch1_) ch_n1.Append((real_type) ((int32_t)(((l_audio_w) & l_mask1) >> l_shift1 ))/l_max);
                        if(ch2_) ch_n2.Append((real_type) ((int32_t)(((l_audio_w) & l_mask2) >> l_shift2 ))/l_max);
                        l_k++;
                        buffer+=audio_word_size_;
                }
        }
        free(l_dummy);
}