#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_pool_size, CudaMgr_Namespace::CudaMgr cuda_mgr, const size_t min_slab_size, const size_t max_slab_size, const size_t page_size, AbstractBufferMgr parent_mgr=nullptr)

	~CpuBufferMgr ()

MgrType	getMgrType () override

std::string	getStringMgrType () override

Public Member Functions inherited from Buffer_Namespace::BufferMgr
	BufferMgr (const int device_id, const size_t max_buffer_size, const size_t min_slab_size, const size_t max_slab_size, const size_t page_size, 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

void	removeTableRelatedDS (const int db_id, const int table_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 (ChunkMetadataVector &chunk_metadata_vec) override

void	getChunkMetadataVecForKeyPrefix (ChunkMetadataVector &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_

std::unique_ptr< Arena >	allocator_

Additional Inherited Members
Protected Attributes inherited from Buffer_Namespace::BufferMgr
const size_t	max_buffer_pool_size_

const size_t	min_slab_size_
	max number of bytes allocated for the buffer pool More...

const size_t	max_slab_size_

const size_t	page_size_

std::vector< int8_t * >	slabs_

std::vector< BufferList >	slab_segments_

Detailed Description

Definition at line 29 of file CpuBufferMgr.h.

Constructor & Destructor Documentation

Buffer_Namespace::CpuBufferMgr::CpuBufferMgr	(	const int	device_id,
		const size_t	max_buffer_pool_size,
		CudaMgr_Namespace::CudaMgr *	cuda_mgr,
		const size_t	min_slab_size,
		const size_t	max_slab_size,
		const size_t	page_size,
		AbstractBufferMgr *	parent_mgr = `nullptr`
	)

inline

Definition at line 31 of file CpuBufferMgr.h.

       : BufferMgr(device_id,
                   max_buffer_pool_size,
                   min_slab_size,
                   max_slab_size,
                   page_size,
                   parent_mgr)
       , cuda_mgr_(cuda_mgr)
       , allocator_(std::make_unique<Arena>(/*min_block_size=*/max_slab_size +
                                            kArenaBlockOverhead)) {}

Buffer_Namespace::CpuBufferMgr::~CpuBufferMgr ( )

inline

Definition at line 48 of file CpuBufferMgr.h.

                   {
     /* the destruction of the allocator automatically frees all memory */
   }

Member Function Documentation

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

overrideprivatevirtual

Implements Buffer_Namespace::BufferMgr.

Definition at line 25 of file CpuBufferMgr.cpp.

References allocator_, CHECK(), Buffer_Namespace::BufferMgr::page_size_, Buffer_Namespace::BufferMgr::slab_segments_, and Buffer_Namespace::BufferMgr::slabs_.

                                                  {
   CHECK(allocator_);
   slabs_.resize(slabs_.size() + 1);
   try {
     slabs_.back() = reinterpret_cast<int8_t*>(allocator_->allocate(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_));
 }

Here is the call graph for this function:

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 44 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 39 of file CpuBufferMgr.cpp.

References allocator_, CHECK(), kArenaBlockOverhead, and Buffer_Namespace::BufferMgr::max_slab_size_.

                               {
   CHECK(allocator_);
   allocator_.reset(new Arena(max_slab_size_ + kArenaBlockOverhead));
 }

Here is the call graph for this function:

MgrType Buffer_Namespace::CpuBufferMgr::getMgrType ( )

inlineoverride

Definition at line 52 of file CpuBufferMgr.h.

52 { return CPU_MGR; }

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

inlineoverride

Definition at line 53 of file CpuBufferMgr.h.

53 { return ToString(CPU_MGR); }

Member Data Documentation

std::unique_ptr<Arena> Buffer_Namespace::CpuBufferMgr::allocator_

private

Definition at line 63 of file CpuBufferMgr.h.

Referenced by addSlab(), and freeAllMem().

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

private

Definition at line 62 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