KM3NeT_Audio_Channel.h

Go to the documentation of this file.

#ifndef KM3NET_AUDIO_CHANNEL_H_
#define KM3NET_AUDIO_CHANNEL_H_
/**
 * \author fsimeone
 */


#include <cstdio>
#include <cstdlib>
#include <ctime>

#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/function.hpp>

#include "KM3NeT_Audio_Data.h"
#include "toalib/km3_toa_lib.hpp"


typedef std::pair<std::size_t,std::size_t>                          threshold_entry;
typedef boost::shared_ptr<KM3::TOALIB::CTOAFinder::probeSignalT>    pProbe;
typedef boost::function<void(ToA_Packet packet)>                                        callback_send_toa;

//#define DEBUG_KM3NET_AUDIO_CHANNEL
#define MAX_DUMP_SIZE 4194304

class KM3NeT_Audio_Channel
{
public:
        static const int                                                                DEBUG_LEVEL=2;

                                                                                                        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){data_.Check_time(header);};
        void                                                                                    Set_test(uint32_t id){test_=id;};       
        
private:
        void                                                                                    Analysis(ToA_Packet packet,real_type* buffer,uint32_t length);
        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_;
        void                                                                                    Open_test_file(uint32_t id, uint8_t ch);
        uint32_t                                                                                test_;
        uint32_t                                                                                overlap_;       
        std::FILE*                                                                              test_file_;
};

#endif