Packages

rocksdb

2.0.0
3.1.2 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
64 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb db db_impl db_impl_follower.h
Raw

deps/rocksdb/db/db_impl/db_impl_follower.h 

//  Copyright (c) 2024-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).



#pragma once



#include <string>

#include <vector>



#include "db/db_impl/db_impl.h"

#include "db/db_impl/db_impl_secondary.h"

#include "logging/logging.h"

#include "port/port.h"



namespace ROCKSDB_NAMESPACE {



class DBImplFollower : public DBImplSecondary {

 public:

  DBImplFollower(const DBOptions& db_options, std::unique_ptr<Env>&& env,

                 const std::string& dbname, std::string src_path);

  ~DBImplFollower();



  Status Close() override;



 protected:

  bool OwnTablesAndLogs() const override {

    // TODO: Change this to true once we've properly implemented file

    // deletion for the read scaling case

    return true;

  }



  Status Recover(const std::vector<ColumnFamilyDescriptor>& column_families,

                 bool /*readonly*/, bool /*error_if_wal_file_exists*/,

                 bool /*error_if_data_exists_in_wals*/,

                 bool /*is_retry*/ = false, uint64_t* = nullptr,

                 RecoveryContext* /*recovery_ctx*/ = nullptr,

                 bool* /*can_retry*/ = nullptr) override;



 private:

  friend class DB;



  Status TryCatchUpWithLeader();

  void PeriodicRefresh();



  std::unique_ptr<Env> env_guard_;

  std::unique_ptr<port::Thread> catch_up_thread_;

  std::atomic<bool> stop_requested_;

  std::string src_path_;

  port::Mutex mu_;

  port::CondVar cv_;

  std::unique_ptr<std::list<uint64_t>::iterator> pending_outputs_inserted_elem_;

};

}  // namespace ROCKSDB_NAMESPACE