Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID > Class Template Reference

#include <SST.hpp>

Collaboration diagram for Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >:

List of all members.

Public Types
typedef std::tr1::shared_ptr < BaseDatagramLayer < EndPointType > >	Ptr
typedef Ptr	BaseDatagramLayerPtr
typedef std::tr1::function < void(void *, int)	DataCallback )
Public Member Functions
void	listenOn (EndPoint< EndPointType > &listeningEndPoint, DataCallback cb)
void	listenOn (const EndPoint< EndPointType > &listeningEndPoint)
void	unlisten (EndPoint< EndPointType > &ep)
void	send (EndPoint< EndPointType > *src, EndPoint< EndPointType > *dest, void *data, int len)
const Context *	context ()
uint32	getUnusedPort (const EndPointType &ep)
void	invalidate ()
Static Public Member Functions
static BaseDatagramLayerPtr	getDatagramLayer (ConnectionVariables< EndPointType > *sstConnVars, EndPointType endPoint)
static BaseDatagramLayerPtr	createDatagramLayer (ConnectionVariables< EndPointType > *sstConnVars, EndPointType endPoint, const Context *ctx, OHDP::Service *ohdp)
static void	stopListening (ConnectionVariables< EndPointType > *sstConnVars, EndPoint< EndPointType > &listeningEndPoint)
Private Types
typedef OHDP::SpaceNodeID	EndPointType
typedef std::map< EndPoint < EndPointType >, OHDP::Port * >	PortMap
Private Member Functions
	BaseDatagramLayer (ConnectionVariables< EndPointType > *sstConnVars, const Context *ctx, OHDP::Service *ohdpservice, const EndPointType &ep)
OHDP::Port *	allocatePort (const EndPoint< EndPointType > &ep)
OHDP::Port *	getPort (const EndPoint< EndPointType > &ep)
OHDP::Port *	getOrAllocatePort (const EndPoint< EndPointType > &ep)
void	receiveMessage (const OHDP::Endpoint &src, const OHDP::Endpoint &dst, MemoryReference payload)
void	receiveMessageToCallback (const OHDP::Endpoint &src, const OHDP::Endpoint &dst, MemoryReference payload, DataCallback cb)
Private Attributes
const Context *	mContext
OHDP::Service *	mOHDP
PortMap	mAllocatedPorts
boost::mutex	mMutex
ConnectionVariables < EndPointType > *	mSSTConnVars
EndPointType	mEndpoint

template<>
class Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >

---

Member Typedef Documentation

typedef Ptr Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::BaseDatagramLayerPtr

typedef std::tr1::function<void(void*, int) Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::DataCallback)

typedef OHDP::SpaceNodeID Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::EndPointType [private]

typedef std::map<EndPoint<EndPointType>, OHDP::Port*> Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::PortMap [private]

typedef std::tr1::shared_ptr<BaseDatagramLayer<EndPointType> > Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::Ptr

---

Constructor & Destructor Documentation

Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::BaseDatagramLayer	(	ConnectionVariables< EndPointType > *	sstConnVars,
		const Context *	ctx,
		OHDP::Service *	ohdpservice,
		const EndPointType &	ep
	)		[inline, private]

---

Member Function Documentation

OHDP::Port* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::allocatePort

(

const EndPoint< EndPointType > &

ep

)

[inline, private]

References Sirikata::SST::EndPoint< EndObjectType >::endPoint, Sirikata::OHDP::SpaceNodeID::node(), Sirikata::SST::EndPoint< EndObjectType >::port, and Sirikata::OHDP::SpaceNodeID::space().

const Context* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::context

(

)

[inline]

static BaseDatagramLayerPtr Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::createDatagramLayer	(	ConnectionVariables< EndPointType > *	sstConnVars,
		EndPointType	endPoint,
		const Context *	ctx,
		OHDP::Service *	ohdp
	)		[inline, static]

References Sirikata::SST::ConnectionVariables< EndPointType >::addDatagramLayer().

static BaseDatagramLayerPtr Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::getDatagramLayer	(	ConnectionVariables< EndPointType > *	sstConnVars,
		EndPointType	endPoint
	)		[inline, static]

References Sirikata::SST::ConnectionVariables< EndPointType >::getDatagramLayer().

OHDP::Port* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::getOrAllocatePort

(

const EndPoint< EndPointType > &

ep

)

[inline, private]

OHDP::Port* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::getPort

(

const EndPoint< EndPointType > &

ep

)

[inline, private]

uint32 Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::getUnusedPort

(

const EndPointType &

ep

)

[inline]

References Sirikata::OHDP::SpaceNodeID::node(), and Sirikata::OHDP::SpaceNodeID::space().

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::invalidate

(

)

[inline]

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::listenOn	(	EndPoint< EndPointType > &	listeningEndPoint,
		DataCallback	cb
	)		[inline]

References Sirikata::XDP::Port< EndpointType >::receive().

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::listenOn

(

const EndPoint< EndPointType > &

listeningEndPoint

)

[inline]

References Sirikata::XDP::Port< EndpointType >::receive().

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::receiveMessage	(	const OHDP::Endpoint &	src,
		const OHDP::Endpoint &	dst,
		MemoryReference	payload
	)		[inline, private]

References Sirikata::DataReference< T >::data(), Sirikata::OHDP::Endpoint::node(), Sirikata::XDP::Endpoint< IdentifierType >::port(), Sirikata::DataReference< T >::size(), and Sirikata::XDP::Endpoint< IdentifierType >::space().

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::receiveMessageToCallback	(	const OHDP::Endpoint &	src,
		const OHDP::Endpoint &	dst,
		MemoryReference	payload,
		DataCallback	cb
	)		[inline, private]

References Sirikata::DataReference< T >::data(), and Sirikata::DataReference< T >::size().

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::send	(	EndPoint< EndPointType > *	src,
		EndPoint< EndPointType > *	dest,
		void *	data,
		int	len
	)		[inline]

References Sirikata::SST::EndPoint< EndObjectType >::endPoint, Sirikata::SST::EndPoint< EndObjectType >::port, and Sirikata::XDP::Port< EndpointType >::send().

static void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::stopListening	(	ConnectionVariables< EndPointType > *	sstConnVars,
		EndPoint< EndPointType > &	listeningEndPoint
	)		[inline, static]

References Sirikata::SST::EndPoint< EndObjectType >::endPoint, Sirikata::SST::ConnectionVariables< EndPointType >::getDatagramLayer(), and Sirikata::SST::ConnectionVariables< EndPointType >::removeDatagramLayer().

void Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::unlisten

(

EndPoint< EndPointType > &

ep

)

[inline]

---

Member Data Documentation

PortMap Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::mAllocatedPorts [private]

const Context* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::mContext [private]

EndPointType Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::mEndpoint [private]

boost::mutex Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::mMutex [private]

OHDP::Service* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::mOHDP [private]

ConnectionVariables<EndPointType>* Sirikata::SST::BaseDatagramLayer< OHDP::SpaceNodeID >::mSSTConnVars [private]

---

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

• libcore/include/sirikata/core/ohdp/SST.hpp