#include <SST.hpp>

Collaboration diagram for Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >:

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, ODP::Service *odp)
static void	stopListening (ConnectionVariables< EndPointType > *sstConnVars, EndPoint< EndPointType > &listeningEndPoint)
Private Types
typedef SpaceObjectReference	EndPointType
typedef std::map< EndPoint < EndPointType >, ODP::Port * >	PortMap
Private Member Functions
	BaseDatagramLayer (ConnectionVariables< EndPointType > sstConnVars, const Context ctx, ODP::Service *odpservice, const EndPointType &ep)
ODP::Port *	allocatePort (const EndPoint< EndPointType > &ep)
ODP::Port *	getPort (const EndPoint< EndPointType > &ep)
ODP::Port *	getOrAllocatePort (const EndPoint< EndPointType > &ep)
void	receiveMessage (const ODP::Endpoint &src, const ODP::Endpoint &dst, MemoryReference payload)
void	receiveMessageToCallback (const ODP::Endpoint &src, const ODP::Endpoint &dst, MemoryReference payload, DataCallback cb)
Private Attributes
const Context *	mContext
ODP::Service *	mODP
PortMap	mAllocatedPorts
boost::mutex	mMutex
ConnectionVariables < EndPointType > *	mSSTConnVars
EndPointType	mEndpoint

template<>
class Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >

Member Typedef Documentation

typedef Ptr Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::BaseDatagramLayerPtr

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

typedef SpaceObjectReference Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::EndPointType [private]

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

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

Constructor & Destructor Documentation

Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::BaseDatagramLayer	(	ConnectionVariables< EndPointType > *	sstConnVars,
		const Context *	ctx,
		ODP::Service *	odpservice,
		const EndPointType &	ep
	)		`[inline, private]`

Member Function Documentation

ODP::Port* Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::allocatePort ( const EndPoint< EndPointType > & ep ) [inline, private]

References Sirikata::SST::EndPoint< EndObjectType >::endPoint, and Sirikata::SST::EndPoint< EndObjectType >::port.

const Context* Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::context ( ) [inline]

static BaseDatagramLayerPtr Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::createDatagramLayer	(	ConnectionVariables< EndPointType > *	sstConnVars,
		EndPointType	endPoint,
		const Context *	ctx,
		ODP::Service *	odp
	)		`[inline, static]`

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

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

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

ODP::Port* Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::getOrAllocatePort ( const EndPoint< EndPointType > & ep ) [inline, private]

ODP::Port* Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::getPort ( const EndPoint< EndPointType > & ep ) [inline, private]

uint32 Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::getUnusedPort ( const EndPointType & ep ) [inline]

void Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::invalidate ( ) [inline]

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

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

void Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::listenOn ( const EndPoint< EndPointType > & listeningEndPoint ) [inline]

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

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

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

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

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

void Sirikata::SST::BaseDatagramLayer< SpaceObjectReference >::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< SpaceObjectReference >::stopListening	(	ConnectionVariables< EndPointType > *	sstConnVars,
		EndPoint< EndPointType > &	listeningEndPoint
	)		`[inline, static]`