#include <ShmemTransport.h>

Inheritance diagram for OpenDDS::DCPS::ShmemTransport:

Collaboration diagram for OpenDDS::DCPS::ShmemTransport:

[legend]

Classes
class	ReadTask

Public Member Functions
	ShmemTransport (const ShmemInst_rch &inst)

ShmemAllocator *	alloc ()

std::string	address ()

void	signal_semaphore ()

ShmemInst_rch	config () const

Public Member Functions inherited from OpenDDS::DCPS::TransportImpl
virtual	~TransportImpl ()

virtual void	unbind_link (DataLink *link)
	Remove any pending_release mappings. More...

bool	release_link_resources (DataLink *link)

TransportInst_rch	config () const

virtual void	register_for_reader (const GUID_t &, const GUID_t &, const GUID_t &, const TransportLocatorSeq &, OpenDDS::DCPS::DiscoveryListener *)

virtual void	unregister_for_reader (const GUID_t &, const GUID_t &, const GUID_t &)

virtual void	register_for_writer (const GUID_t &, const GUID_t &, const GUID_t &, const TransportLocatorSeq &, DiscoveryListener *)

virtual void	unregister_for_writer (const GUID_t &, const GUID_t &, const GUID_t &)

virtual void	update_locators (const GUID_t &, const TransportLocatorSeq &)

virtual void	get_last_recv_locator (const GUID_t &, TransportLocator &)

virtual void	rtps_relay_address_change ()

virtual void	append_transport_statistics (TransportStatisticsSequence &)

ACE_Reactor_Timer_Interface *	timer () const
	Interface to the transport's reactor for scheduling timers. More...

ACE_Reactor *	reactor () const

ACE_thread_t	reactor_owner () const

bool	is_shut_down () const

void	create_reactor_task (bool useAsyncSend=false, const OPENDDS_STRING &name="")

void	dump ()
	Diagnostic aid. More...

OPENDDS_STRING	dump_to_str ()

void	report ()

virtual WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()

virtual void	rtps_relay_only_now (bool)

virtual void	use_rtps_relay_now (bool)

virtual void	use_ice_now (bool)

ReactorTask_rch	reactor_task ()

EventDispatcher_rch	event_dispatcher ()

int	acquire ()

int	tryacquire ()

int	release ()

int	remove ()

bool	connection_info (TransportLocator &local_info, ConnectionInfoFlags flags) const

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Protected Member Functions
virtual AcceptConnectResult	connect_datalink (const RemoteTransport &remote, const ConnectionAttribs &attribs, const TransportClient_rch &client)

virtual AcceptConnectResult	accept_datalink (const RemoteTransport &remote, const ConnectionAttribs &attribs, const TransportClient_rch &client)

virtual void	stop_accepting_or_connecting (const TransportClient_wrch &client, const GUID_t &remote_id, bool disassociate, bool association_failed)

bool	configure_i (const ShmemInst_rch &config)

virtual void	shutdown_i ()

virtual bool	connection_info_i (TransportLocator &info, ConnectionInfoFlags flags) const

virtual void	release_datalink (DataLink *link)

virtual std::string	transport_type () const

Protected Member Functions inherited from OpenDDS::DCPS::TransportImpl
	TransportImpl (TransportInst_rch config)

bool	open ()

typedef	OPENDDS_MULTIMAP (TransportClient_wrch, DataLink_rch) PendConnMap

void	add_pending_connection (const TransportClient_rch &client, DataLink_rch link)

void	shutdown ()

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Private Types
typedef ACE_Thread_Mutex	LockType

typedef ACE_Guard< LockType >	GuardType

Private Member Functions
ShmemDataLink_rch	make_datalink (const std::string &remote_address)
	Create the DataLink object and start it. More...

ShmemDataLink_rch	get_or_make_datalink (const char *caller, const RemoteTransport &remote)

std::pair< std::string, std::string >	blob_to_key (const TransportBLOB &blob)

void	read_from_links ()

typedef	OPENDDS_MAP (std::string, ShmemDataLink_rch) ShmemDataLinkMap

Private Attributes
LockType	links_lock_

ShmemDataLinkMap	links_

