OpenDDS::DCPS::ShmemDataLink Class Reference

#include <ShmemDataLink.h>

Inheritance diagram for OpenDDS::DCPS::ShmemDataLink:

[legend]Collaboration diagram for OpenDDS::DCPS::ShmemDataLink:

[legend]List of all members.

Public Member Functions
	ShmemDataLink (ShmemTransport *transport)
void	configure (ShmemInst *config)
void	send_strategy (ShmemSendStrategy *send_strategy)
void	receive_strategy (ShmemReceiveStrategy *recv_strategy)
ShmemInst *	config ()
bool	open (const std::string &peer_address)
void	control_received (ReceivedDataSample &sample)
std::string	local_address ()
std::string	peer_address ()
pid_t	peer_pid ()
ShmemAllocator *	local_allocator ()
ShmemAllocator *	peer_allocator ()
void	read ()
void	signal_semaphore ()
Protected Member Functions
virtual void	stop_i ()
Protected Attributes
ShmemInst *	config_
ShmemSendStrategy_rch	send_strategy_
	The transport send strategy object for this DataLink.
ShmemReceiveStrategy_rch	recv_strategy_
Private Attributes
std::string	peer_address_
ShmemAllocator *	peer_alloc_

---

Detailed Description

Definition at line 68 of file ShmemDataLink.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::ShmemDataLink::ShmemDataLink

(

ShmemTransport *

transport

)

[explicit]

Definition at line 23 of file ShmemDataLink.cpp.

  : DataLink(transport,
             0,     // priority
             false, // is_loopback,
             false) // is_active
  , config_(0)
  , peer_alloc_(0)
{
}

---

Member Function Documentation

ACE_INLINE ShmemInst * OpenDDS::DCPS::ShmemDataLink::config

(

)

Definition at line 30 of file ShmemDataLink.inl.

References config_.

Referenced by configure(), and OpenDDS::DCPS::ShmemSendStrategy::start_i().

{
  return this->config_;
}

ACE_INLINE void OpenDDS::DCPS::ShmemDataLink::configure

(

ShmemInst *

config

)

Definition at line 12 of file ShmemDataLink.inl.

References config(), and config_.

{
  this->config_ = config;
}

void OpenDDS::DCPS::ShmemDataLink::control_received

(

ReceivedDataSample &

sample

)

Definition at line 93 of file ShmemDataLink.cpp.

Referenced by OpenDDS::DCPS::ShmemReceiveStrategy::deliver_sample().

{
}

std::string OpenDDS::DCPS::ShmemDataLink::local_address

(

)

Definition at line 114 of file ShmemDataLink.cpp.

References OpenDDS::DCPS::DataLink::impl().

Referenced by OpenDDS::DCPS::ShmemReceiveStrategy::read().

{
  return static_rchandle_cast<ShmemTransport>(impl())->address();
}

ShmemAllocator * OpenDDS::DCPS::ShmemDataLink::local_allocator

(

)

Definition at line 108 of file ShmemDataLink.cpp.

References OpenDDS::DCPS::DataLink::impl().

Referenced by OpenDDS::DCPS::ShmemSendStrategy::send_bytes_i(), and OpenDDS::DCPS::ShmemSendStrategy::start_i().

{
  return static_rchandle_cast<ShmemTransport>(impl())->alloc();
}

bool OpenDDS::DCPS::ShmemDataLink::open

(

const std::string &

peer_address

)

Definition at line 34 of file ShmemDataLink.cpp.

References peer_address_, peer_alloc_, recv_strategy_, send_strategy_, OpenDDS::DCPS::DataLink::start(), stop_i(), and VDBG_LVL.

{
  peer_address_ = peer_address;
  const ACE_TString name = ACE_TEXT_CHAR_TO_TCHAR(peer_address.c_str());
  ShmemAllocator::MEMORY_POOL_OPTIONS alloc_opts;

#ifdef ACE_WIN32
  const bool use_opts = true;
  const ACE_TString name_under = name + ACE_TEXT('_');
  // Find max size of peer's pool so enough local address space is reserved.
  HANDLE fm = ACE_TEXT_CreateFileMapping(INVALID_HANDLE_VALUE, 0, PAGE_READONLY,
    0, ACE_DEFAULT_PAGEFILE_POOL_CHUNK, name_under.c_str());
  void* view;
  if (fm == 0 || (view = MapViewOfFile(fm, FILE_MAP_READ, 0, 0, 0)) == 0) {
    stop_i();
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ShmemDataLink::open: ")
                      ACE_TEXT("peer's shared memory area not found (%C)\n"),
                      peer_address.c_str()),
                     false);
  }
  // location of max_size_ in ctrl block: a size_t after two void*s
  const size_t* pmax = (const size_t*)(((void**)view) + 2);
  alloc_opts.max_size_ = *pmax;
  UnmapViewOfFile(view);
  CloseHandle(fm);
#else
  const bool use_opts = false;
