TritonCpuShmResource< IO > Class Template Reference

#include <TritonData.h>

Inheritance diagram for TritonCpuShmResource< IO >:

Public Member Functions
void	close () override
void	copyInput (const void *values, size_t offset, unsigned entry) override
void	copyOutput () override
	TritonCpuShmResource (TritonData< IO > *data, const std::string &name, size_t size)
	~TritonCpuShmResource () override
Public Member Functions inherited from TritonMemResource< IO >
uint8_t *	addr ()
void	closeSafe ()
virtual void	set ()
size_t	size () const
	TritonMemResource (TritonData< IO > *data, const std::string &name, size_t size)
virtual	~TritonMemResource ()

Protected Attributes
size_t	sizeOrig_
Protected Attributes inherited from TritonMemResource< IO >
uint8_t *	addr_
bool	closed_
TritonData< IO > *	data_
std::string	name_
size_t	size_

Detailed Description

template<typename IO>
class TritonCpuShmResource< IO >

Definition at line 27 of file TritonData.h.

Constructor & Destructor Documentation

TritonCpuShmResource()

template<typename IO >

TritonCpuShmResource< IO >::TritonCpuShmResource	(	TritonData< IO > *	data,
		const std::string &	name,
		size_t	size
	)

Definition at line 78 of file TritonMemResource.cc.

References TritonMemResource< IO >::addr_, TritonCpuShmResource< IO >::close(), ALPAKA_ACCELERATOR_NAMESPACE::brokenline::constexpr(), TritonMemResource< IO >::data_, Exception, TritonMemResource< IO >::name_, hltrates_dqm_sourceclient-live_cfg::offset, TritonMemResource< IO >::size_, to_string(), and TRITON_THROW_IF_ERROR.

    : TritonMemResource<IO>(data, name, size), sizeOrig_(size) {
  //mmap of size zero is required to fail by POSIX, but still need to have some shared memory region available for Triton
  this->size_ = std::max<size_t>(this->size_, 1);

  //get shared memory region descriptor
  int shm_fd = shm_open(this->name_.c_str(), O_RDWR | O_CREAT | O_EXCL, S_IRUSR | S_IWUSR);
  if (shm_fd == -1)
    throw cms::Exception("TritonError") << "unable to get shared memory descriptor for key: " + this->name_;

  //extend shared memory object
  int res = ftruncate(shm_fd, this->size_);
  if (res == -1)
    throw cms::Exception("TritonError") << "unable to initialize shared memory key " + this->name_ +
                                               " to requested size: " + std::to_string(this->size_);

  //map to process address space
  constexpr size_t offset(0);
  this->addr_ = (uint8_t*)mmap(nullptr, this->size_, PROT_READ | PROT_WRITE, MAP_SHARED, shm_fd, offset);
  if (this->addr_ == MAP_FAILED)
    throw cms::Exception("TritonError") << "unable to map to process address space for shared memory key: " +
                                               this->name_;

  //close descriptor
  if (::close(shm_fd) == -1)
    throw cms::Exception("TritonError") << "unable to close descriptor for shared memory key: " + this->name_;

  TRITON_THROW_IF_ERROR(this->data_->client()->RegisterSystemSharedMemory(this->name_, this->name_, this->size_),
                        "unable to register shared memory region: " + this->name_,
                        true);
}

~TritonCpuShmResource()

template<typename IO >

TritonCpuShmResource< IO >::~TritonCpuShmResource ( )

override

Definition at line 111 of file TritonMemResource.cc.

                                                {
  this->closeSafe();
}

Member Function Documentation

close()

template<typename IO >

void TritonCpuShmResource< IO >::close ( void  )

overridevirtual

Reimplemented from TritonMemResource< IO >.

Definition at line 116 of file TritonMemResource.cc.

References Exception, and TRITON_THROW_IF_ERROR.

Referenced by esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), and TritonCpuShmResource< IO >::TritonCpuShmResource().

                                     {
  if (this->closed_)
    return;

  TRITON_THROW_IF_ERROR(this->data_->client()->UnregisterSystemSharedMemory(this->name_),
                        "unable to unregister shared memory region: " + this->name_,
                        true);

  //unmap
  int tmp_fd = munmap(this->addr_, this->size_);
  if (tmp_fd == -1)
    throw cms::Exception("TritonError") << "unable to munmap for shared memory key: " << this->name_;

  //unlink
  int shm_fd = shm_unlink(this->name_.c_str());
  if (shm_fd == -1)
    throw cms::Exception("TritonError") << "unable to unlink for shared memory key: " << this->name_;

  this->closed_ = true;
}

copyInput()

void TritonInputCpuShmResource::copyInput ( const void *  values, size_t  offset, unsigned  entry  )

inlineoverridevirtual

Reimplemented from TritonMemResource< IO >.

Definition at line 54 of file TritonMemResource.h.

{}

copyOutput()

void TritonOutputCpuShmResource::copyOutput ( )

inlineoverridevirtual

Reimplemented from TritonMemResource< IO >.

Definition at line 55 of file TritonMemResource.h.

{}

Member Data Documentation

sizeOrig_

template<typename IO >

size_t TritonCpuShmResource< IO >::sizeOrig_

protected

Definition at line 58 of file TritonMemResource.h.