Sirikata::TCPSpaceNetwork Class Reference

#include <TCPSpaceNetwork.hpp>

Inheritance diagram for Sirikata::TCPSpaceNetwork:

Collaboration diagram for Sirikata::TCPSpaceNetwork:

List of all members.

Classes
struct	RemoteData
struct	RemoteSession
	RemoteSession is the data structure that ensures the appearance of a continuous connection to a remote server. More...
struct	RemoteStream
class	TCPReceiveStream
class	TCPSendStream
Public Member Functions
	TCPSpaceNetwork (SpaceContext *ctx)
virtual	~TCPSpaceNetwork ()
virtual void	setSendListener (SendListener *sl)
virtual void	listen (const ServerID &addr, ReceiveListener *receive_listener)
virtual SendStream *	connect (Network::IOStrand *strand, const ServerID &addr)
Private Types
typedef std::tr1::shared_ptr < RemoteStream >	RemoteStreamPtr
typedef std::tr1::weak_ptr < RemoteStream >	RemoteStreamWPtr
typedef std::tr1::unordered_map < ServerID, RemoteStreamPtr >	RemoteStreamMap
typedef std::tr1::unordered_map < Address4, RemoteStreamPtr, Address4::Hasher >	RemoteNetStreamMap
typedef std::tr1::shared_ptr < RemoteSession >	RemoteSessionPtr
typedef std::tr1::weak_ptr < RemoteSession >	RemoteSessionWPtr
typedef std::tr1::unordered_map < ServerID, TCPSendStream * >	SendStreamMap
typedef std::tr1::unordered_map < ServerID, TCPReceiveStream * >	ReceiveStreamMap
typedef std::tr1::unordered_map < ServerID, RemoteData * >	RemoteDataMap
typedef std::set < Sirikata::Network::IOTimerPtr >	TimerSet
typedef std::tr1::shared_ptr < TCPReceiveStream * >	IndirectTCPReceiveStream
Private Member Functions
RemoteData *	getRemoteData (ServerID sid)
RemoteSessionPtr	getRemoteSession (ServerID sid)
TCPSendStream *	getNewSendStream (ServerID sid)
TCPReceiveStream *	getNewReceiveStream (ServerID sid)
RemoteStreamPtr	getNewOutgoingStream (ServerID sid, Address4 remote_net, RemoteStream::Initiator init)
RemoteStreamPtr	getNewIncomingStream (Address4 remote_net, RemoteStream::Initiator init, Sirikata::Network::Stream *strm)
void	finishListen (ServerID resolved_sid, Address4 addr, ReceiveListener *receive_listener)
TCPSendStream *	openConnection (Network::IOStrand *strand, const ServerID &dest)
void	finishOpenConnection (const ServerID &dest, ServerID resolved_dest, Address4 addr)
TCPReceiveStream *	handleConnectedStream (RemoteStreamPtr source_stream)
void	handleDisconnectedStream (const RemoteStreamPtr &wstream)
void	sendServerIntro (const RemoteStreamPtr &out_stream)
void	handleClosingStreamTimeout (Sirikata::Network::IOTimerPtr timer, RemoteStreamPtr &wstream)
void	newStreamCallback (Sirikata::Network::Stream *strm, Sirikata::Network::Stream::SetCallbacks &cb)
void	connectionCallback (RemoteStreamWPtr wstream, const Sirikata::Network::Stream::ConnectionStatus status, const std::string &reason)
void	bytesReceivedCallback (RemoteStreamWPtr wstream, IndirectTCPReceiveStream ind_recv_strm, Chunk &data, const Sirikata::Network::Stream::PauseReceiveCallback &pause)
void	readySendCallback (RemoteStreamWPtr wstream)
Private Attributes
RemoteDataMap	mRemoteData
boost::recursive_mutex	mRemoteDataMutex
Sirikata::PluginManager	mPluginManager
String	mStreamPlugin
Sirikata::OptionSet *	mListenOptions
Sirikata::OptionSet *	mSendOptions
Network::IOStrand *	mIOStrand
Network::IOWork *	mIOWork
RemoteStreamMap	mClosingStreams
TimerSet	mClosingStreamTimers
Address4	mListenAddress
Sirikata::Network::StreamListener *	mListener
SendListener *	mSendListener
ReceiveListener *	mReceiveListener
RemoteNetStreamMap	mPendingStreams

---

Member Typedef Documentation

typedef std::tr1::shared_ptr<TCPReceiveStream*> Sirikata::TCPSpaceNetwork::IndirectTCPReceiveStream [private]

typedef std::tr1::unordered_map<ServerID, TCPReceiveStream*> Sirikata::TCPSpaceNetwork::ReceiveStreamMap [private]

typedef std::tr1::unordered_map<ServerID, RemoteData*> Sirikata::TCPSpaceNetwork::RemoteDataMap [private]

