SharedMemoryPort.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef SHAREDMEMORYPORT_H
#define SHAREDMEMORYPORT_H


#include <rtm/Manager.h>
#include <rtm/idl/SharedMemorySkel.h>
#include <coil/SharedMemory.h>

#define DEFAULT_DATA_SIZE 8
#define DEFAULT_SHARED_MEMORY_SIZE 2097152

namespace RTC
{
  class SharedMemoryPort
      : public virtual POA_OpenRTM::PortSharedMemory,
      public virtual PortableServer::RefCountServantBase
  {
  public:
      SharedMemoryPort();
      virtual ~SharedMemoryPort();
    virtual int string_to_MemorySize(std::string size_str);
    virtual void create_memory(::CORBA::ULongLong memory_size, const char *shm_address)
        throw (CORBA::SystemException);
    virtual void open_memory(::CORBA::ULongLong memory_size, const char *shm_address)
        throw (CORBA::SystemException);
    virtual void close_memory(::CORBA::Boolean unlink = false)
        throw (CORBA::SystemException);
    virtual void write(cdrMemoryStream& data);
    virtual void read(cdrMemoryStream& data);
    virtual void setInterface(::OpenRTM::PortSharedMemory_ptr sm)
        throw (CORBA::SystemException);
    virtual void setEndian(::CORBA::Boolean endian)
        throw (CORBA::SystemException);
    virtual ::OpenRTM::PortStatus put()
      throw (CORBA::SystemException);
    virtual ::OpenRTM::PortStatus get()
      throw (CORBA::SystemException);

    virtual ::OpenRTM::PortSharedMemory_ptr getObjRef();

 protected:
    //mutable Logger rtclog;
    ::OpenRTM::PortSharedMemory_var m_smInterface;
    bool m_endian;
    coil::SharedMemory m_shmem;
    //::OpenRTM::PortSharedMemory_var m_objref;

    
  };  // class SharedMemoryPort
};  // namespace RTC

#ifdef WIN32
#pragma warning( default : 4290 )
#endif

#endif // RTC_RTOBJECT