AbstractBufferMgr.h

Go to the documentation of this file.

/*
 * Copyright 2022 HEAVY.AI, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#pragma once

#include <boost/preprocessor.hpp>
#include "AbstractBuffer.h"
#include "Shared/types.h"

#define X_DEFINE_ENUM_WITH_STRING_CONVERSIONS_TOSTRING_CASE(r, data, elem) \
  case elem:                                                               \
    return BOOST_PP_STRINGIZE(elem);

#define DEFINE_ENUM_WITH_STRING_CONVERSIONS(name, enumerators)                    \
  enum name { BOOST_PP_SEQ_ENUM(enumerators) };                                   \
                                                                                  \
  inline const char* ToString(name v) {                                           \
    switch (v) {                                                                  \
      BOOST_PP_SEQ_FOR_EACH(                                                      \
          X_DEFINE_ENUM_WITH_STRING_CONVERSIONS_TOSTRING_CASE, name, enumerators) \
      default:                                                                    \
        return "[Unknown " BOOST_PP_STRINGIZE(name) "]";                          \
    }                                                                             \
  }

DEFINE_ENUM_WITH_STRING_CONVERSIONS(
    MgrType,
    (CACHING_FILE_MGR)(FILE_MGR)(CPU_MGR)(GPU_MGR)(GLOBAL_FILE_MGR)(PERSISTENT_STORAGE_MGR)(FOREIGN_STORAGE_MGR)(TIERED_CPU_MGR))

namespace Data_Namespace {

class AbstractBufferMgr {
 public:
  virtual ~AbstractBufferMgr() {}
  AbstractBufferMgr(const int deviceId) : device_id_(deviceId) {}

  // Chunk API
  virtual AbstractBuffer* createBuffer(const ChunkKey& key,
                                       const size_t pageSize = 0,
                                       const size_t initialSize = 0) = 0;
  virtual void deleteBuffer(
      const ChunkKey& key,
      const bool purge = true) = 0;  // purge param only used in FileMgr
  virtual void deleteBuffersWithPrefix(const ChunkKey& keyPrefix,
                                       const bool purge = true) = 0;
  virtual AbstractBuffer* getBuffer(const ChunkKey& key, const size_t numBytes = 0) = 0;
  virtual void fetchBuffer(const ChunkKey& key,
                           AbstractBuffer* destBuffer,
                           const size_t numBytes = 0) = 0;
  virtual AbstractBuffer* putBuffer(const ChunkKey& key,
                                    AbstractBuffer* srcBuffer,
                                    const size_t numBytes = 0) = 0;
  virtual void getChunkMetadataVecForKeyPrefix(ChunkMetadataVector& chunkMetadataVec,
                                               const ChunkKey& keyPrefix) = 0;

  virtual bool isBufferOnDevice(const ChunkKey& key) = 0;
  virtual std::string printSlabs() = 0;
  virtual size_t getMaxSize() = 0;
  virtual size_t getInUseSize() = 0;
  virtual size_t getAllocated() = 0;
  virtual bool isAllocationCapped() = 0;

  virtual void checkpoint() = 0;
  virtual void checkpoint(const int db_id, const int tb_id) = 0;
  virtual void removeTableRelatedDS(const int db_id, const int table_id) = 0;

  // Buffer API
  virtual AbstractBuffer* alloc(const size_t numBytes = 0) = 0;
  virtual void free(AbstractBuffer* buffer) = 0;
  virtual MgrType getMgrType() = 0;
  virtual std::string getStringMgrType() = 0;
  virtual size_t getNumChunks() = 0;
  inline int getDeviceId() { return device_id_; }

 protected:
  AbstractBufferMgr* parentMgr_;
  int device_id_;
};

}  // namespace Data_Namespace