KM3NeT_Acoustic_Link Class Reference

#include <KM3NeT_Acoustic_Link.h>

Inheritance diagram for KM3NeT_Acoustic_Link:

Public Member Functions
	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 ()
void	Start_reading ()
void	Disconnect (bool Soft=true)

Static Public Attributes
static const int	DEBUG_LEVEL =3

Private Member Functions
void	Read_completed (const boost::system::error_code &error, std::size_t transferred)

Private Attributes
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_

Detailed Description

Author

fsimeone

Definition at line 25 of file KM3NeT_Acoustic_Link.h.

Constructor & Destructor Documentation

KM3NeT_Acoustic_Link()

KM3NeT_Acoustic_Link::KM3NeT_Acoustic_Link	(	boost::asio::io_service &	io_service,
		std::map< std::size_t, pDOM > &	doms,
		uint32_t	buffer_size = STD_DIM_BUFFER
	)

Author

fsimeone

Definition at line 17 of file KM3NeT_Acoustic_Link.cc.

                                                                                         :      strand_(io_service),\
                                                                                                socket_(io_service),\
                                                                                                dom_map_(doms)
{
        DEBUG_MSG("Constructor",3);
        data_size_=AUDIO_PACKET_FIXED_SIZE;
        buffer_size_=buffer_size;
        buffer_=(uint8_t*)malloc(buffer_size_);
        header_received_=false;
}

~KM3NeT_Acoustic_Link()

KM3NeT_Acoustic_Link::~KM3NeT_Acoustic_Link ( )

virtual

Definition at line 31 of file KM3NeT_Acoustic_Link.cc.

{
        DEBUG_MSG("Destructor",3);
        Disconnect();
        free(buffer_);
}

Member Function Documentation

Socket()

boost::asio::ip::tcp::socket& KM3NeT_Acoustic_Link::Socket ( )

inline

Definition at line 36 of file KM3NeT_Acoustic_Link.h.

{return socket_;};

Start_reading()

void KM3NeT_Acoustic_Link::Start_reading

(

)

Definition at line 49 of file KM3NeT_Acoustic_Link.cc.

{
        if (buffer_size_<data_size_)
        {
                DEBUG_MSG("Realloc: free " << (void*) buffer_<<" - "<<buffer_size_<<" byte",1);
                free(buffer_);
                buffer_size_=data_size_;
                buffer_=(uint8_t*)malloc(buffer_size_);
                DEBUG_MSG("Realloc: alloc " << (void*) buffer_<<" - "<<buffer_size_<<" byte",1);
        }
 
        async_read(socket_,boost::asio::buffer(buffer_,buffer_size_),boost::asio::transfer_exactly(data_size_),strand_.wrap(boost::bind(&KM3NeT_Acoustic_Link::Read_completed, shared_from_this(), _1, _2)));
}

Disconnect()

void KM3NeT_Acoustic_Link::Disconnect

(

bool

Soft = true

)

Definition at line 38 of file KM3NeT_Acoustic_Link.cc.

{
        DEBUG_MSG("Disconnect",3);
        if (soft)
        {
                boost::system::error_code l_ignore;
                socket_.shutdown(boost::asio::ip::tcp::socket::shutdown_both, l_ignore);
        }
        socket_.close();
}

Read_completed()

void KM3NeT_Acoustic_Link::Read_completed ( const boost::system::error_code &  error, std::size_t  transferred  )

private

Definition at line 63 of file KM3NeT_Acoustic_Link.cc.

{
  if (!error)
  {
        DEBUG_MSG("Read completed " << transferred << " bytes ",1);
        if (!header_received_)
        {
                header_received_=true;
                Audio_Header* l_pheader=(Audio_Header*)buffer_;
                DEBUG_MSG("h seconds="<<l_pheader->Common_Header.Time_Stamp_seconds,0);
                DEBUG_MSG("h tick="<<l_pheader->Common_Header.Time_Stamp_ticks,0);
                data_size_=l_pheader->Common_Header.Frame_Length-sizeof(Audio_Header);
                dom_id_=l_pheader->Common_Header.DOM_Identifier;
                
                std::map<std::size_t,pDOM>::iterator i=dom_map_.find(dom_id_);
                if (i!=dom_map_.end())  i->second->Check_time_async(*l_pheader);
        }
        else
        {
                std::map<std::size_t,pDOM>::iterator i=dom_map_.find(dom_id_);
                if (i!=dom_map_.end())  
                {
                        uint8_t* tmp_buffer=(uint8_t*)malloc(transferred);
            memcpy(tmp_buffer,buffer_,transferred);
                        i->second->Handle_samples_async(tmp_buffer,transferred);
                }
                data_size_=AUDIO_PACKET_FIXED_SIZE;
                header_received_=false;
        }
        Start_reading();
  }
  else
  {
          DEBUG_MSG("Read completed err " << error <<" "<< transferred << " bytes",3);
          Disconnect();
  }
}

Member Data Documentation

DEBUG_LEVEL

const int KM3NeT_Acoustic_Link::DEBUG_LEVEL =3

static

Definition at line 30 of file KM3NeT_Acoustic_Link.h.

strand_

boost::asio::io_service::strand KM3NeT_Acoustic_Link::strand_

private

Definition at line 43 of file KM3NeT_Acoustic_Link.h.

socket_

boost::asio::ip::tcp::socket KM3NeT_Acoustic_Link::socket_

private

Definition at line 44 of file KM3NeT_Acoustic_Link.h.

buffer_

uint8_t* KM3NeT_Acoustic_Link::buffer_

private

Definition at line 45 of file KM3NeT_Acoustic_Link.h.

buffer_size_

uint32_t KM3NeT_Acoustic_Link::buffer_size_

private

Definition at line 46 of file KM3NeT_Acoustic_Link.h.

data_size_

uint32_t KM3NeT_Acoustic_Link::data_size_

private

Definition at line 47 of file KM3NeT_Acoustic_Link.h.

dom_map_

std::map<std::size_t,pDOM>& KM3NeT_Acoustic_Link::dom_map_

private

Definition at line 48 of file KM3NeT_Acoustic_Link.h.

dom_id_

uint32_t KM3NeT_Acoustic_Link::dom_id_

private

Definition at line 49 of file KM3NeT_Acoustic_Link.h.

header_received_

bool KM3NeT_Acoustic_Link::header_received_

private

Definition at line 50 of file KM3NeT_Acoustic_Link.h.

---

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

• KM3NeT_Acoustic_Link.h
• KM3NeT_Acoustic_Link.cc