KM3NeT_DOM.h

Go to the documentation of this file.

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


#include <map>
#include <vector>

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

#include "Definitions/Audio_Structures.h"
#include "KM3NeT_Audio_Channel.h"
#include "toalib/km3_toa_lib.hpp"


#define BSWAP_64(x)     (((uint64_t)(x) << 56) |\
                                                (((uint64_t)(x) << 40) & 0xff000000000000ULL) |\
                                                (((uint64_t)(x) << 24) & 0xff0000000000ULL) |\
                                                (((uint64_t)(x) << 8)  & 0xff00000000ULL) |\
                                                (((uint64_t)(x) >> 8)  & 0xff000000ULL) |\
                                                (((uint64_t)(x) >> 24) & 0xff0000ULL) |\
                                                (((uint64_t)(x) >> 40) & 0xff00ULL) |\
                                                ((uint64_t)(x)  >> 56))
                        
//#define DEBUG_KM3NET_DOM


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

                                                                                KM3NeT_DOM(     boost::asio::io_service& io_service,\
                                                                                                        callback_send_toa callback,\
                                                                                                        std::string& debug_path,\
                                                                                                        std::size_t window=STD_WINDOW,\
                                                                                                        std::size_t overlap=STD_OVERLAP);
        virtual                                                         ~KM3NeT_DOM();

    void                                Add_probe(pProbe probe, std::size_t id, std::size_t threshold);
        void                                                            Check_time_async(Audio_Header header) { strand_.post(boost::bind(&KM3NeT_DOM::Check_time,this,header)); };
        void                                                            Handle_samples_async(uint8_t* buffer,uint32_t length) { strand_.post(boost::bind(&KM3NeT_DOM::Handle_samples,this,buffer,length)); };

        void                                                            Set_test(uint32_t id){ch_n1.Set_test(id);ch_n2.Set_test(id);};
private:
    void                                Check_time(Audio_Header header);
    void                                Handle_samples(uint8_t* buffer,uint32_t length);
    
        boost::asio::io_service::strand         strand_;
    
        Audio_Header                                header_;
    bool                                ch1_;
    bool                                ch2_;
    uint32_t                            audio_word_size_;

    KM3NeT_Audio_Channel                ch_n1;
    KM3NeT_Audio_Channel                ch_n2;

};

typedef boost::shared_ptr<KM3NeT_DOM>   pDOM;

#endif