unique_ptr< ShmemAllocator >	alloc_

unique_ptr< ReadTask >	read_task_

Additional Inherited Members
Public Attributes inherited from OpenDDS::DCPS::TransportImpl
LockType	lock_
	Lock to protect the config_ and reactor_task_ data members. More...

WeakRcHandle< TransportInst >	config_

ReactorTask_rch	reactor_task_

EventDispatcher_rch	event_dispatcher_
	smart ptr to the associated DL cleanup task More...

unique_ptr< Monitor >	monitor_
	Monitor object for this entity. More...

Protected Types inherited from OpenDDS::DCPS::TransportImpl
typedef ACE_SYNCH_MUTEX	LockType

typedef ACE_Guard< LockType >	GuardType

Protected Attributes inherited from OpenDDS::DCPS::TransportImpl
LockType	pending_connections_lock_
	Lock to protect the pending_connections_ data member. More...

PendConnMap	pending_connections_

AtomicBool	is_shut_down_
	Id of the last link established. More...

Detailed Description

Definition at line 27 of file ShmemTransport.h.

Member Typedef Documentation

◆ GuardType

typedef ACE_Guard<LockType> OpenDDS::DCPS::ShmemTransport::GuardType

private

Definition at line 73 of file ShmemTransport.h.

◆ LockType

typedef ACE_Thread_Mutex OpenDDS::DCPS::ShmemTransport::LockType

private

Definition at line 72 of file ShmemTransport.h.

Constructor & Destructor Documentation

◆ ShmemTransport()

OpenDDS::DCPS::ShmemTransport::ShmemTransport ( const ShmemInst_rch & inst )

explicit

Definition at line 28 of file ShmemTransport.cpp.

References configure_i(), and OpenDDS::DCPS::TransportImpl::open().

   : TransportImpl(inst)
 {
   if (!(configure_i(inst) && open())) {
     throw Transport::UnableToCreate();
   }
 }

Member Function Documentation

◆ accept_datalink()

TransportImpl::AcceptConnectResult OpenDDS::DCPS::ShmemTransport::accept_datalink	(	const RemoteTransport &	remote,
		const ConnectionAttribs &	attribs,
		const TransportClient_rch &	client
	)

protectedvirtual

accept_datalink() is called from TransportClient to initiate an association as the passive peer. A DataLink may be returned if one is already connected and ready to use, otherwise passively wait for a physical connection from the active side (either in the form of a connection event or handshaking message). Upon completion of the physical connection, the transport calls back to TransportClient::use_datalink().

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 107 of file ShmemTransport.cpp.

References get_or_make_datalink().

 {
   return AcceptConnectResult(get_or_make_datalink("accept_datalink", remote));
 }

◆ address()

std::string OpenDDS::DCPS::ShmemTransport::address ( void )

Definition at line 356 of file ShmemTransport.cpp.

References config(), and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

 {
   ShmemInst_rch cfg = config();
   return cfg ? cfg->poolname() : std::string();
 }

◆ alloc()

ShmemAllocator* OpenDDS::DCPS::ShmemTransport::alloc ( void )

inline

Definition at line 32 of file ShmemTransport.h.

32 { return alloc_.get(); }

OpenDDS::DCPS::ShmemTransport::alloc_

unique_ptr< ShmemAllocator > alloc_

Definition: ShmemTransport.h:82

◆ blob_to_key()

std::pair< std::string, std::string > OpenDDS::DCPS::ShmemTransport::blob_to_key ( const TransportBLOB & blob )

private

Definition at line 258 of file ShmemTransport.cpp.

Referenced by get_or_make_datalink().

 {
   const char* const c_str = reinterpret_cast<const char*>(blob.get_buffer());
   const std::string host(c_str);
   const size_t host_len = host.size();
 
   const std::string pool(c_str + host_len + 1, blob.length() - host_len - 1);
   return make_pair(host, pool);
 }

◆ config()

ShmemInst_rch OpenDDS::DCPS::ShmemTransport::config ( ) const

Definition at line 37 of file ShmemTransport.cpp.

References OpenDDS::DCPS::TransportImpl::config(), and OpenDDS::DCPS::dynamic_rchandle_cast().

Referenced by address(), connection_info_i(), and get_or_make_datalink().

 {
   return dynamic_rchandle_cast<ShmemInst>(TransportImpl::config());
 }

◆ configure_i()

bool OpenDDS::DCPS::ShmemTransport::configure_i ( const ShmemInst_rch & config )

protected

Definition at line 133 of file ShmemTransport.cpp.

References ACE_ERROR, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, alloc_, OpenDDS::DCPS::TransportImpl::create_reactor_task(), OpenDDS::DCPS::LogLevel::Error, LM_DEBUG, LM_ERROR, OpenDDS::DCPS::log_level, read_task_, and VDBG_LVL.

Referenced by ShmemTransport().

 {
   if (!config) {
     return false;
   }
 
   create_reactor_task(false, "ShmemTransport" + config->name());
 
 #ifdef OPENDDS_SHMEM_UNSUPPORTED
   ACE_UNUSED_ARG(config);
   if (log_level >= LogLevel::Error) {
     ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: ShmemTransport::configure_i: "
                "no platform support for shared memory!\n"));
   }
   return false;
 #else /* OPENDDS_SHMEM_UNSUPPORTED */
 
   ShmemAllocator::MEMORY_POOL_OPTIONS alloc_opts;
 #  if defined OPENDDS_SHMEM_WINDOWS
   alloc_opts.max_size_ = config->pool_size_;
 #  elif defined OPENDDS_SHMEM_UNIX
   alloc_opts.base_addr_ = 0;
   alloc_opts.segment_size_ = config->pool_size_;
   alloc_opts.minimum_bytes_ = alloc_opts.segment_size_;
   alloc_opts.max_segments_ = 1;
 #  endif /* OPENDDS_SHMEM_WINDOWS */
 
   alloc_.reset(
     new ShmemAllocator(ACE_TEXT_CHAR_TO_TCHAR(config->poolname().c_str()),
                        0 /*lock_name is optional*/, &alloc_opts));
 
   void* mem = alloc_->malloc(sizeof(ShmemSharedSemaphore));
   if (mem == 0) {
     if (log_level >= LogLevel::Error) {
       ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: ShmemTrasport::configure_i: failed to allocate"
                  " space for semaphore in shared memory!\n"));
     }
     return false;
   }
 
   ShmemSharedSemaphore* pSem = reinterpret_cast<ShmemSharedSemaphore*>(mem);
   alloc_->bind("Semaphore", pSem);
 
   bool ok;
 #  if defined OPENDDS_SHMEM_WINDOWS
   *pSem = ::CreateSemaphoreW(0 /*default security*/,
                              0 /*initial count*/,
                              0x7fffffff /*max count (ACE's default)*/,
                              0 /*no name*/);
   ACE_sema_t ace_sema = *pSem;
   ok = (*pSem != 0);
 #  elif defined OPENDDS_SHMEM_UNIX
   ok = (0 == ::sem_init(pSem, 1 /*process shared*/, 0 /*initial count*/));
   ACE_sema_t ace_sema;
   std::memset(&ace_sema, 0, sizeof ace_sema);
   ace_sema.sema_ = pSem;
 #    ifdef OPENDDS_SHMEM_UNIX_EMULATE_SEM_TIMEOUT
   ace_sema.lock_ = PTHREAD_MUTEX_INITIALIZER;
   ace_sema.count_nonzero_ = PTHREAD_COND_INITIALIZER;
 #    endif
 #  endif /* OPENDDS_SHMEM_WINDOWS */
   if (!ok) {
     ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                       ACE_TEXT("ShmemTransport::configure_i: ")
                       ACE_TEXT("could not create semaphore\n")),
                      false);
   }
 
   read_task_.reset(new ReadTask(this, ace_sema));
 
   VDBG_LVL((LM_DEBUG, "(%P|%t) ShmemTransport %@ configured with address %C\n",
             this, config->poolname().c_str()), 1);
 
   return true;
 #endif /* OPENDDS_SHMEM_UNSUPPORTED */
 }

◆ connect_datalink()

TransportImpl::AcceptConnectResult OpenDDS::DCPS::ShmemTransport::connect_datalink	(	const RemoteTransport &	remote,
		const ConnectionAttribs &	attribs,
		const TransportClient_rch &	client
	)

protectedvirtual

connect_datalink() is called from TransportClient to initiate an association as the active peer. A DataLink may be returned if one is already connected and ready to use, otherwise initiate a connection to the passive side and return from this method. Upon completion of the physical connection, the transport calls back to TransportClient::use_datalink().

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 90 of file ShmemTransport.cpp.

References OpenDDS::DCPS::TransportImpl::AcceptConnectResult::ACR_SUCCESS, OpenDDS::DCPS::TransportImpl::add_pending_connection(), get_or_make_datalink(), and OpenDDS::DCPS::TransportImpl::RemoteTransport::repo_id_.

 {
   ShmemDataLink_rch link = get_or_make_datalink("connect_datalink", remote);
   if (!link) {
     return AcceptConnectResult();
   }
   // Wait for invoke_on_start_callbacks to actually start a writer. This is done
   // when the writer gets an association message from the reader in the writer
   // case of ShmemDataLink::request_ack_received.
   link->add_on_start_callback(client, remote.repo_id_);
   add_pending_connection(client, link);
   return AcceptConnectResult(AcceptConnectResult::ACR_SUCCESS);
 }

◆ connection_info_i()

bool OpenDDS::DCPS::ShmemTransport::connection_info_i	(	TransportLocator &	local_info,
		ConnectionInfoFlags	flags
	)		const

protectedvirtual

Called by our connection_info() method to allow the concrete TransportImpl subclass to do the dirty work since it really is the one that knows how to populate the supplied TransportLocator object.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 247 of file ShmemTransport.cpp.

References config().

 {
   ShmemInst_rch cfg = config();
   if (cfg) {
     cfg->populate_locator(info, flags);
     return true;
   }
   return false;
 }

◆ get_or_make_datalink()

ShmemDataLink_rch OpenDDS::DCPS::ShmemTransport::get_or_make_datalink	(	const char *	caller,
		const RemoteTransport &	remote
	)

private

Definition at line 66 of file ShmemTransport.cpp.

References ACE_ERROR, OpenDDS::DCPS::TransportImpl::RemoteTransport::blob_, blob_to_key(), config(), OpenDDS::DCPS::LogLevel::Error, links_, links_lock_, LM_DEBUG, LM_ERROR, OpenDDS::DCPS::log_level, make_datalink(), and VDBG_LVL.

Referenced by accept_datalink(), and connect_datalink().

 {
   const std::pair<std::string, std::string> key = blob_to_key(remote.blob_);
   ShmemInst_rch cfg = config();
   if (!cfg || key.first != cfg->hostname()) {
     if (log_level >= LogLevel::Error) {
       ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: ShmemTransport::get_or_make_datalink: "
                  "%C link %C:%C not found, hostname %C.\n",
                  caller, key.first.c_str(), key.second.c_str(),
                  cfg ? cfg->hostname().c_str() : "(no config)"));
     }
     return ShmemDataLink_rch();
   }
 
   GuardType guard(links_lock_);
   ShmemDataLinkMap::iterator iter = links_.find(key.second);
   const bool make = iter == links_.end();
   VDBG_LVL((LM_DEBUG, "(%P|%t) ShmemTransport::get_or_make_datalink: %C using %C link %C:%C\n",
             caller, make ? "new" : "existing", key.first.c_str(), key.second.c_str()), 2);
   return make ? make_datalink(key.second) : iter->second;
 }

◆ make_datalink()

ShmemDataLink_rch OpenDDS::DCPS::ShmemTransport::make_datalink ( const std::string & remote_address )

private

Create the DataLink object and start it.

Definition at line 43 of file ShmemTransport.cpp.

References ACE_ERROR, OpenDDS::DCPS::LogLevel::Error, links_, LM_ERROR, OpenDDS::DCPS::log_level, and OpenDDS::DCPS::rchandle_from().

Referenced by get_or_make_datalink().

 {
   ShmemDataLink_rch link = make_rch<ShmemDataLink>(rchandle_from(this));
 
   if (!link->open(remote_address)) {
     if (log_level >= LogLevel::Error) {
       ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: ShmemTransport::make_datalink: "
         "failed to open DataLink!\n"));
     }
     return ShmemDataLink_rch();
   }
 
   if (!links_.insert(ShmemDataLinkMap::value_type(remote_address, link)).second) {
     if (log_level >= LogLevel::Error) {
       ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: ShmemTransport::make_datalink: "
         "there is an existing link for %C!\n", remote_address.c_str()));
     }
     return ShmemDataLink_rch();
   }
 
   return link;
 }

◆ OPENDDS_MAP()

typedef OpenDDS::DCPS::ShmemTransport::OPENDDS_MAP	(	std::string	,
		ShmemDataLink_rch
	)

private

Map of fully associated DataLinks for this transport. Protected by links_lock_.

◆ read_from_links()

void OpenDDS::DCPS::ShmemTransport::read_from_links ( )

private

Definition at line 329 of file ShmemTransport.cpp.

References OpenDDS::DCPS::TransportImpl::is_shut_down(), links_, and links_lock_.

Referenced by OpenDDS::DCPS::ShmemTransport::ReadTask::svc().

 {
   std::vector<ShmemDataLink_rch> dl_copies;
   {
     GuardType guard(links_lock_);
     typedef ShmemDataLinkMap::iterator iter_t;
     for (iter_t it = links_.begin(); it != links_.end(); ++it) {
       dl_copies.push_back(it->second);
     }
   }
 
   typedef std::vector<ShmemDataLink_rch>::iterator dl_iter_t;
   for (dl_iter_t dl_it = dl_copies.begin(); !is_shut_down() && dl_it != dl_copies.end(); ++dl_it) {
     dl_it->in()->read();
   }
 }

◆ release_datalink()

void OpenDDS::DCPS::ShmemTransport::release_datalink ( DataLink * link )

protectedvirtual

Called by the TransportRegistry when this TransportImpl object is released while the TransportRegistry is handling a release() "event". The DataLink itself calls this method when it thinks it is no longer used for any associations. This occurs during a "remove associations" operation being performed by some TransportClient that uses this TransportImpl. The TransportClient is known to have acquired our reservation_lock_, so there won't be any reserve_datalink() calls being made from any other threads while we perform this release.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 269 of file ShmemTransport.cpp.

References links_, links_lock_, and OpenDDS::DCPS::DataLink::stop().

 {
   GuardType guard(links_lock_);
   for (ShmemDataLinkMap::iterator it(links_.begin());
        it != links_.end(); ++it) {
     // We are guaranteed to have exactly one matching DataLink
     // in the map; release any resources held and return.
     if (link == static_cast<DataLink*>(it->second.in())) {
       link->stop();
       links_.erase(it);
       return;
     }
   }
 }

◆ shutdown_i()

void OpenDDS::DCPS::ShmemTransport::shutdown_i ( )

protectedvirtual

Called during the shutdown() method in order to give the concrete TransportImpl subclass a chance to do something when the shutdown "event" occurs.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 211 of file ShmemTransport.cpp.

References alloc_, links_, links_lock_, read_task_, and TheServiceParticipant.

 {
   if (read_task_) {
     read_task_->stop();
     ThreadStatusManager::Sleeper s(TheServiceParticipant->get_thread_status_manager());
     read_task_->wait();
   }
 
   // Shutdown reserved datalinks and release configuration:
   GuardType guard(links_lock_);
   for (ShmemDataLinkMap::iterator it(links_.begin());
        it != links_.end(); ++it) {
     it->second->transport_shutdown();
   }
   links_.clear();
 
   read_task_.reset();
 
   if (alloc_) {
 #ifndef OPENDDS_SHMEM_UNSUPPORTED
     void* mem = 0;
     alloc_->find("Semaphore", mem);
     ShmemSharedSemaphore* pSem = reinterpret_cast<ShmemSharedSemaphore*>(mem);
 #  if defined OPENDDS_SHMEM_WINDOWS
     ::CloseHandle(*pSem);
 #  elif defined OPENDDS_SHMEM_UNIX
     ::sem_destroy(pSem);
 #  endif /* OPENDDS_SHMEM_WINDOWS */
 #endif /* OPENDDS_SHMEM_UNSUPPORTED */
 
     alloc_->release(1 /*close*/);
     alloc_.reset();
   }
 }

