Sirikata::SpaceNodeConnection Struct Reference

#include <SpaceNodeConnection.hpp>

Inheritance diagram for Sirikata::SpaceNodeConnection:

Collaboration diagram for Sirikata::SpaceNodeConnection:

List of all members.

Public Types
typedef OHDPSST::Stream	OHSSTStream
typedef OHSSTStream::Ptr	OHSSTStreamPtr
typedef OHDPSST::Endpoint	OHSSTEndpoint
typedef OHDPSST::BaseDatagramLayer	OHSSTBaseDatagramLayer
typedef OHDPSST::BaseDatagramLayer::Ptr	OHSSTBaseDatagramLayerPtr
typedef std::tr1::function < void(SpaceNodeConnection *)	GotSpaceConnectionCallback )
typedef std::tr1::function < void(SpaceNodeConnection *)	ReceiveCallback )
typedef std::tr1::function < void(const Network::Stream::ConnectionStatus, const std::string &)>	ConnectionEventCallback
Public Member Functions
	SpaceNodeConnection (ObjectHostContext *ctx, Network::IOStrand *ioStrand, TimeProfiler::Stage *handle_read_stage, OptionSet *streamOptions, const SpaceID &spaceid, ServerID sid, OHDP::Service *ohdp_service, ConnectionEventCallback ccb, ReceiveCallback rcb)
	~SpaceNodeConnection ()
bool	push (const ObjectMessage &msg)
ObjectMessage *	pull ()
bool	empty ()
void	shutdown ()
const SpaceID &	space () const
const ServerID &	server () const
OHSSTStreamPtr	stream () const
void	connect (const Network::Address &addr)
void	failConnection ()
bool	connecting () const
void	addCallback (GotSpaceConnectionCallback cb)
void	invokeAndClearCallbacks (bool connected)
Private Types
typedef std::vector < GotSpaceConnectionCallback >	ConnectionCallbackList
Private Member Functions
void	handleConnectionEvent (const Network::Stream::ConnectionStatus status, const std::string &reason)
void	setupConnectionStream (const Network::Stream::ConnectionStatus status, const std::string &reason, uint8 retries)
void	handleStreamConnected (const Network::Stream::ConnectionStatus status, const std::string &reason, int err, OHSSTStreamPtr strm, uint8 retries)
void	handleRead (const Sirikata::Network::Chunk &chunk, const Sirikata::Network::Stream::PauseReceiveCallback &pause)
Private Attributes
ObjectHostContext *	mContext
TimeProfiler::Stage *	mHandleReadStage
SpaceID	mSpace
ServerID	mServer
OHDP::Service *	mOHDPService
Network::Stream *	socket
Network::Address	mAddr
ConnectionCallbackList	mConnectCallbacks
bool	mConnecting
QueueRouterElement< ObjectMessage >	receive_queue
ConnectionEventCallback	mConnectCB
ReceiveCallback	mReceiveCB
OHSSTStreamPtr	mOHSSTStream

---

Member Typedef Documentation

typedef std::vector<GotSpaceConnectionCallback> Sirikata::SpaceNodeConnection::ConnectionCallbackList [private]

typedef std::tr1::function<void(const Network::Stream::ConnectionStatus, const std::string&)> Sirikata::SpaceNodeConnection::ConnectionEventCallback

typedef std::tr1::function<void(SpaceNodeConnection*) Sirikata::SpaceNodeConnection::GotSpaceConnectionCallback)

typedef OHDPSST::BaseDatagramLayer Sirikata::SpaceNodeConnection::OHSSTBaseDatagramLayer

typedef OHDPSST::BaseDatagramLayer::Ptr Sirikata::SpaceNodeConnection::OHSSTBaseDatagramLayerPtr

typedef OHDPSST::Endpoint Sirikata::SpaceNodeConnection::OHSSTEndpoint

typedef OHDPSST::Stream Sirikata::SpaceNodeConnection::OHSSTStream

typedef OHSSTStream::Ptr Sirikata::SpaceNodeConnection::OHSSTStreamPtr

typedef std::tr1::function<void(SpaceNodeConnection*) Sirikata::SpaceNodeConnection::ReceiveCallback)

---

Constructor & Destructor Documentation

Sirikata::SpaceNodeConnection::SpaceNodeConnection	(	ObjectHostContext *	ctx,
		Network::IOStrand *	ioStrand,
		TimeProfiler::Stage *	handle_read_stage,
		OptionSet *	streamOptions,
		const SpaceID &	spaceid,
		ServerID	sid,
		OHDP::Service *	ohdp_service,
		ConnectionEventCallback	ccb,
		ReceiveCallback	rcb
	)

Sirikata::SpaceNodeConnection::~SpaceNodeConnection

(

)

References Sirikata::Liveness::letDie(), and socket.

---

Member Function Documentation

void Sirikata::SpaceNodeConnection::addCallback

(

GotSpaceConnectionCallback

cb

)

[inline]

Referenced by Sirikata::SessionManager::getAnySpaceConnection(), and Sirikata::SessionManager::registerSpaceNodeConnection().

void Sirikata::SpaceNodeConnection::connect

(

const Network::Address &

addr

)

References Sirikata::Network::Stream::connect(), handleConnectionEvent(), handleRead(), Sirikata::Network::Stream::ignoreReadySendCallback(), Sirikata::Network::Stream::ignoreSubstreamCallback(), mAddr, Sirikata::Context::mainStrand, mConnecting, mContext, socket, and Sirikata::Network::IOStrand::wrap().

bool Sirikata::SpaceNodeConnection::connecting

(

)

const [inline]

Referenced by Sirikata::SessionManager::getAnySpaceConnection().