typedef std::tr1::unordered_map<Address4, RemoteStreamPtr, Address4::Hasher> Sirikata::TCPSpaceNetwork::RemoteNetStreamMap [private]

typedef std::tr1::shared_ptr<RemoteSession> Sirikata::TCPSpaceNetwork::RemoteSessionPtr [private]

typedef std::tr1::weak_ptr<RemoteSession> Sirikata::TCPSpaceNetwork::RemoteSessionWPtr [private]

typedef std::tr1::unordered_map<ServerID, RemoteStreamPtr> Sirikata::TCPSpaceNetwork::RemoteStreamMap [private]

typedef std::tr1::shared_ptr<RemoteStream> Sirikata::TCPSpaceNetwork::RemoteStreamPtr [private]

typedef std::tr1::weak_ptr<RemoteStream> Sirikata::TCPSpaceNetwork::RemoteStreamWPtr [private]

typedef std::tr1::unordered_map<ServerID, TCPSendStream*> Sirikata::TCPSpaceNetwork::SendStreamMap [private]

typedef std::set<Sirikata::Network::IOTimerPtr> Sirikata::TCPSpaceNetwork::TimerSet [private]

---

Constructor & Destructor Documentation

Sirikata::TCPSpaceNetwork::TCPSpaceNetwork

(

SpaceContext *

ctx

)

References Sirikata::Network::IOService::createStrand(), Sirikata::FactoryWithOptionsImpl< T, Ftype >::getConstructor(), Sirikata::FactoryWithOptionsImpl< T, Ftype >::getOptionParser(), Sirikata::GetOptionValue< String >(), Sirikata::Network::StreamFactory::getSingleton(), Sirikata::Network::StreamListenerFactory::getSingleton(), Sirikata::Context::ioService, Sirikata::SpaceNetwork::mContext, mIOStrand, mIOWork, mListener, mListenOptions, mSendOptions, and mStreamPlugin.

Sirikata::TCPSpaceNetwork::~TCPSpaceNetwork

(

)

[virtual]

References mClosingStreamTimers, mIOStrand, mIOWork, mListener, and mRemoteData.

---

Member Function Documentation

void Sirikata::TCPSpaceNetwork::bytesReceivedCallback	(	RemoteStreamWPtr	wstream,
		IndirectTCPReceiveStream	ind_recv_strm,
		Chunk &	data,
		const Sirikata::Network::Stream::PauseReceiveCallback &	pause
	)		[private]

References Sirikata::Logging::error, handleConnectedStream(), Sirikata::Logging::info, Sirikata::Logging::insane, LOG_INVALID_MESSAGE, mPendingStreams, mReceiveListener, Sirikata::SpaceNetwork::ReceiveListener::networkReceivedData(), Sirikata::parsePBJMessage(), and TCPNET_LOG.

Referenced by finishOpenConnection(), and newStreamCallback().

SpaceNetwork::SendStream * Sirikata::TCPSpaceNetwork::connect	(	Network::IOStrand *	strand,
		const ServerID &	addr
	)		[virtual]

Implements Sirikata::SpaceNetwork.

References openConnection().

void Sirikata::TCPSpaceNetwork::connectionCallback	(	RemoteStreamWPtr	wstream,
		const Sirikata::Network::Stream::ConnectionStatus	status,
		const std::string &	reason
	)		[private]

References Sirikata::Network::Stream::Connected, Sirikata::Network::Stream::ConnectionFailed, Sirikata::Network::Stream::Disconnected, Sirikata::Logging::error, handleConnectedStream(), handleDisconnectedStream(), Sirikata::Logging::info, sendServerIntro(), TCPNET_LOG, and Sirikata::Logging::warning.

Referenced by finishOpenConnection(), and newStreamCallback().

void Sirikata::TCPSpaceNetwork::finishListen	(	ServerID	resolved_sid,
		Address4	addr,
		ReceiveListener *	receive_listener
	)		[private]

References Sirikata::convertAddress4ToSirikata(), Sirikata::Network::Address::getHostName(), Sirikata::Network::Address::getService(), Sirikata::Network::StreamListener::listen(), mListenAddress, mListener, newStreamCallback(), and Sirikata::Address4::Null.

Referenced by listen().

void Sirikata::TCPSpaceNetwork::finishOpenConnection	(	const ServerID &	dest,
		ServerID	resolved_dest,
		Address4	addr
	)		[private]

References bytesReceivedCallback(), connectionCallback(), Sirikata::convertAddress4ToSirikata(), Sirikata::Logging::error, getNewOutgoingStream(), getNewReceiveStream(), Sirikata::Network::Stream::ignoreSubstreamCallback(), Sirikata::Logging::info, Sirikata::Address4::Null, readySendCallback(), TCPNET_LOG, and Sirikata::TCPSpaceNetwork::RemoteStream::Us.

