#include <TCPConnection.h>

Inheritance diagram for dtn::net::TCPConnection:

Collaboration diagram for dtn::net::TCPConnection:

Public Member Functions
	TCPConnection (TCPConvergenceLayer &tcpsrv, const dtn::core::Node &node, ibrcommon::clientsocket *sock, const size_t timeout=10)

virtual	~TCPConnection ()

virtual void	initialize () throw ()

void	shutdown () throw ()

const dtn::streams::StreamContactHeader &	getHeader () const

const dtn::core::Node &	getNode () const

virtual void	eventShutdown (dtn::streams::StreamConnection::ConnectionShutdownCases csc) throw ()

virtual void	eventTimeout () throw ()

virtual void	eventError () throw ()

virtual void	eventConnectionUp (const dtn::streams::StreamContactHeader &header) throw ()

virtual void	eventConnectionDown () throw ()

virtual void	eventBundleRefused () throw ()

virtual void	eventBundleForwarded () throw ()

virtual void	eventBundleAck (const dtn::data::Length &ack) throw ()

virtual void	addTrafficIn (size_t) throw ()

virtual void	addTrafficOut (size_t) throw ()

dtn::core::Node::Protocol	getDiscoveryProtocol () const

void	queue (const dtn::net::BundleTransfer &job)

bool	match (const dtn::core::Node &n) const

bool	match (const dtn::data::EID &destination) const

bool	match (const dtn::core::NodeEvent &evt) const

Protected Member Functions
void	rejectTransmission ()

void	setup () throw ()

void	connect ()

void	run () throw ()

void	finally () throw ()

void	__cancellation () throw ()

void	clearQueue ()

void	keepalive ()

bool	good () const

void	initiateExtendedHandshake () throw (ibrcommon::Exception)

Detailed Description

Definition at line 48 of file TCPConnection.h.

Constructor & Destructor Documentation

dtn::net::TCPConnection::TCPConnection	(	TCPConvergenceLayer &	tcpsrv,
		const dtn::core::Node &	node,
		ibrcommon::clientsocket *	sock,
		const size_t	timeout = `10`
	)

Constructor for a new TCPConnection object.

Parameters

tcpsrv
stream	TCP stream to talk to the other peer.
name
timeout

Returns

Definition at line 61 of file TCPConnection.cpp.

dtn::net::TCPConnection::~TCPConnection ( )

virtual

Destructor

Returns

Definition at line 68 of file TCPConnection.cpp.

Member Function Documentation

void dtn::net::TCPConnection::__cancellation	(	)
throw	(
	)

protected

Definition at line 358 of file TCPConnection.cpp.

void dtn::net::TCPConnection::addTrafficIn	(	size_t	)
throw	(
	)

virtual

Reports inbound traffic amount

Reimplemented from dtn::streams::StreamConnection::Callback.

Definition at line 323 of file TCPConnection.cpp.

void dtn::net::TCPConnection::addTrafficOut	(	size_t	)
throw	(
	)

virtual

Reports outbound traffic amount

Reimplemented from dtn::streams::StreamConnection::Callback.

Definition at line 328 of file TCPConnection.cpp.

void dtn::net::TCPConnection::clearQueue ( )

protected

Definition at line 763 of file TCPConnection.cpp.

References dtn::streams::StreamContactHeader::_flags, dtn::data::Bitset< E >::getBit(), dtn::net::BundleTransfer::getBundle(), dtn::streams::StreamContactHeader::getEID(), dtn::streams::StreamContactHeader::REQUEST_FRAGMENTATION, and dtn::core::FragmentManager::setOffset().

Referenced by finally().

Here is the call graph for this function:

void dtn::net::TCPConnection::connect ( )

protected

Definition at line 432 of file TCPConnection.cpp.

References dtn::core::Node::add(), dtn::core::Node::clear(), dtn::core::Node::CONN_TCPIP, dtn::streams::StreamConnection::CONNECTION_SHUTDOWN_ERROR, dtn::core::Node::URI::decode(), dtn::core::Node::get(), shutdown(), dtn::core::Node::toString(), and dtn::core::Node::URI::value.

Referenced by run().

Here is the call graph for this function:

