#include <ReadBuffer.h>

Public Member Functions
std::pair< char *, std::size_t >	buffer ()

int	bufferIdentifier () const

const ReadBuffer &	operator= (const ReadBuffer &)=delete

const ReadBuffer &	operator= (ReadBuffer &&)=delete

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

	ReadBuffer (const ReadBuffer &)=delete

	ReadBuffer (ReadBuffer &&)=delete

Private Member Functions
bool	mustGetBufferAgain () const

Private Attributes
std::pair< char *, std::size_t >	buffer_

BufferInfo *	bufferInfo_

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

char	bufferOldIndex_

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

Detailed Description

Definition at line 34 of file ReadBuffer.h.

Constructor & Destructor Documentation

edm::shared_memory::ReadBuffer::ReadBuffer	(	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 39 of file ReadBuffer.h.

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

         : buffer_{nullptr, 0}, bufferInfo_{iBufferInfo}, bufferOldIndex_{3} {
       *bufferInfo_ = {0, 0};
       bufferNames_[0] = iUniqueName + buffer_names::kBuffer0;
       bufferNames_[1] = iUniqueName + buffer_names::kBuffer1;
     }

edm::shared_memory::ReadBuffer::ReadBuffer ( const ReadBuffer & )

delete

edm::shared_memory::ReadBuffer::ReadBuffer ( ReadBuffer && )

delete

Member Function Documentation

std::pair<char*, std::size_t> edm::shared_memory::ReadBuffer::buffer ( )

inline

Definition at line 54 of file ReadBuffer.h.

References buffer_, bufferInfo_, bufferNames_, bufferOldIndex_, edm::shared_memory::BufferInfo::index_, edm::shared_memory::buffer_names::kBuffer, mustGetBufferAgain(), and sm_.

                                        {
       if (mustGetBufferAgain()) {
         using namespace boost::interprocess;
         sm_ = std::make_unique<managed_shared_memory>(open_only, bufferNames_[bufferInfo_->index_].c_str());
         buffer_ = sm_->find<char>(buffer_names::kBuffer);
         bufferOldIndex_ = bufferInfo_->index_;
       }
       return buffer_;
     }