OmniSciDB  1dac507f6e
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Buffer_Namespace::CpuBufferMgr Class Reference

#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 ()
 
AbstractBuffercreateBuffer (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
 
AbstractBuffergetBuffer (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
 
AbstractBufferputBuffer (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
 
AbstractBufferalloc (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::CudaMgrcuda_mgr_
 

Additional Inherited Members

- Protected Attributes inherited from Buffer_Namespace::BufferMgr
std::vector< int8_t * > slabs_
 
std::vector< BufferListslab_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) {}
CudaMgr_Namespace::CudaMgr * cuda_mgr_
Definition: CpuBufferMgr.h:46
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().

33  {
34  freeAllMem();
35 }

+ 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_.

37  {
38  slabs_.resize(slabs_.size() + 1);
39  try {
40  slabs_.back() = new int8_t[slab_size];
41  } catch (std::bad_alloc&) {
42  slabs_.resize(slabs_.size() - 1);
43  throw FailedToCreateSlab(slab_size);
44  }
45  slab_segments_.resize(slab_segments_.size() + 1);
46  slab_segments_[slab_segments_.size() - 1].push_back(
47  BufferSeg(0, slab_size / page_size_));
48 }
std::vector< BufferList > slab_segments_
Definition: BufferMgr.h:177
std::vector< int8_t * > slabs_
Definition: BufferMgr.h:175
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_.

58  {
59  new CpuBuffer(this,
60  seg_it,
61  device_id_,
62  cuda_mgr_,
63  page_size,
64  initial_size); // this line is admittedly a bit weird but
65  // the segment iterator passed into buffer
66  // takes the address of the new Buffer in its
67  // buffer member
68 }
CudaMgr_Namespace::CudaMgr * cuda_mgr_
Definition: CpuBufferMgr.h:46
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().

50  {
51  for (auto buf_it = slabs_.begin(); buf_it != slabs_.end(); ++buf_it) {
52  delete[] * buf_it;
53  }
54 }
std::vector< int8_t * > slabs_
Definition: BufferMgr.h:175

+ 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: