DtSmSocket provides access to shared memory via a subscribable message queue. More...

Inheritance diagram for DtSmSocket__rti__:

Collaboration diagram for DtSmSocket__rti__:

Public Member Functions
	DtSmSocket__rti__ (const char *sharename, std::shared_ptr< DtMsgHeaderReader > hdrReader)

virtual	~DtSmSocket__rti__ ()

virtual bool	initializeSmQueue (DtU32 id=DtSM_INVALID_SUBSCRIBER_ID, bool forceSubscribe=false)
	Attach to shared memory message queue. More...

virtual bool	initializeSmQueue (DtU32 numBuckets, DtU32 payloadSize, DtU32 id=DtSM_INVALID_SUBSCRIBER_ID, bool forceSubscribe=false)
	The following version of initializeSmQueue() is specific to management of the shared memory subscribable message queue which the socket interfaces with. More...

virtual int	sendMessage (caddr_t msg, size_t msgSize, bool deleteAfterSend, const DtInetAddr &notUsed=DtInetAddr::inaddrAny())
	The send method sendMessage() ignores the destination address and does not promulgate any transport method. More...

virtual bool	flush ()
	Send buffered messages. More...

virtual void	openSocket (const DtInetEndpoint &dest, DtU32 flags=DtDefaultSockOpts, DtU16 localPort=0, DtInetDevice *hostIf=NULL)
	These methods do nothing but must be overridden to prevent parent class from attempting to perform setsockopt on non-existent socket. More...

virtual void	enableBundling (size_t maxBundleSize)
	Enables message bundling and sets the maximum bundle size. More...

virtual void	disableBundling ()
	Disables message bundling. More...

virtual void	enableCompression (DtU8 compressionLevel)

virtual void	disableCompression ()
	Disables message compression. More...

virtual bool	joinMulticastGroup (const DtInetAddr &grpAddr, DtInetDevice *device=NULL)

virtual bool	joinMulticastGroup (const DtInetEndpoint &grpEndpoint, DtInetDevice *device=NULL)

virtual bool	dropMulticastGroup (const DtInetAddr &grpAddr, DtInetDevice *device=NULL)

virtual bool	dropMulticastGroup (const DtInetEndpoint &grpEndpoint, DtInetDevice *device=NULL)

virtual bool	setMcastTtlOption (DtU32 ttl)

virtual void	setRetryOnSend (unsigned int numRetries, double waitPeriod)
	Enables/disables send retries on failure. More...

virtual DtSmSubscribableMessageQueue__rti__ *	msgQueue () const

virtual bool	isOpen () const
	Returns true if the socket is open. More...

virtual int	subscribe (DtU32 id=DtSM_INVALID_SUBSCRIBER_ID)
	The following methods are for use by all subscribers the the shared memory subscribable message queue the socket interfaces with. More...

virtual void	unsubscribe (DtU32 id)

virtual bool	shutdownQueue (bool ruthless=false)
	The following methods are specific to management of the shared memory subscribable message queue which the socket interfaces with. More...

virtual int	subscriberCount () const

Public Member Functions inherited from DtUdpMsgSocket
	DtUdpMsgSocket (std::shared_ptr< DtMsgHeaderReader > hdrReader, size_t maxPacketSize=DtDefaultMaxPacketSize)
	Constructor. More...

virtual	~DtUdpMsgSocket ()
	Destructor. More...

virtual void	openSocket (const MAKRti::DtInetEndpoint &dest, MAKRti::DtU32 flags=theDefaultSockOpts, MAKRti::DtU16 localPort=0, MAKRti::DtInetDevice *hostIf=NULL)
	Opens the socket if not already open. More...

virtual int	sendMessage (caddr_t msg, size_t msgSize, bool deleteAfterSend, const MAKRti::DtInetAddr &destAddr=MAKRti::DtInetAddr::inaddrAny(), int port=0)
	Sends a message. More...

virtual int	recvMessage (caddr_t *buffptr)
	Gets the next message from the incoming data. More...

virtual int	recvMessageWithSrc (caddr_t *buffptr, MAKRti::DtInetEndpoint &src)
	Gets the next message from the incoming data. More...

virtual void	enableCompression (MAKRti::DtU8 compressionLevel)
	Enables message compression and sets the compression level. More...

virtual bool	joinMulticastGroup (const MAKRti::DtInetAddr &grpAddr, MAKRti::DtInetDevice *device=NULL)
	Join / drop subscription to multicast group. More...

virtual bool	joinMulticastGroup (const MAKRti::DtInetEndpoint &grpEndpoint, MAKRti::DtInetDevice *device=NULL)

virtual bool	dropMulticastGroup (const MAKRti::DtInetAddr &grpAddr, MAKRti::DtInetDevice *device=NULL)

virtual bool	dropMulticastGroup (const MAKRti::DtInetEndpoint &grpEndpoint, MAKRti::DtInetDevice *device=NULL)

virtual bool	setMcastTtlOption (MAKRti::DtU32 ttl)
	Change the default time-to-live on outbound multicast packets sent from this socket. More...

virtual MAKRti::DtU32	maxMsgSize () const
	Gets the maximum message size. More...

MAKRti::DtInetUdpSocket *	inetUdpSocket ()
	Returns a pointer to the MAKRti::DtInetUdpSocket. More...

virtual void	setFilterPort (int port)
	Sets the filter port. All messages sent from this port on this machine will be filtered. More...

Public Member Functions inherited from DtMsgSocket
	DtMsgSocket (std::shared_ptr< DtMsgHeaderReader > hdrReader, size_t recvBuffSize)
	Constructor. More...

	DtMsgSocket (DtUniquePtr< MAKRti::DtInetSocket > socket, std::shared_ptr< DtMsgHeaderReader > hdrReader, size_t recvBuffSize)
	Constructor which takes a pre-created MAKRti::DtInetSocket pointer. More...

virtual	~DtMsgSocket ()
	Destructor. More...

virtual bool	closeSocket ()
	Close a socket. Returns true on successful close or false on failure. More...

virtual MAKRti::DtInetSockState	state () const
	Returns the state of the socket. More...

void	printStateToStream (MAKRti::DtOutputStream &stream) const
	prints state to stream More...

const MAKRti::DtString &	lastError () const
	Returns a description of the last error. More...

const MAKRti::DtInetEndpoint &	localEndpoint () const
	Gets the local endpoint for the socket. More...

void	setSendBufferSize (MAKRti::DtU32 size)
	Sets the socket send buffer size. More...

void	setRecvBufferSize (MAKRti::DtU32 size)
	Sets the socket receive buffer size. More...

MAKRti::DtU32	maxSendMsgSize () const
	Gets the maximum socket send size. More...

unsigned int	descriptor () const
	Get's the socket file descriptor. More...

MAKRti::DtInetSocket *	inetSocket ()
	Returns a pointer to the MAKRti::DtInetSocket. More...

Protected Member Functions
virtual int	recv (caddr_t buffptr, DtInetEndpoint ep)
	Gets the next message from the incoming data. More...

	DtSmSocket__rti__ (const DtSmSocket__rti__ &)
	Not Implemented. More...

DtSmSocket__rti__ &	operator= (const DtSmSocket__rti__ &)
	Not Implemented. More...

Protected Member Functions inherited from DtUdpMsgSocket
virtual int	sendPacket (caddr_t msg, size_t msgSize, const MAKRti::DtInetAddr &destAddr=MAKRti::DtInetAddr::inaddrAny(), int port=0)
	Sends a single packet; handle retries if necessary. More...

virtual int	doSendPacket (caddr_t msg, size_t msgSize, const MAKRti::DtInetAddr &destAddr=MAKRti::DtInetAddr::inaddrAny(), int port=0)
	Just do the send packet part dealing with destination and port. More...

virtual int	retrySendTo (caddr_t msg, size_t msgSize, const MAKRti::DtInetAddr &destAddr=MAKRti::DtInetAddr::inaddrAny(), int port=0)
	Retry sending a message which failed to send. More...

virtual int	recv (caddr_t buffptr, MAKRti::DtInetEndpoint ep)
	Gets the next message from the incoming data. More...

Protected Member Functions inherited from DtMsgSocket
void	expandRecvBuffer (size_t sizeNeeded)
	Expands the receive buffer to accommodate the given size message. More...

Protected Attributes
MAKRti::DtString	mySharedMemName

DtSmSubscribableMessageQueue__rti__ *	mySmMsgQueue

Protected Attributes inherited from DtUdpMsgSocket
MAKRti::DtInetEndpoint	myEndpoint
	The current endpoint to send to. More...

std::map< MAKRti::DtInetAddr, DtMsgBundler * >	myMsgBundlers
	Message bundlers for outgoing messages for each destination address. More...

DtMsgBundler	myDefaultMsgBundler
	Message bundler for the default destination. More...

bool	myBundlingEnabled
	Whether message bundling is enabled. More...

DtMsgCompressor	myMsgCompressor
	Message compressor and uncompressor. More...

bool	myCompressionEnabled
	Whether message compression is enabled. More...

MAKRti::DtInetEndpoint	myLastSourceEndpoint
	Source endpoint of last data received. More...

size_t	myMaxPacketSize
	The maximum packet size. More...

unsigned int	myMaxSendRetries
	The maximum number of times to try resending. More...

double	mySendRetryPeriod
	The wait period between send retries. More...

int	myFilterPort
	All messages sent from this port on this machine will be filtered. More...

Protected Attributes inherited from DtMsgSocket
DtUniquePtr< MAKRti::DtInetSocket >	mySocket
	The socket. More...

MAKRti::DtInetBuffer	myRecvBuffer
	The buffer to store received data in. More...

MAKRti::DtString	myLastError
	Description of last error. More...

std::shared_ptr < DtMsgHeaderReader >	myHeaderReader
	Reads data from message header. More...

Additional Inherited Members
Static Protected Attributes inherited from DtUdpMsgSocket
static const MAKRti::DtU32	theDefaultSockOpts

Detailed Description

DtSmSocket provides access to shared memory via a subscribable message queue.

DtSmSocket isn't really a socket in the classical 'BSD sockets' sense. It is an interface abstraction that mirrors socket functionality to allow applications to easily use either network I/O or shared memory for communication using the same general interface. Where this flexibility is not a paramount concern direct access to the subscribable message queue is more efficient.

Constructor & Destructor Documentation

DtSmSocket__rti__::DtSmSocket__rti__	(	const char *	sharename,
		std::shared_ptr< DtMsgHeaderReader >	hdrReader
	)

virtual DtSmSocket__rti__::~DtSmSocket__rti__ ( )

virtual

DtSmSocket__rti__::DtSmSocket__rti__ ( const DtSmSocket__rti__ & )

protected

Not Implemented.

Member Function Documentation

virtual void DtSmSocket__rti__::disableBundling ( )

virtual

Disables message bundling.

Reimplemented from DtUdpMsgSocket.

virtual void DtSmSocket__rti__::disableCompression ( )

virtual

Disables message compression.

Reimplemented from DtUdpMsgSocket.

virtual bool DtSmSocket__rti__::dropMulticastGroup	(	const DtInetAddr &	grpAddr,
		DtInetDevice *	device = `NULL`
	)

virtual

virtual bool DtSmSocket__rti__::dropMulticastGroup	(	const DtInetEndpoint &	grpEndpoint,
		DtInetDevice *	device = `NULL`
	)

virtual

virtual void DtSmSocket__rti__::enableBundling ( size_t maxBundleSize )

virtual

Enables message bundling and sets the maximum bundle size.

Reimplemented from DtUdpMsgSocket.

virtual void DtSmSocket__rti__::enableCompression ( DtU8 compressionLevel )

virtual

virtual bool DtSmSocket__rti__::flush ( )

virtual

Send buffered messages.

Returns the indication of whether flush is complete or incomplete.

Reimplemented from DtUdpMsgSocket.

virtual bool DtSmSocket__rti__::initializeSmQueue	(	DtU32	id = `DtSM_INVALID_SUBSCRIBER_ID`,
		bool	forceSubscribe = `false`
	)

virtual

Attach to shared memory message queue.

If 'id' is not specified one will be assigned automatically. For use by non-manager subscribers.

virtual bool DtSmSocket__rti__::initializeSmQueue	(	DtU32	numBuckets,
		DtU32	payloadSize,
		DtU32	id = `DtSM_INVALID_SUBSCRIBER_ID`,
		bool	forceSubscribe = `false`
	)

virtual

The following version of initializeSmQueue() is specific to management of the shared memory subscribable message queue which the socket interfaces with.

These should only be used by a queue manager, not by ordinary subscribers. It must be called once and only once prior to use of the message queue.

virtual bool DtSmSocket__rti__::isOpen ( ) const

virtual

Returns true if the socket is open.

Reimplemented from DtUdpMsgSocket.

virtual bool DtSmSocket__rti__::joinMulticastGroup	(	const DtInetAddr &	grpAddr,
		DtInetDevice *	device = `NULL`
	)

virtual

virtual bool DtSmSocket__rti__::joinMulticastGroup	(	const DtInetEndpoint &	grpEndpoint,
		DtInetDevice *	device = `NULL`
	)

virtual

virtual DtSmSubscribableMessageQueue__rti__* DtSmSocket__rti__::msgQueue ( ) const

virtual

virtual void DtSmSocket__rti__::openSocket	(	const DtInetEndpoint &	dest,
		DtU32	flags = `DtDefaultSockOpts`,
		DtU16	localPort = `0`,
		DtInetDevice *	hostIf = `NULL`
	)

virtual

These methods do nothing but must be overridden to prevent parent class from attempting to perform setsockopt on non-existent socket.

DtSmSocket__rti__& DtSmSocket__rti__::operator= ( const DtSmSocket__rti__ & )

protected

Not Implemented.

virtual int DtSmSocket__rti__::recv	(	caddr_t *	buffptr,
		DtInetEndpoint *	ep
	)

protectedvirtual

Gets the next message from the incoming data.

virtual int DtSmSocket__rti__::sendMessage	(	caddr_t	msg,
		size_t	msgSize,
		bool	deleteAfterSend,
		const DtInetAddr &	notUsed = `DtInetAddr::inaddrAny()`
	)

virtual

The send method sendMessage() ignores the destination address and does not promulgate any transport method.

It doesn't matter if the socket is intended to emulate a TCP socket or a UDP socket, once copied to shared memory by an instance of this generic DtSmSocket class a message can only be read by other shared memory queue subscribers. If it must be forwarded to another destination by a certain means (i.e. reliable transport over a network) then this generic shared memory socket must be subclassed and the derived class must provide that capability.

virtual bool DtSmSocket__rti__::setMcastTtlOption ( DtU32 ttl )

virtual

virtual void DtSmSocket__rti__::setRetryOnSend	(	unsigned int	numRetries,
		double	waitPeriod
	)

virtual

Enables/disables send retries on failure.

Reimplemented from DtUdpMsgSocket.

virtual bool DtSmSocket__rti__::shutdownQueue ( bool ruthless = false )

virtual

The following methods are specific to management of the shared memory subscribable message queue which the socket interfaces with.

These should primarily be used by a queue manager, not by ordinary subscribers

virtual int DtSmSocket__rti__::subscribe ( DtU32 id = DtSM_INVALID_SUBSCRIBER_ID )

virtual

The following methods are for use by all subscribers the the shared memory subscribable message queue the socket interfaces with.

virtual int DtSmSocket__rti__::subscriberCount ( ) const

virtual

virtual void DtSmSocket__rti__::unsubscribe ( DtU32 id )

virtual

Member Data Documentation

MAKRti::DtString DtSmSocket__rti__::mySharedMemName

protected

DtSmSubscribableMessageQueue__rti__* DtSmSocket__rti__::mySmMsgQueue

protected

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

smSocket__rti__.h

Public Member Functions

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation