#include <CpuBufferMgr.h>

Inheritance diagram for Buffer_Namespace::CpuBufferMgr:

Collaboration diagram for Buffer_Namespace::CpuBufferMgr:

Public Member Functions
	CpuBufferMgr (const int device_id, const size_t max_buffer_size, CudaMgr_Namespace::CudaMgr cuda_mgr, const size_t buffer_alloc_increment=2147483648, const size_t page_size=512, AbstractBufferMgr parent_mgr=0)

MgrType	getMgrType () override

std::string	getStringMgrType () override

	~CpuBufferMgr () override

Public Member Functions inherited from Buffer_Namespace::BufferMgr
	BufferMgr (const int device_id, const size_t max_buffer_size, const size_t max_slab_size=2147483648, const size_t page_size=512, AbstractBufferMgr *parent_mgr=0)
	Constructs a BufferMgr object that allocates memSize bytes. More...

	~BufferMgr () override
	Destructor. More...

void	reinit ()

void	clear ()

std::string	printSlab (size_t slab_num)

std::string	printSlabs () override

void	clearSlabs () override

std::string	printMap ()

void	printSegs ()

std::string	printSeg (BufferList::iterator &seg_it)

std::string	keyToString (const ChunkKey &key)

size_t	getInUseSize () override

size_t	getMaxSize () override

size_t	getAllocated () override

size_t	getMaxBufferSize ()

size_t	getMaxSlabSize ()

size_t	getPageSize ()

bool	isAllocationCapped () override

const std::vector< BufferList > &	getSlabSegments ()

AbstractBuffer *	createBuffer (const ChunkKey &key, const size_t page_size=0, const size_t initial_size=0) override
	Creates a chunk with the specified key and page size. More...

void	deleteBuffer (const ChunkKey &key, const bool purge=true) override
	Deletes the chunk with the specified key. More...

void	deleteBuffersWithPrefix (const ChunkKey &key_prefix, const bool purge=true) override

AbstractBuffer *	getBuffer (const ChunkKey &key, const size_t num_bytes=0) override
	Returns the a pointer to the chunk with the specified key. More...

bool	isBufferOnDevice (const ChunkKey &key) override
	Puts the contents of d into the Buffer with ChunkKey key. More...

void	fetchBuffer (const ChunkKey &key, AbstractBuffer *dest_buffer, const size_t num_bytes=0) override

AbstractBuffer *	putBuffer (const ChunkKey &key, AbstractBuffer *d, const size_t num_bytes=0) override

void	checkpoint () override

void	checkpoint (const int db_id, const int tb_id) override

AbstractBuffer *	alloc (const size_t num_bytes=0) override
	client is responsible for deleting memory allocated for b->mem_ More...

void	free (AbstractBuffer *buffer) override

size_t	size ()
	Returns the total number of bytes allocated. More...

size_t	getNumChunks () override

BufferList::iterator	reserveBuffer (BufferList::iterator &seg_it, const size_t num_bytes)

void	getChunkMetadataVec (std::vector< std::pair< ChunkKey, ChunkMetadata >> &chunk_metadata_vec) override

void	getChunkMetadataVecForKeyPrefix (std::vector< std::pair< ChunkKey, ChunkMetadata >> &chunk_metadata_vec, const ChunkKey &key_prefix) override

Private Member Functions
void	addSlab (const size_t slab_size) override

void	freeAllMem () override

void	allocateBuffer (BufferList::iterator segment_iter, const size_t page_size, const size_t initial_size) override

Private Attributes
CudaMgr_Namespace::CudaMgr *	cuda_mgr_

Additional Inherited Members
Protected Attributes inherited from Buffer_Namespace::BufferMgr
std::vector< int8_t * >	slabs_

std::vector< BufferList >	slab_segments_

size_t	page_size_

Detailed Description

Definition at line 27 of file CpuBufferMgr.h.

Constructor & Destructor Documentation

Buffer_Namespace::CpuBufferMgr::CpuBufferMgr	(	const int	device_id,
		const size_t	max_buffer_size,
		CudaMgr_Namespace::CudaMgr *	cuda_mgr,
		const size_t	buffer_alloc_increment = `2147483648`,
		const size_t	page_size = `512`,
		AbstractBufferMgr *	parent_mgr = `0`
	)