#endif

  peer_alloc_ = new ShmemAllocator(name.c_str(), 0 /*lock_name*/,
                                   use_opts ? &alloc_opts : 0);

  if (-1 == peer_alloc_->find("Semaphore")) {
    stop_i();
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ShmemDataLink::open: ")
                      ACE_TEXT("peer's shared memory area not found (%C)\n"),
                      peer_address.c_str()),
                     false);
  }

  if (start(static_rchandle_cast<TransportSendStrategy>(send_strategy_),
            static_rchandle_cast<TransportStrategy>(recv_strategy_))
      != 0) {
    stop_i();
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ")
                      ACE_TEXT("ShmemDataLink::open: start failed!\n")),
                     false);
  }

  VDBG_LVL((LM_INFO, "(%P|%t) ShmemDataLink link %@ open to peer %C\n",
            this, peer_address_.c_str()), 1);

  return true;
}

ACE_INLINE std::string OpenDDS::DCPS::ShmemDataLink::peer_address

(

)

Definition at line 36 of file ShmemDataLink.inl.

References peer_address_.

Referenced by OpenDDS::DCPS::ShmemSendStrategy::start_i().

{
  return this->peer_address_;
}

ShmemAllocator* OpenDDS::DCPS::ShmemDataLink::peer_allocator

(

)

[inline]

Definition at line 89 of file ShmemDataLink.h.

Referenced by OpenDDS::DCPS::ShmemReceiveStrategy::read(), OpenDDS::DCPS::ShmemReceiveStrategy::receive_bytes(), and OpenDDS::DCPS::ShmemSendStrategy::start_i().

{ return peer_alloc_; }

pid_t OpenDDS::DCPS::ShmemDataLink::peer_pid

(

)

Definition at line 126 of file ShmemDataLink.cpp.

References peer_address_.

Referenced by OpenDDS::DCPS::ShmemSendStrategy::start_i().

{
  return std::atoi(peer_address_.c_str() + peer_address_.find('-') + 1);
}

void OpenDDS::DCPS::ShmemDataLink::read

(

)

[inline]

Definition at line 91 of file ShmemDataLink.h.

{ recv_strategy_->read(); }

ACE_INLINE void OpenDDS::DCPS::ShmemDataLink::receive_strategy

(

ShmemReceiveStrategy *

recv_strategy

)

Definition at line 24 of file ShmemDataLink.inl.

References recv_strategy_.

{
  this->recv_strategy_ = recv_strategy;
}

ACE_INLINE void OpenDDS::DCPS::ShmemDataLink::send_strategy

(

ShmemSendStrategy *

send_strategy

)

Definition at line 18 of file ShmemDataLink.inl.

References send_strategy_.

{
  this->send_strategy_ = send_strategy;
}

void OpenDDS::DCPS::ShmemDataLink::signal_semaphore

(

)

Definition at line 120 of file ShmemDataLink.cpp.

References OpenDDS::DCPS::DataLink::impl().

Referenced by OpenDDS::DCPS::ShmemReceiveStrategy::receive_bytes().

{
  return static_rchandle_cast<ShmemTransport>(impl())->signal_semaphore();
}

void OpenDDS::DCPS::ShmemDataLink::stop_i

(

)

[protected, virtual]

This announces the "stop" event to our subclass. The "stop" event will occur when this DataLink is handling a release_reservations() call and determines that it has just released all of the remaining reservations on this DataLink. The "stop" event will also occur when the TransportImpl is being shutdown() - we call stop_i() from our transport_shutdown() method to handle this case.

Reimplemented from OpenDDS::DCPS::DataLink.

Definition at line 98 of file ShmemDataLink.cpp.

References peer_alloc_.

Referenced by open().

{
  if (peer_alloc_) {
    peer_alloc_->release(0 /*don't close*/);
  }
  delete peer_alloc_;
  peer_alloc_ = 0;
}

---

Member Data Documentation

ShmemInst* OpenDDS::DCPS::ShmemDataLink::config_ [protected]

Definition at line 95 of file ShmemDataLink.h.

Referenced by config(), and configure().

std::string OpenDDS::DCPS::ShmemDataLink::peer_address_ [private]

Definition at line 103 of file ShmemDataLink.h.

Referenced by open(), peer_address(), and peer_pid().

ShmemAllocator* OpenDDS::DCPS::ShmemDataLink::peer_alloc_ [private]

Definition at line 104 of file ShmemDataLink.h.

Referenced by open(), and stop_i().

ShmemReceiveStrategy_rch OpenDDS::DCPS::ShmemDataLink::recv_strategy_ [protected]

Definition at line 98 of file ShmemDataLink.h.

Referenced by open(), and receive_strategy().

ShmemSendStrategy_rch OpenDDS::DCPS::ShmemDataLink::send_strategy_ [protected]

The transport send strategy object for this DataLink.

Reimplemented from OpenDDS::DCPS::DataLink.

Definition at line 97 of file ShmemDataLink.h.

Referenced by open(), and send_strategy().

---

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

• ShmemDataLink.h
• ShmemDataLink.cpp
• ShmemDataLink.inl

---