Packages

rocksdb

0.26.0
3.1.1 3.1.0 3.0.0 2.6.2 2.6.1 retired 2.6.0 retired 2.5.0 2.4.1 2.4.0 2.3.0 2.2.0 2.1.0 2.0.0 1.9.0 1.8.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.26.2 0.26.1 0.26.0 0.25.0 0.24.0 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.21.0 0.20.1 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0

RocksDB for Erlang

HexDocs

Current section

Files

Jump to
Readme
63 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb util allocator.h
Raw

deps/rocksdb/util/allocator.h 

//  Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.

//  This source code is licensed under both the GPLv2 (found in the

//  COPYING file in the root directory) and Apache 2.0 License

//  (found in the LICENSE.Apache file in the root directory).

//

// Copyright (c) 2011 The LevelDB Authors. All rights reserved.

// Use of this source code is governed by a BSD-style license that can be

// found in the LICENSE file. See the AUTHORS file for names of contributors.

//

// Abstract interface for allocating memory in blocks. This memory is freed

// when the allocator object is destroyed. See the Arena class for more info.



#pragma once

#include <cerrno>

#include <cstddef>

#include "rocksdb/write_buffer_manager.h"



namespace rocksdb {



class Logger;



class Allocator {

 public:

  virtual ~Allocator() {}



  virtual char* Allocate(size_t bytes) = 0;

  virtual char* AllocateAligned(size_t bytes, size_t huge_page_size = 0,

                                Logger* logger = nullptr) = 0;



  virtual size_t BlockSize() const = 0;

};



class AllocTracker {

 public:

  explicit AllocTracker(WriteBufferManager* write_buffer_manager);

  ~AllocTracker();

  void Allocate(size_t bytes);

  // Call when we're finished allocating memory so we can free it from

  // the write buffer's limit.

  void DoneAllocating();



  void FreeMem();



  bool is_freed() const { return write_buffer_manager_ == nullptr || freed_; }



 private:

  WriteBufferManager* write_buffer_manager_;

  std::atomic<size_t> bytes_allocated_;

  bool done_allocating_;

  bool freed_;



  // No copying allowed

  AllocTracker(const AllocTracker&);

  void operator=(const AllocTracker&);

};



}  // namespace rocksdb