void dtn::net::TCPConnection::eventBundleAck	(	const dtn::data::Length &	ack	)
throw	(
	)

virtual

This method is called if a ACK is received.

Implements dtn::streams::StreamConnection::Callback.

Definition at line 318 of file TCPConnection.cpp.

void dtn::net::TCPConnection::eventBundleForwarded	(	)
throw	(
	)

virtual

This method is called if a bundle is refused by the peer.

Implements dtn::streams::StreamConnection::Callback.

Definition at line 295 of file TCPConnection.cpp.

References dtn::net::BundleTransfer::complete().

Here is the call graph for this function:

void dtn::net::TCPConnection::eventBundleRefused	(	)
throw	(
	)

virtual

This method is called if a bundle is refused by the peer.

Implements dtn::streams::StreamConnection::Callback.

Definition at line 272 of file TCPConnection.cpp.

References dtn::net::BundleTransfer::abort(), and dtn::net::TransferAbortedEvent::REASON_REFUSED.

Here is the call graph for this function:

void dtn::net::TCPConnection::eventConnectionDown	(	)
throw	(
	)

virtual

This method is called if a connection went down.

Implements dtn::streams::StreamConnection::Callback.

Definition at line 251 of file TCPConnection.cpp.

References dtn::streams::StreamContactHeader::_localeid, dtn::net::ConnectionEvent::CONNECTION_DOWN, and dtn::net::ConnectionEvent::raise().

Here is the call graph for this function:

void dtn::net::TCPConnection::eventConnectionUp	(	const dtn::streams::StreamContactHeader &	header	)
throw	(
	)

virtual

This method is called if a handshake was successful.

Parameters

header

Implements dtn::streams::StreamConnection::Callback.

Definition at line 193 of file TCPConnection.cpp.

References dtn::net::ConnectionEvent::CONNECTION_UP, dtn::core::BundleCore::getInstance(), dtn::daemon::Configuration::getInstance(), dtn::daemon::Configuration::getNetwork(), dtn::daemon::Configuration::Network::getTCPIdleTimeout(), dtn::core::BundleCore::local, and dtn::net::ConnectionEvent::raise().

Here is the call graph for this function:

void dtn::net::TCPConnection::eventError	(	)
throw	(
	)

virtual

This method is called if a error occured in the stream.

Implements dtn::streams::StreamConnection::Callback.

Definition at line 131 of file TCPConnection.cpp.

void dtn::net::TCPConnection::eventShutdown	(	dtn::streams::StreamConnection::ConnectionShutdownCases	csc	)
throw	(
	)

virtual

callback methods for tcpstream

Implements dtn::streams::StreamConnection::Callback.

Definition at line 114 of file TCPConnection.cpp.

void dtn::net::TCPConnection::eventTimeout	(	)
throw	(
	)

virtual

This method is called if the stream is closed by a TIMEOUT.

Implements dtn::streams::StreamConnection::Callback.

Definition at line 118 of file TCPConnection.cpp.

References dtn::net::ConnectionEvent::CONNECTION_TIMEOUT, and dtn::net::ConnectionEvent::raise().

Here is the call graph for this function:

void dtn::net::TCPConnection::finally	(	)
throw	(
	)

protected

Definition at line 367 of file TCPConnection.cpp.

References clearQueue().

Here is the call graph for this function:

dtn::core::Node::Protocol dtn::net::TCPConnection::getDiscoveryProtocol ( ) const

const dtn::streams::StreamContactHeader & dtn::net::TCPConnection::getHeader ( ) const

Get the header of this connection

Returns

Definition at line 99 of file TCPConnection.cpp.

const dtn::core::Node & dtn::net::TCPConnection::getNode ( ) const

Get the associated Node object

Returns

Definition at line 104 of file TCPConnection.cpp.

Referenced by dtn::net::TCPConvergenceLayer::queue().

bool dtn::net::TCPConnection::good ( ) const

protected

Definition at line 800 of file TCPConnection.cpp.

void dtn::net::TCPConnection::initialize	(	)
throw	(
	)

virtual

This method is called after accept()

Definition at line 333 of file TCPConnection.cpp.

Referenced by dtn::net::TCPConvergenceLayer::componentRun(), dtn::net::TCPConvergenceLayer::open(), and dtn::net::TCPConvergenceLayer::queue().

void dtn::net::TCPConnection::initiateExtendedHandshake	(		)
throw	(	ibrcommon::Exception
	)

protected

Definition at line 135 of file TCPConnection.cpp.

References dtn::streams::StreamContactHeader::_flags, dtn::data::Bitset< E >::getBit(), dtn::streams::StreamContactHeader::getEID(), dtn::data::EID::getHost(), dtn::daemon::Configuration::getInstance(), dtn::daemon::Configuration::getSecurity(), dtn::data::EID::getString(), dtn::streams::StreamContactHeader::REQUEST_TLS, dtn::daemon::Configuration::Security::TLSRequired(), and dtn::security::SecurityCertificateManager::validateSubject().

Here is the call graph for this function:

void dtn::net::TCPConnection::keepalive ( )

protected

Definition at line 795 of file TCPConnection.cpp.

bool dtn::net::TCPConnection::match ( const dtn::core::Node & n ) const

Definition at line 809 of file TCPConnection.cpp.

Referenced by match(), dtn::net::TCPConvergenceLayer::open(), and dtn::net::TCPConvergenceLayer::queue().

bool dtn::net::TCPConnection::match ( const dtn::data::EID & destination ) const

Definition at line 814 of file TCPConnection.cpp.

References dtn::core::Node::getEID(), and dtn::data::EID::sameHost().

Here is the call graph for this function:

bool dtn::net::TCPConnection::match ( const dtn::core::NodeEvent & evt ) const

Definition at line 819 of file TCPConnection.cpp.

References dtn::core::NodeEvent::getNode(), and match().

Here is the call graph for this function:

void dtn::net::TCPConnection::queue ( const dtn::net::BundleTransfer & job )

queue a bundle for this connection

Parameters

bundle

Definition at line 94 of file TCPConnection.cpp.

Referenced by dtn::net::TCPConvergenceLayer::queue().

void dtn::net::TCPConnection::rejectTransmission ( )

protected

Definition at line 109 of file TCPConnection.cpp.

Referenced by run().

void dtn::net::TCPConnection::run	(	void	)
throw	(
	)

protected

Definition at line 503 of file TCPConnection.cpp.

References dtn::streams::StreamContactHeader::_flags, dtn::streams::StreamContactHeader::_localeid, connect(), dtn::streams::StreamConnection::CONNECTION_SHUTDOWN_ERROR, dtn::core::BundleCore::filter(), dtn::data::Bitset< E >::getBit(), dtn::net::TCPConvergenceLayer::getDiscoveryProtocol(), dtn::core::BundleCore::getInstance(), dtn::core::BundleFilter::INPUT, dtn::core::BundleCore::local, dtn::net::BundleReceivedEvent::raise(), rejectTransmission(), dtn::streams::StreamContactHeader::REQUEST_FRAGMENTATION, dtn::core::FilterContext::setBundle(), dtn::data::DefaultDeserializer::setFragmentationSupport(), dtn::core::FilterContext::setPeer(), dtn::core::FilterContext::setProtocol(), and shutdown().

Here is the call graph for this function:

void dtn::net::TCPConnection::setup	(	)
throw	(
	)

protected

Definition at line 390 of file TCPConnection.cpp.

References dtn::daemon::Configuration::getInstance(), dtn::streams::StreamContactHeader::REQUEST_ACKNOWLEDGMENTS, dtn::streams::StreamContactHeader::REQUEST_FRAGMENTATION, and dtn::streams::StreamContactHeader::REQUEST_NEGATIVE_ACKNOWLEDGMENTS.

Here is the call graph for this function:

void dtn::net::TCPConnection::shutdown	(	)
throw	(
	)

shutdown the whole tcp connection

Definition at line 343 of file TCPConnection.cpp.

References dtn::streams::StreamConnection::CONNECTION_SHUTDOWN_ERROR.

Referenced by connect(), and run().

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

daemon/src/net/TCPConnection.h
daemon/src/net/TCPConnection.cpp

Public Member Functions

Protected Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation