novaddt::MessageBuffer Class Reference

#include "/cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N21-01-24/SuperNovaDDT/online/MessageBuffer.h"

Public Types
using	TimeType = uint64_t
using	DataType = uint64_t
using	Point = std::pair< TimeType, DataType >
using	PointAllocator = boost::interprocess::allocator< Point, boost::interprocess::managed_shared_memory::segment_manager >
	a point is pair (timestamp,nclusters) More...
using	PointVector = boost::interprocess::vector< Point, PointAllocator >
using	interprocess_mutex = boost::interprocess::interprocess_mutex
using	scoped_lock = boost::interprocess::scoped_lock< interprocess_mutex >

Public Member Functions
	MessageBuffer (const char *shmemName, const char *bufName, size_t Capacity=10)
	~MessageBuffer ()
void	addPoint (Point p)
bool	isFull ()
size_t	size ()
size_t	capacity ()
void	clear ()
nsnmessages::NSNPackedMessage	makeMessage ()
scoped_lock	ScopedLock ()

Private Attributes
novaddt::sm_cleaner	_sm_cleaner
boost::interprocess::managed_shared_memory	_segment
const PointAllocator	_allocator
PointVector *	_buffer
interprocess_mutex *	_mutex
unsigned *	_counter
size_t	_capacity

Detailed Description

Definition at line 33 of file MessageBuffer.h.

Member Typedef Documentation

using novaddt::MessageBuffer::DataType = uint64_t

Definition at line 38 of file MessageBuffer.h.

using novaddt::MessageBuffer::interprocess_mutex = boost::interprocess::interprocess_mutex

Definition at line 43 of file MessageBuffer.h.

using novaddt::MessageBuffer::Point = std::pair<TimeType, DataType>

Definition at line 39 of file MessageBuffer.h.

using novaddt::MessageBuffer::PointAllocator = boost::interprocess::allocator <Point,boost::interprocess::managed_shared_memory::segment_manager>

a point is pair (timestamp,nclusters)

Definition at line 41 of file MessageBuffer.h.

using novaddt::MessageBuffer::PointVector = boost::interprocess::vector<Point, PointAllocator>

Definition at line 42 of file MessageBuffer.h.

using novaddt::MessageBuffer::scoped_lock = boost::interprocess::scoped_lock<interprocess_mutex>

Definition at line 44 of file MessageBuffer.h.

using novaddt::MessageBuffer::TimeType = uint64_t

a class to manage point buffer in shared memory When 10 points are accumulated, we can form an NSNPackedMessage

Definition at line 37 of file MessageBuffer.h.

Constructor & Destructor Documentation

novaddt::MessageBuffer::MessageBuffer ( const char *  shmemName, const char *  bufName, size_t  Capacity = 10  )

inline

Definition at line 46 of file MessageBuffer.h.

References om::cout, and allTimeWatchdog::endl.

                                                                                    :
            _sm_cleaner(shmemName),
            _segment(boost::interprocess::open_or_create, shmemName, 65536),
            _allocator(_segment.get_segment_manager()),
            _buffer(_segment.find_or_construct<PointVector>(bufName)(_allocator)),
            _mutex(_segment.find_or_construct<interprocess_mutex>("mtx")()),
            _capacity(Capacity)
        {
            scoped_lock lock(*_mutex);
            //set buffer length
            _buffer->reserve(_capacity);
            boost::interprocess::managed_shared_memory::shrink_to_fit(shmemName);
            std::cout<<"Open messageBuffer \""<<bufName<<"\" of size= "<<_segment.get_size()<<std::endl;
        }

novaddt::MessageBuffer::~MessageBuffer ( )

inline

Definition at line 61 of file MessageBuffer.h.

                        {
                   }

Member Function Documentation

void novaddt::MessageBuffer::addPoint ( Point  p )

inline

Definition at line 64 of file MessageBuffer.h.

Referenced by novaddt::SNMessageService::PushPoint().

                              {
            if(isFull())
                throw std::logic_error("Trying to fill full buffer");
            _buffer->push_back(p);
        }

size_t novaddt::MessageBuffer::capacity ( )

inline

Definition at line 71 of file MessageBuffer.h.

{return _capacity;}

void novaddt::MessageBuffer::clear ( )

inline

Definition at line 72 of file MessageBuffer.h.

Referenced by novaddt::SNMessageService::PushPoint().

{_buffer->clear();}

bool novaddt::MessageBuffer::isFull ( )

inline

Definition at line 69 of file MessageBuffer.h.

Referenced by novaddt::SNMessageService::PushPoint().

{return (_buffer->size()>=_capacity);}

nsnmessages::NSNPackedMessage novaddt::MessageBuffer::makeMessage ( )

inline

Definition at line 74 of file MessageBuffer.h.

References MECModelEnuComparisons::i, and m.

Referenced by novaddt::SNMessageService::PushPoint().

                                                 {
            //prepare a message to be sent
            nsnmessages::NSNPackedMessage m;
            for(size_t i=0;i<_capacity;++i){
                Point p=_buffer->at(i);
                m.time[i]=p.first;
                m.hits[i]=p.second;
            }
            return m;
        }

scoped_lock novaddt::MessageBuffer::ScopedLock ( )

inline

Definition at line 84 of file MessageBuffer.h.

Referenced by novaddt::SNMessageService::PushPoint().

{return scoped_lock(*_mutex);}

size_t novaddt::MessageBuffer::size ( )

inline

Definition at line 70 of file MessageBuffer.h.

{return _buffer->size();}

Member Data Documentation

const PointAllocator novaddt::MessageBuffer::_allocator

private

Definition at line 88 of file MessageBuffer.h.

PointVector* novaddt::MessageBuffer::_buffer

private

Definition at line 89 of file MessageBuffer.h.

Referenced by srt_ntide_dump_file.ide_dump_file::get_line(), and srt_ntide_dump_file.ide_dump_file::load_buffer().

size_t novaddt::MessageBuffer::_capacity

private

Definition at line 92 of file MessageBuffer.h.

unsigned* novaddt::MessageBuffer::_counter

private

Definition at line 91 of file MessageBuffer.h.

interprocess_mutex* novaddt::MessageBuffer::_mutex

private

Definition at line 90 of file MessageBuffer.h.

boost::interprocess::managed_shared_memory novaddt::MessageBuffer::_segment

private

Definition at line 87 of file MessageBuffer.h.

novaddt::sm_cleaner novaddt::MessageBuffer::_sm_cleaner

private

Definition at line 86 of file MessageBuffer.h.

---

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

• /cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N21-01-24/SuperNovaDDT/online/MessageBuffer.h