KM3NeT_Audio_Channel Class Reference

#include <KM3NeT_Audio_Channel.h>

Public Member Functions
	KM3NeT_Audio_Channel (boost::asio::io_service &io_service, callback_send_toa callback, uint32_t id, std::string &debug_path, uint32_t window=STD_WINDOW, uint32_t overlap=STD_OVERLAP)
virtual	~KM3NeT_Audio_Channel ()
void	Add_probe (pProbe probe, std::size_t id, std::size_t threshold)
void	Append (real_type sample)
void	Check_time (Audio_Header header)
void	Set_test (uint32_t id)

Static Public Attributes
static const int	DEBUG_LEVEL =2

Private Member Functions
void	Analysis (ToA_Packet packet, real_type *buffer, uint32_t length)
void	Open_test_file (uint32_t id, uint8_t ch)

Private Attributes
boost::asio::io_service::strand	strand_
std::map< std::size_t, std::size_t >	thresholds_
std::vector< std::size_t >	probes_id_
callback_send_toa	send_toa_
uint32_t	id_
KM3::TOALIB::CTOAFinder	finder_
KM3NeT_Audio_Data	data_
std::string	debug_files_path_
uint32_t	test_
uint32_t	overlap_
std::FILE *	test_file_

Detailed Description

Definition at line 27 of file KM3NeT_Audio_Channel.h.

Constructor & Destructor Documentation

KM3NeT_Audio_Channel::KM3NeT_Audio_Channel	(	boost::asio::io_service &	io_service,
		callback_send_toa	callback,
		uint32_t	id,
		std::string &	debug_path,
		uint32_t	window = STD_WINDOW,
		uint32_t	overlap = STD_OVERLAP
	)

Definition at line 17 of file KM3NeT_Audio_Channel.cc.

                                                                                         :      strand_(io_service),\

												finder_(window),\

												data_(window,overlap)
{
        DEBUG_MSG("Constructor",0);
        id_=id;
        send_toa_=callback;
        test_=0;
        overlap_=overlap;
        test_file_=0;
        debug_files_path_=debug_path;
}

KM3NeT_Audio_Channel::~KM3NeT_Audio_Channel ( )

virtual

Definition at line 36 of file KM3NeT_Audio_Channel.cc.

{
        DEBUG_MSG("Destructor",0);
        if ((test_)&&(test_file_)) std::fclose(test_file_);
}

Member Function Documentation

void KM3NeT_Audio_Channel::Add_probe	(	pProbe	probe,
		std::size_t	id,
		std::size_t	threshold
	)

Definition at line 42 of file KM3NeT_Audio_Channel.cc.

{
    thresholds_.insert(threshold_entry(id,threshold));
    probes_id_.push_back(id);
        finder_.addProbeSignal(probe);
}

void KM3NeT_Audio_Channel::Append

(

real_type

sample

)

Definition at line 49 of file KM3NeT_Audio_Channel.cc.

{
        if(data_.Append(sample))
        {
                ToA_Packet l_toa;
                l_toa.Time.Channel=1;
                real_type* buffer=data_.Get_window(&l_toa);
                strand_.post(boost::bind(&KM3NeT_Audio_Channel::Analysis,this,l_toa,buffer,data_.Get_size()));
        }
}

void KM3NeT_Audio_Channel::Check_time ( Audio_Header  header )

inline

Definition at line 42 of file KM3NeT_Audio_Channel.h.

{data_.Check_time(header);};

void KM3NeT_Audio_Channel::Set_test ( uint32_t  id )

inline

Definition at line 43 of file KM3NeT_Audio_Channel.h.

{test_=id;};    

void KM3NeT_Audio_Channel::Analysis ( ToA_Packet  packet, real_type *  buffer, uint32_t  length  )

private

Definition at line 60 of file KM3NeT_Audio_Channel.cc.

{
        DEBUG_MSG("Analysis",2);
        if (test_)
        {
                if (!test_file_) Open_test_file(packet.Header.DOM_Identifier,packet.Time.Channel);

                if (std::ftell(test_file_)>MAX_DUMP_SIZE)
                {
                        DEBUG_MSG("Test file DOM="<<packet.Header.DOM_Identifier<<" ch="<<packet.Time.Channel<<" closed",2);
                        std::fclose(test_file_);
                        Open_test_file(packet.Header.DOM_Identifier,packet.Time.Channel);
                }

                if (test_file_) 
                {
                        std::fwrite( (char*) &packet.Header.Time_Stamp_seconds, sizeof(uint32_t), 1, test_file_);
                        std::fwrite( (char*) &packet.Header.Time_Stamp_ticks, sizeof(uint32_t), 1, test_file_);
                        std::fwrite( (char*) &length, sizeof(uint32_t), 1, test_file_);
                        std::fwrite( ((char*)buffer)+sizeof(real_type)*overlap_,sizeof(real_type), length-overlap_, test_file_);
                }
        }
        std::vector<KM3::TOALIB::CTOAInfo> toaList;
        finder_.copyFromBuffer(buffer,length);
        finder_.findTOAs(toaList);
        free(buffer);

        packet.Header.Number_of_Items=1;
        packet.Header.Frame_Length=sizeof(ToA_Packet);
        
        packet.Header.Detector_Identifier=htonl(packet.Header.Detector_Identifier);
        packet.Header.DOM_Identifier=htonl(packet.Header.DOM_Identifier);
        packet.Header.DQ_Status=htonl(packet.Header.DQ_Status);
        packet.Header.DOM_Status1=htonl(packet.Header.DOM_Status1);
        packet.Header.DOM_Status2=htonl(packet.Header.DOM_Status2);
        packet.Header.DOM_Status3=htonl(packet.Header.DOM_Status3);
        packet.Header.DOM_Status4=htonl(packet.Header.DOM_Status4);
        packet.Header.Data_Type=htonl(packet.Header.Data_Type);
        packet.Header.Frame_Length=htonl(packet.Header.Frame_Length);
        packet.Header.Number_of_Items=htonl(packet.Header.Number_of_Items);
        packet.Header.Run_Number=htonl(packet.Header.Run_Number);
        packet.Header.Sequence_Number=htonl(packet.Header.Sequence_Number);
        packet.Header.Time_Stamp_seconds=htonl(packet.Header.Time_Stamp_seconds);
        packet.Header.Time_Stamp_ticks=htonl(packet.Header.Time_Stamp_ticks);

        double sampling=128./packet.Time.Sampling_Rate;
        for (uint8_t i=0; i<toaList.size(); i++)
        {
                ToA_Packet l_toa;
                l_toa=packet;
                l_toa.Time.Reserved=0;

                if (toaList[i].getGoodness()>=thresholds_.find(probes_id_[i])->second)
                {
                        l_toa.Time.Emitter_ID=probes_id_[i];
                        l_toa.Time.Quality_Factor=toaList[i].getGoodness();
                        l_toa.Time.ToA+=sampling * toaList[i].getTime();

                        l_toa.Time.Emitter_ID=htonl(l_toa.Time.Emitter_ID);
                        l_toa.Time.Quality_Factor=htonl(l_toa.Time.Quality_Factor);
                        l_toa.Time.ToA=htonl(l_toa.Time.ToA);

                        send_toa_(l_toa);
                }
        }
}

void KM3NeT_Audio_Channel::Open_test_file ( uint32_t  id, uint8_t  ch  )

private

Definition at line 127 of file KM3NeT_Audio_Channel.cc.

{
        std::string l_file=debug_files_path_;
        std::time_t seconds = std::time(0);
        l_file+="DOM_"+std::to_string((long long unsigned int)id)+"_CH"+std::to_string((long long unsigned int)ch)+"_"+std::to_string((long long unsigned int)seconds)+".bin";
        test_file_= std::fopen(l_file.c_str(),"wb");
    DEBUG_MSG("Test file opened at "<<seconds,2);
}

Member Data Documentation

const int KM3NeT_Audio_Channel::DEBUG_LEVEL =2

static

Definition at line 30 of file KM3NeT_Audio_Channel.h.

boost::asio::io_service::strand KM3NeT_Audio_Channel::strand_

private

Definition at line 47 of file KM3NeT_Audio_Channel.h.

std::map<std::size_t,std::size_t> KM3NeT_Audio_Channel::thresholds_

private

Definition at line 48 of file KM3NeT_Audio_Channel.h.

std::vector<std::size_t> KM3NeT_Audio_Channel::probes_id_

private

Definition at line 49 of file KM3NeT_Audio_Channel.h.

callback_send_toa KM3NeT_Audio_Channel::send_toa_

private

Definition at line 51 of file KM3NeT_Audio_Channel.h.

uint32_t KM3NeT_Audio_Channel::id_

private

Definition at line 53 of file KM3NeT_Audio_Channel.h.

KM3::TOALIB::CTOAFinder KM3NeT_Audio_Channel::finder_

private

Definition at line 55 of file KM3NeT_Audio_Channel.h.

KM3NeT_Audio_Data KM3NeT_Audio_Channel::data_

private

Definition at line 56 of file KM3NeT_Audio_Channel.h.

std::string KM3NeT_Audio_Channel::debug_files_path_

private

Definition at line 58 of file KM3NeT_Audio_Channel.h.

uint32_t KM3NeT_Audio_Channel::test_

private

Definition at line 60 of file KM3NeT_Audio_Channel.h.

uint32_t KM3NeT_Audio_Channel::overlap_

private

Definition at line 61 of file KM3NeT_Audio_Channel.h.

std::FILE* KM3NeT_Audio_Channel::test_file_

private

Definition at line 62 of file KM3NeT_Audio_Channel.h.

---

The documentation for this class was generated from the following files:

• KM3NeT_Audio_Channel.h
• KM3NeT_Audio_Channel.cc