Packages

rocksdb

1.6.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 monitoring stats_dump_scheduler.h
Raw

deps/rocksdb/monitoring/stats_dump_scheduler.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).



#pragma once



#ifndef ROCKSDB_LITE



#include "db/db_impl/db_impl.h"

#include "util/timer.h"



namespace ROCKSDB_NAMESPACE {



// StatsDumpScheduler is a singleton object, which is scheduling/running

// DumpStats() and PersistStats() for all DB instances. All DB instances uses

// the same object from `Default()`.

// Internally, it uses a single threaded timer object to run the stats dump

// functions. Timer thread won't be started if there's no function needs to run,

// for example, option.stats_dump_period_sec and option.stats_persist_period_sec

// are set to 0.

class StatsDumpScheduler {

 public:

  static StatsDumpScheduler* Default();



  StatsDumpScheduler() = delete;

  StatsDumpScheduler(const StatsDumpScheduler&) = delete;

  StatsDumpScheduler(StatsDumpScheduler&&) = delete;

  StatsDumpScheduler& operator=(const StatsDumpScheduler&) = delete;

  StatsDumpScheduler& operator=(StatsDumpScheduler&&) = delete;



  void Register(DBImpl* dbi, unsigned int stats_dump_period_sec,

                unsigned int stats_persist_period_sec);



  void Unregister(DBImpl* dbi);



 protected:

  std::unique_ptr<Timer> timer;



  explicit StatsDumpScheduler(Env* env);



 private:

  std::string GetTaskName(DBImpl* dbi, const std::string& func_name);

};



#ifndef NDEBUG

// StatsDumpTestScheduler is for unittest, which can specify the Env like

// SafeMockTimeEnv. It also contains functions for unittest.

class StatsDumpTestScheduler : public StatsDumpScheduler {

 public:

  static StatsDumpTestScheduler* Default(Env* env);



  void TEST_WaitForRun(std::function<void()> callback) const;



  size_t TEST_GetValidTaskNum() const;



 private:

  explicit StatsDumpTestScheduler(Env* env);

};

#endif  // !NDEBUG



}  // namespace ROCKSDB_NAMESPACE



#endif  // ROCKSDB_LITE