Packages

rocksdb

1.4.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 flush_scheduler.h
Raw

deps/rocksdb/db/flush_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



#include <stdint.h>

#include <atomic>

#include <mutex>

#include <set>



namespace rocksdb {



class ColumnFamilyData;



// Unless otherwise noted, all methods on FlushScheduler should be called

// only with the DB mutex held or from a single-threaded recovery context.

class FlushScheduler {

 public:

  FlushScheduler() : head_(nullptr) {}



  // May be called from multiple threads at once, but not concurrent with

  // any other method calls on this instance

  void ScheduleFlush(ColumnFamilyData* cfd);



  // Removes and returns Ref()-ed column family. Client needs to Unref().

  // Filters column families that have been dropped.

  ColumnFamilyData* TakeNextColumnFamily();



  // This can be called concurrently with ScheduleFlush but it would miss all

  // the scheduled flushes after the last synchronization. This would result

  // into less precise enforcement of memtable sizes but should not matter much.

  bool Empty();



  void Clear();



 private:

  struct Node {

    ColumnFamilyData* column_family;

    Node* next;

  };



  std::atomic<Node*> head_;

#ifndef NDEBUG

  std::mutex checking_mutex_;

  std::set<ColumnFamilyData*> checking_set_;

#endif  // NDEBUG

};



}  // namespace rocksdb