KM3NeT_Audio_Data.cpp

Go to the documentation of this file.

#include "KM3NeT_Audio_Data.h"

#include <netinet/in.h>

#ifdef DEBUG_KM3NET_AUDIO_DATA
#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_Audio_Data::DEBUG_LEVEL) { DBG_MSG << boost::posix_time::microsec_clock::local_time() << " KM3NET_AUDIO_DATA(" << (void*)this << "): "<< str << '\n'; } }while( false )
#else
#define DEBUG_MSG(str,lev) do { } while ( false )
#endif

/**
 * \author fsimeone
 */

KM3NeT_Audio_Data::KM3NeT_Audio_Data(uint32_t window,uint32_t overlap)
{
        DEBUG_MSG("Constructor",0);
        if      ((window==0)||(overlap==0)||(overlap>=window))
        {
                window=STD_WINDOW;
                overlap=STD_OVERLAP;
        }
        window_=window;
        overlap_=overlap;
        bound_=window_-overlap_;
        write_=offset_=0;
        data_=(real_type*)malloc(window_*sizeof(real_type));
        next_.Time_Stamp_seconds=header_.Common_Header.Time_Stamp_seconds=0;
        next_.Time_Stamp_ticks=header_.Common_Header.Time_Stamp_ticks=0;
}

KM3NeT_Audio_Data::~KM3NeT_Audio_Data()
{
        DEBUG_MSG("Desctructor",0);
        free(data_);
}

void KM3NeT_Audio_Data::Check_time(Audio_Header header)
{
        DEBUG_MSG("common header frame length="<<header.Common_Header.Frame_Length,1);
        DEBUG_MSG("common header data type="<<header.Common_Header.Data_Type,1);
        DEBUG_MSG("common header detector identifier="<<header.Common_Header.Detector_Identifier,1);
        DEBUG_MSG("common header run number="<<header.Common_Header.Run_Number,1);
        DEBUG_MSG("common header sequence number="<<header.Common_Header.Sequence_Number,1);
        DEBUG_MSG("common header seconds="<<header.Common_Header.Time_Stamp_seconds,1);
        DEBUG_MSG("common header ticks="<<header.Common_Header.Time_Stamp_ticks,1);
        DEBUG_MSG("common header dom id="<<header.Common_Header.DOM_Identifier,1);
        DEBUG_MSG("common header dq status="<<header.Common_Header.DQ_Status,1);
        DEBUG_MSG("common header som status1="<<header.Common_Header.DOM_Status1,1);
        DEBUG_MSG("common header som status2="<<header.Common_Header.DOM_Status2,1);
        DEBUG_MSG("common header som status3="<<header.Common_Header.DOM_Status3,1);
        DEBUG_MSG("common header som status4="<<header.Common_Header.DOM_Status4,1);
        DEBUG_MSG("common header items="<<header.Common_Header.Number_of_Items,1);

        DEBUG_MSG("header time info="<<header.Info.Time_Info,1);
        header.Info.Time_Info=ntohl(header.Info.Time_Info);

        if ( (next_.Time_Stamp_seconds!=header.Common_Header.Time_Stamp_seconds)||(next_.Time_Stamp_ticks!=header.Common_Header.Time_Stamp_ticks+header.Info.Time_Info) )
        {
                DEBUG_MSG("cktime reset",3);
                DEBUG_MSG("next s="<<next_.Time_Stamp_seconds,3);
                DEBUG_MSG("next tick="<<next_.Time_Stamp_ticks,3);
                DEBUG_MSG("head s="<<header.Common_Header.Time_Stamp_seconds,3);
                DEBUG_MSG("head tick="<<(header.Common_Header.Time_Stamp_ticks+header.Info.Time_Info),3);
                header_=header;
            offset_=round(((float)header_.Info.Time_Info)/62.5);
                next_.Time_Stamp_seconds=header.Common_Header.Time_Stamp_seconds;
                next_.Time_Stamp_ticks=header.Common_Header.Time_Stamp_ticks+header.Info.Time_Info;
                write_=0;
        }
        else
        {
                DEBUG_MSG("cktime NO reset",0);
        }
}

bool KM3NeT_Audio_Data::Append(real_type d)
{
        if (data_==NULL) return false;
        data_[write_]=d;
        write_++;
        DEBUG_MSG("append sampling"<<header_.Info.Samplig_Rate,1);
        next_.Time_Stamp_ticks+=(8000/header_.Info.Samplig_Rate);
        if (next_.Time_Stamp_ticks>=62500000)
        {
                next_.Time_Stamp_ticks-=62500000;
                next_.Time_Stamp_seconds++;
        }
        if (write_ == window_) return true;
        return false;
}

real_type* KM3NeT_Audio_Data::Get_window(ToA_Packet* packet)
{
        real_type* l_dummy=data_;
        data_=(real_type*)malloc(window_*sizeof(real_type));
        memcpy((void*)data_,(void*)(l_dummy+bound_),overlap_*sizeof(real_type));
        write_=overlap_;
        packet->Time.ToA=offset_;
        packet->Header=header_.Common_Header;
        packet->Time.Resolution=header_.Info.Info.Bits.Amplitude_Resolution;
        packet->Time.Sampling_Rate=header_.Info.Samplig_Rate;
        
        header_.Common_Header.Time_Stamp_ticks+=bound_*(8000/header_.Info.Samplig_Rate);
        while (header_.Common_Header.Time_Stamp_ticks>=62500000)
        {
                header_.Common_Header.Time_Stamp_ticks-=62500000;
                header_.Common_Header.Time_Stamp_seconds++;
        }
        return l_dummy;
}