Referenced by openConnection().

TCPSpaceNetwork::RemoteStreamPtr Sirikata::TCPSpaceNetwork::getNewIncomingStream	(	Address4	remote_net,
		RemoteStream::Initiator	init,
		Sirikata::Network::Stream *	strm
	)		[private]

Referenced by newStreamCallback().

TCPSpaceNetwork::RemoteStreamPtr Sirikata::TCPSpaceNetwork::getNewOutgoingStream	(	ServerID	sid,
		Address4	remote_net,
		RemoteStream::Initiator	init
	)		[private]

References Sirikata::FactoryWithOptionsImpl< T, Ftype >::getConstructor(), getRemoteSession(), Sirikata::Network::StreamFactory::getSingleton(), mIOStrand, mRemoteDataMutex, mSendOptions, and mStreamPlugin.

Referenced by finishOpenConnection().

TCPSpaceNetwork::TCPReceiveStream * Sirikata::TCPSpaceNetwork::getNewReceiveStream

(

ServerID

sid

)

[private]

References getRemoteData(), mIOStrand, mReceiveListener, mRemoteDataMutex, Sirikata::SpaceNetwork::ReceiveListener::networkReceivedConnection(), Sirikata::Provider< SpaceNetworkConnectionListener * >::notify(), Sirikata::TCPSpaceNetwork::RemoteData::receive, and Sirikata::TCPSpaceNetwork::RemoteData::session.

Referenced by finishOpenConnection(), and handleConnectedStream().

TCPSpaceNetwork::TCPSendStream * Sirikata::TCPSpaceNetwork::getNewSendStream

(

ServerID

sid

)

[private]

References getRemoteData(), mRemoteDataMutex, mSendListener, Sirikata::SpaceNetwork::SendListener::networkReadyToSend(), Sirikata::Provider< SpaceNetworkConnectionListener * >::notify(), Sirikata::TCPSpaceNetwork::RemoteData::send, and Sirikata::TCPSpaceNetwork::RemoteData::session.

Referenced by handleConnectedStream(), and openConnection().

TCPSpaceNetwork::RemoteData * Sirikata::TCPSpaceNetwork::getRemoteData

(

ServerID

sid

)

[private]

References mRemoteData, and mRemoteDataMutex.

Referenced by getNewReceiveStream(), getNewSendStream(), and getRemoteSession().

TCPSpaceNetwork::RemoteSessionPtr Sirikata::TCPSpaceNetwork::getRemoteSession

(

ServerID

sid

)

[private]

References getRemoteData(), mRemoteDataMutex, and Sirikata::TCPSpaceNetwork::RemoteData::session.

Referenced by getNewOutgoingStream(), handleConnectedStream(), and handleDisconnectedStream().

void Sirikata::TCPSpaceNetwork::handleClosingStreamTimeout	(	Sirikata::Network::IOTimerPtr	timer,
		RemoteStreamPtr &	wstream
	)		[private]

References Sirikata::Logging::error, Sirikata::Logging::info, mClosingStreamTimers, and TCPNET_LOG.

Referenced by handleConnectedStream().

TCPSpaceNetwork::TCPReceiveStream * Sirikata::TCPSpaceNetwork::handleConnectedStream

(

RemoteStreamPtr

source_stream

)

[private]

References Sirikata::Network::IOTimer::create(), Sirikata::Logging::fatal, getNewReceiveStream(), getNewSendStream(), getRemoteSession(), handleClosingStreamTimeout(), Sirikata::SpaceContext::id(), Sirikata::Logging::info, Sirikata::TCPSpaceNetwork::TCPReceiveStream::logical_endpoint, mClosingStreamTimers, Sirikata::SpaceNetwork::mContext, mIOStrand, mSendListener, Sirikata::SpaceNetwork::SendListener::networkReadyToSend(), Sirikata::Provider< SpaceNetworkConnectionListener * >::notify(), Sirikata::SpaceNetworkConnectionListener::onSpaceNetworkConnected(), TCPNET_LOG, Sirikata::TCPSpaceNetwork::RemoteStream::Them, and Sirikata::TCPSpaceNetwork::RemoteStream::Us.

Referenced by bytesReceivedCallback(), and connectionCallback().

void Sirikata::TCPSpaceNetwork::handleDisconnectedStream

(

const RemoteStreamPtr &

wstream

)

[private]

References getRemoteSession(), Sirikata::Provider< SpaceNetworkConnectionListener * >::notify(), and Sirikata::SpaceNetworkConnectionListener::onSpaceNetworkDisconnected().

Referenced by connectionCallback().

void Sirikata::TCPSpaceNetwork::listen	(	const ServerID &	addr,
		ReceiveListener *	receive_listener
	)		[virtual]

References finishListen(), Sirikata::Logging::info, Sirikata::ServerIDMap::lookupInternal(), Sirikata::Context::mainStrand, Sirikata::SpaceNetwork::mContext, mReceiveListener, Sirikata::SpaceNetwork::mServerIDMap, TCPNET_LOG, and Sirikata::Network::IOStrand::wrap().

void Sirikata::TCPSpaceNetwork::newStreamCallback	(	Sirikata::Network::Stream *	strm,
		Sirikata::Network::Stream::SetCallbacks &	cb
	)		[private]

References bytesReceivedCallback(), connectionCallback(), getNewIncomingStream(), Sirikata::Network::Stream::getRemoteEndpoint(), Sirikata::Logging::info, mPendingStreams, readySendCallback(), TCPNET_LOG, and Sirikata::TCPSpaceNetwork::RemoteStream::Them.

Referenced by finishListen().

TCPSpaceNetwork::TCPSendStream * Sirikata::TCPSpaceNetwork::openConnection	(	Network::IOStrand *	strand,
		const ServerID &	dest
	)		[private]

References finishOpenConnection(), getNewSendStream(), Sirikata::ServerIDMap::lookupInternal(), Sirikata::SpaceNetwork::mServerIDMap, and Sirikata::Network::IOStrand::wrap().

Referenced by connect().

void Sirikata::TCPSpaceNetwork::readySendCallback

(

RemoteStreamWPtr

wstream

)

[private]

References mSendListener, and Sirikata::SpaceNetwork::SendListener::networkReadyToSend().

Referenced by finishOpenConnection(), and newStreamCallback().

void Sirikata::TCPSpaceNetwork::sendServerIntro

(

const RemoteStreamPtr &

out_stream

)

[private]

References Sirikata::SpaceContext::id(), Sirikata::SpaceNetwork::mContext, Sirikata::Network::ReliableOrdered, and Sirikata::serializePBJMessage().

Referenced by connectionCallback().

void Sirikata::TCPSpaceNetwork::setSendListener

(

SendListener *

sl

)

[virtual]

References mSendListener.

---

Member Data Documentation

RemoteStreamMap Sirikata::TCPSpaceNetwork::mClosingStreams [private]

TimerSet Sirikata::TCPSpaceNetwork::mClosingStreamTimers [private]

Referenced by handleClosingStreamTimeout(), handleConnectedStream(), and ~TCPSpaceNetwork().

Network::IOStrand* Sirikata::TCPSpaceNetwork::mIOStrand [private]

Referenced by getNewOutgoingStream(), getNewReceiveStream(), handleConnectedStream(), TCPSpaceNetwork(), and ~TCPSpaceNetwork().

Network::IOWork* Sirikata::TCPSpaceNetwork::mIOWork [private]

Referenced by TCPSpaceNetwork(), and ~TCPSpaceNetwork().

Address4 Sirikata::TCPSpaceNetwork::mListenAddress [private]

Referenced by finishListen().

Sirikata::Network::StreamListener* Sirikata::TCPSpaceNetwork::mListener [private]

Referenced by finishListen(), TCPSpaceNetwork(), and ~TCPSpaceNetwork().

Sirikata::OptionSet* Sirikata::TCPSpaceNetwork::mListenOptions [private]

Referenced by TCPSpaceNetwork().

RemoteNetStreamMap Sirikata::TCPSpaceNetwork::mPendingStreams [private]

Referenced by bytesReceivedCallback(), and newStreamCallback().

Sirikata::PluginManager Sirikata::TCPSpaceNetwork::mPluginManager [private]

ReceiveListener* Sirikata::TCPSpaceNetwork::mReceiveListener [private]

Referenced by bytesReceivedCallback(), getNewReceiveStream(), and listen().

RemoteDataMap Sirikata::TCPSpaceNetwork::mRemoteData [private]

Referenced by getRemoteData(), and ~TCPSpaceNetwork().

boost::recursive_mutex Sirikata::TCPSpaceNetwork::mRemoteDataMutex [private]

Referenced by getNewOutgoingStream(), getNewReceiveStream(), getNewSendStream(), getRemoteData(), and getRemoteSession().

SendListener* Sirikata::TCPSpaceNetwork::mSendListener [private]

Referenced by getNewSendStream(), handleConnectedStream(), readySendCallback(), and setSendListener().

Sirikata::OptionSet* Sirikata::TCPSpaceNetwork::mSendOptions [private]

Referenced by getNewOutgoingStream(), and TCPSpaceNetwork().

String Sirikata::TCPSpaceNetwork::mStreamPlugin [private]

Referenced by getNewOutgoingStream(), and TCPSpaceNetwork().

---

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

• space/src/TCPSpaceNetwork.hpp
• space/src/TCPSpaceNetwork.cpp