bool Sirikata::SpaceNodeConnection::empty

(

)

References Sirikata::QueueRouterElement< PacketType >::empty(), and receive_queue.

Referenced by Sirikata::SessionManager::handleServerMessages().

void Sirikata::SpaceNodeConnection::failConnection

(

)

References invokeAndClearCallbacks(), and mConnecting.

void Sirikata::SpaceNodeConnection::handleConnectionEvent	(	const Network::Stream::ConnectionStatus	status,
		const std::string &	reason
	)		[private]

References Sirikata::Network::Stream::Connected, invokeAndClearCallbacks(), mConnectCB, mConnecting, and setupConnectionStream().

Referenced by connect().

void Sirikata::SpaceNodeConnection::handleRead	(	const Sirikata::Network::Chunk &	chunk,
		const Sirikata::Network::Stream::PauseReceiveCallback &	pause
	)		[private]

Referenced by connect().

void Sirikata::SpaceNodeConnection::handleStreamConnected	(	const Network::Stream::ConnectionStatus	status,
		const std::string &	reason,
		int	err,
		OHSSTStreamPtr	strm,
		uint8	retries
	)		[private]

References Sirikata::Network::Stream::ConnectionFailed, Sirikata::Logging::detailed, Sirikata::Logging::error, invokeAndClearCallbacks(), mConnectCB, mConnecting, mOHSSTStream, node, setupConnectionStream(), SILOG, space(), and SST_IMPL_SUCCESS.

Referenced by setupConnectionStream().

void Sirikata::SpaceNodeConnection::invokeAndClearCallbacks

(

bool

connected

)

References mConnectCallbacks.

Referenced by failConnection(), handleConnectionEvent(), and handleStreamConnected().

ObjectMessage * Sirikata::SpaceNodeConnection::pull

(

)

References Sirikata::QueueRouterElement< PacketType >::pull(), and receive_queue.

Referenced by Sirikata::SessionManager::handleServerMessages().

bool Sirikata::SpaceNodeConnection::push

(

const ObjectMessage &

msg

)

References Sirikata::Trace::OH_DROPPED_AT_SEND, Sirikata::Trace::OH_HIT_NETWORK, Sirikata::Network::ReliableOrdered, Sirikata::Network::Stream::send(), Sirikata::ObjectMessage::serialize(), socket, TIMESTAMP_END, TIMESTAMP_START, and TRACE_DROP.

Referenced by Sirikata::SessionManager::send().

const ServerID& Sirikata::SpaceNodeConnection::server

(

)

const [inline]

Referenced by Sirikata::SessionManager::handleServerMessages(), and Sirikata::SessionManager::openConnectionStartSession().

void Sirikata::SpaceNodeConnection::setupConnectionStream	(	const Network::Stream::ConnectionStatus	status,
		const std::string &	reason,
		uint8	retries
	)		[private]

References Sirikata::SST::ConnectionManager< EndPointType >::connectStream(), Sirikata::SST::ConnectionManager< EndPointType >::createDatagramLayer(), handleStreamConnected(), mContext, mOHDPService, mServer, mSpace, OBJECT_SPACE_PORT, Sirikata::ObjectHostContext::ohSSTConnMgr(), and Sirikata::OHDP::NodeID::self().

Referenced by handleConnectionEvent(), and handleStreamConnected().

void Sirikata::SpaceNodeConnection::shutdown

(

)

References Sirikata::Network::Stream::close(), and socket.

Referenced by Sirikata::SessionManager::stop().

const SpaceID& Sirikata::SpaceNodeConnection::space

(

)

const [inline]

Referenced by handleStreamConnected().

OHSSTStreamPtr Sirikata::SpaceNodeConnection::stream

(

)

const [inline]

Referenced by Sirikata::SessionManager::handleSpaceSession().

---

Member Data Documentation

Network::Address Sirikata::SpaceNodeConnection::mAddr [private]

Referenced by connect().

ConnectionCallbackList Sirikata::SpaceNodeConnection::mConnectCallbacks [private]

Referenced by invokeAndClearCallbacks().

ConnectionEventCallback Sirikata::SpaceNodeConnection::mConnectCB [private]

Referenced by handleConnectionEvent(), and handleStreamConnected().

bool Sirikata::SpaceNodeConnection::mConnecting [private]

Referenced by connect(), failConnection(), handleConnectionEvent(), and handleStreamConnected().

ObjectHostContext* Sirikata::SpaceNodeConnection::mContext [private]

Referenced by connect(), and setupConnectionStream().

TimeProfiler::Stage* Sirikata::SpaceNodeConnection::mHandleReadStage [private]

OHDP::Service* Sirikata::SpaceNodeConnection::mOHDPService [private]

Referenced by setupConnectionStream().

OHSSTStreamPtr Sirikata::SpaceNodeConnection::mOHSSTStream [private]

Referenced by handleStreamConnected().

ReceiveCallback Sirikata::SpaceNodeConnection::mReceiveCB [private]

ServerID Sirikata::SpaceNodeConnection::mServer [private]

Referenced by setupConnectionStream().

SpaceID Sirikata::SpaceNodeConnection::mSpace [private]

Referenced by setupConnectionStream().

QueueRouterElement<ObjectMessage> Sirikata::SpaceNodeConnection::receive_queue [private]

Referenced by empty(), and pull().

Network::Stream* Sirikata::SpaceNodeConnection::socket [private]

Referenced by connect(), push(), shutdown(), and ~SpaceNodeConnection().

---

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

• liboh/include/sirikata/oh/SpaceNodeConnection.hpp
• liboh/src/SpaceNodeConnection.cpp