KM3NeT_Acoustic_Link.h

Go to the documentation of this file.

#ifndef KM3NET_ACOUSTIC_LINK_H_
#define KM3NET_ACOUSTIC_LINK_H_

#include <map>

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

#include "Definitions/Audio_Structures.h"
#include "Tools/KM3NeT_DOM.h"


#define STD_DIM_BUFFER  131072

/**
 * \author fsimeone
 */

//#define DEBUG_KM3NET_ACOUSTIC_LINK


class KM3NeT_Acoustic_Link : public boost::enable_shared_from_this<KM3NeT_Acoustic_Link>
{


public:
        static const int                                        DEBUG_LEVEL=3;
        
                                                                                                KM3NeT_Acoustic_Link(   boost::asio::io_service& io_service,\
                                                                                                                                                std::map<std::size_t,pDOM>& doms,\
                                                                                                                                                uint32_t buffer_size=STD_DIM_BUFFER);
        virtual                                                                         ~KM3NeT_Acoustic_Link();
        boost::asio::ip::tcp::socket&                           Socket(){return socket_;};
        void                                                                            Start_reading();
        void                                            Disconnect(bool Soft=true);

private:
        void                                                                            Read_completed(const boost::system::error_code& error,std::size_t transferred);
        
        boost::asio::io_service::strand                         strand_;
        boost::asio::ip::tcp::socket                            socket_;
        uint8_t*                                                                        buffer_;
        uint32_t                                                                        buffer_size_;
        uint32_t                                                                        data_size_;
        std::map<std::size_t,pDOM>&                                     dom_map_;
        uint32_t                                                                        dom_id_;
        bool                                                                            header_received_;
};

typedef boost::shared_ptr<KM3NeT_Acoustic_Link> pLink;

#endif /* KM3NET_ACOUSTIC_LINK_H_ */