KM3NeT_Audio_Data.cc

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;
}