Brief description of class still missing. More...

#include <PeerInfo.h>

Public Member Functions
void	addDestination (const Address &destination)
const Address &	address () const
void	beaconReceived ()
void	calculate ()
void	connect (const Address &peer, uint16_t port)
double	lastBeaconDelay ()
const LinkInfo &	link () const
const MasterTime &	masterTime () const
	PeerInfo (const Address &a)
const MasterTime &	peerMasterTime () const
void	setLink (const LinkInfo &l)
void	setMasterTime (const MasterTime &m)
void	setPeerMasterTime (const MasterTime &m)
void	setStream (LinkStream *stream)
const LinkStream *	stream () const
	~PeerInfo ()

Detailed Description

Brief description of class still missing.

Full description of class still missing

Constructor & Destructor Documentation

PeerInfo::PeerInfo ( const Address & a )

Description of constructor still missing

{
  _address=a;
  _timer=0;
  _stream=0;
}

PeerInfo::~PeerInfo ( )

Description of destructor still missing

References GpCoreTools::Stream::close().

{
  delete _timer;
  if(_stream) _stream->close();
}

Member Function Documentation

void PeerInfo::addDestination ( const Address & destination )

const Address& PeerInfo::address ( ) const [inline]

Referenced by PeerTracker::checkDeadPeers(), PeerTracker::resetFromMasterGateway(), PeerTracker::resetToMasterGateway(), and PeerTracker::stop().

{return _address;}

void PeerInfo::beaconReceived ( ) [inline]

References GpCoreTools::Chrono::start().

Referenced by PeerTracker::event().

{_lastBeacon.start();}

void PeerInfo::calculate ( )

Link and peer master time must be up-to-date.

References LinkInfo::isLinked(), LinkInfo::latency(), MasterTime::setTimeFromMaster(), MasterTime::setTimeToMaster(), LinkInfo::slownessFromPeer(), LinkInfo::slownessToPeer(), MasterTime::timeFromMaster(), and MasterTime::timeToMaster().

Referenced by PeerTracker::setLink().

{
  if(_link.isLinked()) {
    if(_peerMasterTime.timeToMaster()<1e99) {
      _masterTime.setTimeToMaster(_peerMasterTime.timeToMaster()+_link.latency()+128*_link.slownessToPeer());
    }
    if(_peerMasterTime.timeFromMaster()<1e99) {
      _masterTime.setTimeFromMaster(_peerMasterTime.timeFromMaster()+_link.latency()+128*_link.slownessFromPeer());
    }
  } else {
    _masterTime.setTimeToMaster(1e99);
    _masterTime.setTimeFromMaster(1e99);
  }
}

void PeerInfo::connect	(	const Address &	peer,
		uint16_t	port
	)

References LinkTimer::exec(), and GpCoreTools::Timer::start().

{
  if(!_timer) {
    _timer=new LinkTimer(peer, port);
  }
  // Try to connect right now
  if(_timer->exec()) {
    _timer->start(); // retry later
  }
}