Definition at line 24 of file CpuBufferMgr.cpp.

30 : BufferMgr(device_id, max_buffer_size, buffer_alloc_increment, page_size, parent_mgr)

31 , cuda_mgr_(cuda_mgr) {}

Buffer_Namespace::CpuBufferMgr::cuda_mgr_

CudaMgr_Namespace::CudaMgr * cuda_mgr_

Definition: CpuBufferMgr.h:46

Buffer_Namespace::BufferMgr::BufferMgr

BufferMgr(const int device_id, const size_t max_buffer_size, const size_t max_slab_size=2147483648, const size_t page_size=512, AbstractBufferMgr *parent_mgr=0)

Constructs a BufferMgr object that allocates memSize bytes.

Definition: BufferMgr.cpp:47

Buffer_Namespace::CpuBufferMgr::~CpuBufferMgr ( )

override

Definition at line 33 of file CpuBufferMgr.cpp.

References freeAllMem().

                             {
   freeAllMem();
 }

Here is the call graph for this function:

Member Function Documentation

void Buffer_Namespace::CpuBufferMgr::addSlab ( const size_t slab_size )

overrideprivatevirtual

Implements Buffer_Namespace::BufferMgr.

Definition at line 37 of file CpuBufferMgr.cpp.

References Buffer_Namespace::BufferMgr::page_size_, Buffer_Namespace::BufferMgr::slab_segments_, and Buffer_Namespace::BufferMgr::slabs_.

                                                  {
   slabs_.resize(slabs_.size() + 1);
   try {
     slabs_.back() = new int8_t[slab_size];
   } catch (std::bad_alloc&) {
     slabs_.resize(slabs_.size() - 1);
     throw FailedToCreateSlab(slab_size);
   }
   slab_segments_.resize(slab_segments_.size() + 1);
   slab_segments_[slab_segments_.size() - 1].push_back(
       BufferSeg(0, slab_size / page_size_));
 }

void Buffer_Namespace::CpuBufferMgr::allocateBuffer	(	BufferList::iterator	segment_iter,
		const size_t	page_size,
		const size_t	initial_size
	)

overrideprivatevirtual

Implements Buffer_Namespace::BufferMgr.

Definition at line 56 of file CpuBufferMgr.cpp.

References cuda_mgr_.

                                                              {
   new CpuBuffer(this,
                 seg_it,
                 device_id_,
                 cuda_mgr_,
                 page_size,
                 initial_size);  // this line is admittedly a bit weird but
                                 // the segment iterator passed into buffer
                                 // takes the address of the new Buffer in its
                                 // buffer member
 }

void Buffer_Namespace::CpuBufferMgr::freeAllMem ( )

overrideprivatevirtual

Implements Buffer_Namespace::BufferMgr.

Definition at line 50 of file CpuBufferMgr.cpp.

References Buffer_Namespace::BufferMgr::slabs_.

Referenced by ~CpuBufferMgr().

                               {
   for (auto buf_it = slabs_.begin(); buf_it != slabs_.end(); ++buf_it) {
     delete[] * buf_it;
   }
 }

Here is the caller graph for this function:

MgrType Buffer_Namespace::CpuBufferMgr::getMgrType ( )

inlineoverride

Definition at line 35 of file CpuBufferMgr.h.

35 { return CPU_MGR; }

std::string Buffer_Namespace::CpuBufferMgr::getStringMgrType ( )

inlineoverride

Definition at line 36 of file CpuBufferMgr.h.

36 { return ToString(CPU_MGR); }

Member Data Documentation

CudaMgr_Namespace::CudaMgr* Buffer_Namespace::CpuBufferMgr::cuda_mgr_

private

Definition at line 46 of file CpuBufferMgr.h.

Referenced by allocateBuffer().

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

/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/BufferMgr/CpuBufferMgr/CpuBufferMgr.h
/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/BufferMgr/CpuBufferMgr/CpuBufferMgr.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation