#include <WriteBuffer.h>

Public Member Functions
void	copyToBuffer (const char *iStart, std::size_t iLength)

const WriteBuffer &	operator= (const WriteBuffer &)=delete

const WriteBuffer &	operator= (WriteBuffer &&)=delete

	WriteBuffer (std::string const &iUniqueName, BufferInfo *iBufferInfo)

	WriteBuffer (const WriteBuffer &)=delete

	WriteBuffer (WriteBuffer &&)=delete

	~WriteBuffer ()

Private Member Functions
void	growBuffer (std::size_t iLength)

Private Attributes
char *	buffer_

BufferInfo *	bufferInfo_

std::array< std::string, 2 >	bufferNames_

std::size_t	bufferSize_

std::unique_ptr< boost::interprocess::managed_shared_memory >	sm_

Detailed Description

Definition at line 37 of file WriteBuffer.h.

Constructor & Destructor Documentation

edm::shared_memory::WriteBuffer::WriteBuffer	(	std::string const &	iUniqueName,
		BufferInfo *	iBufferInfo
	)

inline

iUniqueName : must be unique for all processes running on a system. iBufferInfo : is a pointer to a shared_memory address where the same address needs to be shared by ReadBuffer and WriteBuffer.

Definition at line 43 of file WriteBuffer.h.

References buffer_, bufferInfo_, bufferNames_, edm::shared_memory::buffer_names::kBuffer0, edm::shared_memory::buffer_names::kBuffer1, operator=(), and ~WriteBuffer().

         : bufferSize_{0}, buffer_{nullptr}, bufferInfo_{iBufferInfo} {
       bufferNames_[0] = iUniqueName + buffer_names::kBuffer0;
       bufferNames_[1] = iUniqueName + buffer_names::kBuffer1;
       assert(bufferInfo_);
     }

edm::shared_memory::WriteBuffer::WriteBuffer ( const WriteBuffer & )

delete

edm::shared_memory::WriteBuffer::WriteBuffer ( WriteBuffer && )

delete

WriteBuffer::~WriteBuffer ( )

Definition at line 31 of file WriteBuffer.cc.

References bufferInfo_, bufferNames_, edm::shared_memory::BufferInfo::index_, edm::shared_memory::buffer_names::kBuffer, MatrixUtil::remove(), and sm_.

Referenced by WriteBuffer().

                           {
   if (sm_) {
     sm_->destroy<char>(buffer_names::kBuffer);
     sm_.reset();
     boost::interprocess::shared_memory_object::remove(bufferNames_[bufferInfo_->index_].c_str());
   }
 }

Member Function Documentation

void edm::shared_memory::WriteBuffer::copyToBuffer	(	const char *	iStart,
		std::size_t	iLength
	)

inline

Definition at line 57 of file WriteBuffer.h.

References buffer_, bufferSize_, popcon2dropbox::copy(), and growBuffer().

                                                              {
       if (iLength > bufferSize_) {
         growBuffer(iLength);
       }
       std::copy(iStart, iStart + iLength, buffer_);
     }

void WriteBuffer::growBuffer ( std::size_t iLength )

private

Definition at line 41 of file WriteBuffer.cc.

References buffer_, bufferInfo_, bufferNames_, bufferSize_, edm::shared_memory::BufferInfo::identifier_, edm::shared_memory::BufferInfo::index_, edm::shared_memory::buffer_names::kBuffer, MatrixUtil::remove(), and sm_.

Referenced by copyToBuffer().

                                               {
   int newBuffer = (bufferInfo_->index_ + 1) % 2;
   if (sm_) {
     sm_->destroy<char>(buffer_names::kBuffer);
     sm_.reset();
     boost::interprocess::shared_memory_object::remove(bufferNames_[bufferInfo_->index_].c_str());
   }
   sm_ = std::make_unique<boost::interprocess::managed_shared_memory>(
       boost::interprocess::open_or_create, bufferNames_[newBuffer].c_str(), iLength + 1024);
   assert(sm_.get());
   bufferSize_ = iLength;
   bufferInfo_->index_ = newBuffer;
   bufferInfo_->identifier_ = bufferInfo_->identifier_ + 1;
   buffer_ = sm_->construct<char>(buffer_names::kBuffer)[iLength](0);
   assert(buffer_);
 }