◆ signal_semaphore()

void OpenDDS::DCPS::ShmemTransport::signal_semaphore ( )

Definition at line 347 of file ShmemTransport.cpp.

References OpenDDS::DCPS::TransportImpl::is_shut_down(), and read_task_.

 {
   if (is_shut_down()) {
     return;
   }
   read_task_->signal_semaphore();
 }

◆ stop_accepting_or_connecting()

void OpenDDS::DCPS::ShmemTransport::stop_accepting_or_connecting	(	const TransportClient_wrch &	client,
		const GUID_t &	remote_id,
		bool	disassociate,
		bool	association_failed
	)

protectedvirtual

stop_accepting_or_connecting() is called from TransportClient to terminate the accepting process begun by accept_datalink() or connect_datalink(). This allows the TransportImpl to clean up any resources associated with this pending connection. The TransportClient* passed in to accept or connect is not valid after this method is called.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 114 of file ShmemTransport.cpp.

References ACE_GUARD, OpenDDS::DCPS::dynamic_rchandle_cast(), links_lock_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::DCPS::TransportImpl::pending_connections_, and OpenDDS::DCPS::TransportImpl::pending_connections_lock_.

 {
   ACE_GUARD(ACE_Thread_Mutex, links_guard, links_lock_);
   ACE_GUARD(ACE_Thread_Mutex, pending_guard, pending_connections_lock_);
   typedef PendConnMap::iterator Iter;
   const std::pair<Iter, Iter> range = pending_connections_.equal_range(client);
   for (Iter iter = range.first; iter != range.second; ++iter) {
     ShmemDataLink_rch sdl = dynamic_rchandle_cast<ShmemDataLink>(iter->second);
     TransportClient_rch tc = client.lock();
     if (tc) {
       sdl->stop_resend_association_msgs(tc->get_guid(), remote_id);
     }
   }
   pending_connections_.erase(range.first, range.second);
 }

◆ transport_type()

virtual std::string OpenDDS::DCPS::ShmemTransport::transport_type ( ) const

inlineprotectedvirtual

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 60 of file ShmemTransport.h.

60 { return "shmem"; }

Member Data Documentation

◆ alloc_

unique_ptr<ShmemAllocator> OpenDDS::DCPS::ShmemTransport::alloc_

private

Definition at line 82 of file ShmemTransport.h.

Referenced by configure_i(), and shutdown_i().

◆ links_

ShmemDataLinkMap OpenDDS::DCPS::ShmemTransport::links_

private

Definition at line 80 of file ShmemTransport.h.

Referenced by get_or_make_datalink(), make_datalink(), read_from_links(), release_datalink(), and shutdown_i().

◆ links_lock_

LockType OpenDDS::DCPS::ShmemTransport::links_lock_

private

Definition at line 75 of file ShmemTransport.h.

Referenced by get_or_make_datalink(), read_from_links(), release_datalink(), shutdown_i(), and stop_accepting_or_connecting().

◆ read_task_

unique_ptr<ReadTask> OpenDDS::DCPS::ShmemTransport::read_task_

private

Definition at line 96 of file ShmemTransport.h.

Referenced by configure_i(), shutdown_i(), and signal_semaphore().

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

Classes

Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ GuardType

◆ LockType

Constructor & Destructor Documentation

◆ ShmemTransport()

Member Function Documentation

◆ accept_datalink()

◆ address()

◆ alloc()

◆ blob_to_key()

◆ config()

◆ configure_i()

◆ connect_datalink()

◆ connection_info_i()

◆ get_or_make_datalink()

◆ make_datalink()

◆ OPENDDS_MAP()

◆ read_from_links()

◆ release_datalink()

◆ shutdown_i()

◆ signal_semaphore()

◆ stop_accepting_or_connecting()

◆ transport_type()

Member Data Documentation

◆ alloc_

◆ links_

◆ links_lock_

◆ read_task_