db_impl.h 30.4 KB
Newer Older
1 2 3 4 5
//  Copyright (c) 2013, Facebook, Inc.  All rights reserved.
//  This source code is licensed under the BSD-style license found in the
//  LICENSE file in the root directory of this source tree. An additional grant
//  of patent rights can be found in the PATENTS file in the same directory.
//
J
jorlow@chromium.org 已提交
6 7 8
// 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.
9
#pragma once
K
Kai Liu 已提交
10

H
Haobo Xu 已提交
11
#include <atomic>
12
#include <deque>
13
#include <limits>
J
jorlow@chromium.org 已提交
14
#include <set>
I
Igor Canadi 已提交
15
#include <list>
T
Tomislav Novak 已提交
16
#include <utility>
17
#include <list>
18
#include <vector>
I
Igor Canadi 已提交
19
#include <string>
K
kailiu 已提交
20

J
jorlow@chromium.org 已提交
21 22 23
#include "db/dbformat.h"
#include "db/log_writer.h"
#include "db/snapshot.h"
24
#include "db/column_family.h"
25 26
#include "db/compaction_job.h"
#include "db/flush_job.h"
27
#include "db/version_edit.h"
I
Igor Canadi 已提交
28
#include "db/wal_manager.h"
29
#include "db/writebuffer.h"
K
Kai Liu 已提交
30 31
#include "memtable_list.h"
#include "port/port.h"
32 33 34 35
#include "rocksdb/db.h"
#include "rocksdb/env.h"
#include "rocksdb/memtablerep.h"
#include "rocksdb/transaction_log.h"
36
#include "util/autovector.h"
I
Igor Canadi 已提交
37 38
#include "util/event_logger.h"
#include "util/hash.h"
39
#include "util/stop_watch.h"
40
#include "util/thread_local.h"
41
#include "util/scoped_arena_iterator.h"
Y
Yueh-Hsuan Chiang 已提交
42
#include "util/hash.h"
43
#include "util/instrumented_mutex.h"
I
Igor Canadi 已提交
44
#include "db/internal_stats.h"
45
#include "db/write_controller.h"
I
Igor Canadi 已提交
46
#include "db/flush_scheduler.h"
I
Igor Canadi 已提交
47
#include "db/write_thread.h"
48

49
namespace rocksdb {
J
jorlow@chromium.org 已提交
50 51 52 53 54 55

class MemTable;
class TableCache;
class Version;
class VersionEdit;
class VersionSet;
D
Danny Guo 已提交
56
class CompactionFilterV2;
57
class Arena;
A
agiardullo 已提交
58
class WriteCallback;
I
Igor Canadi 已提交
59
struct JobContext;
J
jorlow@chromium.org 已提交
60 61 62

class DBImpl : public DB {
 public:
I
Igor Canadi 已提交
63
  DBImpl(const DBOptions& options, const std::string& dbname);
J
jorlow@chromium.org 已提交
64 65 66
  virtual ~DBImpl();

  // Implementations of the DB interface
67 68
  using DB::Put;
  virtual Status Put(const WriteOptions& options,
69
                     ColumnFamilyHandle* column_family, const Slice& key,
I
Igor Sugak 已提交
70
                     const Slice& value) override;
71 72
  using DB::Merge;
  virtual Status Merge(const WriteOptions& options,
73
                       ColumnFamilyHandle* column_family, const Slice& key,
I
Igor Sugak 已提交
74
                       const Slice& value) override;
75 76
  using DB::Delete;
  virtual Status Delete(const WriteOptions& options,
I
Igor Sugak 已提交
77 78
                        ColumnFamilyHandle* column_family,
                        const Slice& key) override;
79
  using DB::Write;
I
Igor Sugak 已提交
80 81
  virtual Status Write(const WriteOptions& options,
                       WriteBatch* updates) override;
A
agiardullo 已提交
82

83
  using DB::Get;
J
jorlow@chromium.org 已提交
84
  virtual Status Get(const ReadOptions& options,
85
                     ColumnFamilyHandle* column_family, const Slice& key,
I
Igor Sugak 已提交
86
                     std::string* value) override;
87 88 89
  using DB::MultiGet;
  virtual std::vector<Status> MultiGet(
      const ReadOptions& options,
90
      const std::vector<ColumnFamilyHandle*>& column_family,
I
Igor Sugak 已提交
91 92
      const std::vector<Slice>& keys,
      std::vector<std::string>* values) override;
93

94
  virtual Status CreateColumnFamily(const ColumnFamilyOptions& options,
95
                                    const std::string& column_family,
I
Igor Sugak 已提交
96 97
                                    ColumnFamilyHandle** handle) override;
  virtual Status DropColumnFamily(ColumnFamilyHandle* column_family) override;
98

99 100 101 102
  // Returns false if key doesn't exist in the database and true if it may.
  // If value_found is not passed in as null, then return the value if found in
  // memory. On return, if value was found, then value_found will be set to true
  // , otherwise false.
103
  using DB::KeyMayExist;
104
  virtual bool KeyMayExist(const ReadOptions& options,
105
                           ColumnFamilyHandle* column_family, const Slice& key,
I
Igor Sugak 已提交
106 107
                           std::string* value,
                           bool* value_found = nullptr) override;
108 109
  using DB::NewIterator;
  virtual Iterator* NewIterator(const ReadOptions& options,
I
Igor Sugak 已提交
110
                                ColumnFamilyHandle* column_family) override;
111 112
  virtual Status NewIterators(
      const ReadOptions& options,
I
Igor Canadi 已提交
113
      const std::vector<ColumnFamilyHandle*>& column_families,
I
Igor Sugak 已提交
114 115 116
      std::vector<Iterator*>* iterators) override;
  virtual const Snapshot* GetSnapshot() override;
  virtual void ReleaseSnapshot(const Snapshot* snapshot) override;
117
  using DB::GetProperty;
118
  virtual bool GetProperty(ColumnFamilyHandle* column_family,
I
Igor Sugak 已提交
119
                           const Slice& property, std::string* value) override;
120 121 122
  using DB::GetIntProperty;
  virtual bool GetIntProperty(ColumnFamilyHandle* column_family,
                              const Slice& property, uint64_t* value) override;
123
  using DB::GetApproximateSizes;
124
  virtual void GetApproximateSizes(ColumnFamilyHandle* column_family,
125 126
                                   const Range* range, int n, uint64_t* sizes,
                                   bool include_memtable = false) override;
127
  using DB::CompactRange;
128 129 130
  virtual Status CompactRange(const CompactRangeOptions& options,
                              ColumnFamilyHandle* column_family,
                              const Slice* begin, const Slice* end) override;
131

132
  using DB::CompactFiles;
I
Igor Sugak 已提交
133 134 135 136 137
  virtual Status CompactFiles(const CompactionOptions& compact_options,
                              ColumnFamilyHandle* column_family,
                              const std::vector<std::string>& input_file_names,
                              const int output_level,
                              const int output_path_id = -1) override;
138

139
  using DB::SetOptions;
I
Igor Sugak 已提交
140 141 142
  Status SetOptions(
      ColumnFamilyHandle* column_family,
      const std::unordered_map<std::string, std::string>& options_map) override;
143

144
  using DB::NumberLevels;
I
Igor Sugak 已提交
145
  virtual int NumberLevels(ColumnFamilyHandle* column_family) override;
146
  using DB::MaxMemCompactionLevel;
I
Igor Sugak 已提交
147
  virtual int MaxMemCompactionLevel(ColumnFamilyHandle* column_family) override;
148
  using DB::Level0StopWriteTrigger;
I
Igor Sugak 已提交
149 150 151 152
  virtual int Level0StopWriteTrigger(
      ColumnFamilyHandle* column_family) override;
  virtual const std::string& GetName() const override;
  virtual Env* GetEnv() const override;
153
  using DB::GetOptions;
I
Igor Sugak 已提交
154 155
  virtual const Options& GetOptions(
      ColumnFamilyHandle* column_family) const override;
156 157
  using DB::GetDBOptions;
  virtual const DBOptions& GetDBOptions() const override;
158 159
  using DB::Flush;
  virtual Status Flush(const FlushOptions& options,
I
Igor Sugak 已提交
160
                       ColumnFamilyHandle* column_family) override;
I
Igor Canadi 已提交
161

I
Igor Sugak 已提交
162
  virtual SequenceNumber GetLatestSequenceNumber() const override;
I
Igor Canadi 已提交
163 164

#ifndef ROCKSDB_LITE
I
Igor Sugak 已提交
165 166
  virtual Status DisableFileDeletions() override;
  virtual Status EnableFileDeletions(bool force) override;
167
  virtual int IsFileDeletionsEnabled() const;
I
Igor Canadi 已提交
168
  // All the returned filenames start with "/"
169
  virtual Status GetLiveFiles(std::vector<std::string>&,
170
                              uint64_t* manifest_file_size,
I
Igor Sugak 已提交
171 172
                              bool flush_memtable = true) override;
  virtual Status GetSortedWalFiles(VectorLogPtr& files) override;
I
Igor Canadi 已提交
173

174 175 176
  virtual Status GetUpdatesSince(
      SequenceNumber seq_number, unique_ptr<TransactionLogIterator>* iter,
      const TransactionLogIterator::ReadOptions&
I
Igor Sugak 已提交
177 178
          read_options = TransactionLogIterator::ReadOptions()) override;
  virtual Status DeleteFile(std::string name) override;
179

I
Igor Sugak 已提交
180 181
  virtual void GetLiveFilesMetaData(
      std::vector<LiveFileMetaData>* metadata) override;
182 183 184 185 186 187 188 189 190

  // Obtains the meta data of the specified column family of the DB.
  // Status::NotFound() will be returned if the current DB does not have
  // any column family match the specified name.
  // TODO(yhchiang): output parameter is placed in the end in this codebase.
  virtual void GetColumnFamilyMetaData(
      ColumnFamilyHandle* column_family,
      ColumnFamilyMetaData* metadata) override;

191 192 193 194
  // experimental API
  Status SuggestCompactRange(ColumnFamilyHandle* column_family,
                             const Slice* begin, const Slice* end);

195 196
  Status PromoteL0(ColumnFamilyHandle* column_family, int target_level);

A
agiardullo 已提交
197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224
  // Similar to Write() but will call the callback once on the single write
  // thread to determine whether it is safe to perform the write.
  virtual Status WriteWithCallback(const WriteOptions& write_options,
                                   WriteBatch* my_batch,
                                   WriteCallback* callback);

  // Returns the sequence number that is guaranteed to be smaller than or equal
  // to the sequence number of any key that could be inserted into the current
  // memtables. It can then be assumed that any write with a larger(or equal)
  // sequence number will be present in this memtable or a later memtable.
  //
  // If the earliest sequence number could not be determined,
  // kMaxSequenceNumber will be returned.
  //
  // If include_history=true, will also search Memtables in MemTableList
  // History.
  SequenceNumber GetEarliestMemTableSequenceNumber(SuperVersion* sv,
                                                   bool include_history);

  // For a given key, check to see if there are any records for this key
  // in the memtables, including memtable history.

  // On success, *seq will contain the sequence number for the
  // latest such change or kMaxSequenceNumber if no records were present.
  // Returns OK on success, other status on error reading memtables.
  Status GetLatestSequenceForKeyFromMemtable(SuperVersion* sv, const Slice& key,
                                             SequenceNumber* seq);

I
Igor Canadi 已提交
225
#endif  // ROCKSDB_LITE
226

I
Igor Canadi 已提交
227 228 229 230
  // checks if all live files exist on file system and that their file sizes
  // match to our in-memory records
  virtual Status CheckConsistency();

231
  virtual Status GetDbIdentity(std::string& identity) const override;
232

I
Igor Canadi 已提交
233
  Status RunManualCompaction(ColumnFamilyData* cfd, int input_level,
234
                             int output_level, uint32_t output_path_id,
235 236
                             const Slice* begin, const Slice* end,
                             bool disallow_trivial_move = false);
237

238
#ifndef ROCKSDB_LITE
J
jorlow@chromium.org 已提交
239
  // Extra methods (for testing) that are not in the public DB interface
I
Igor Canadi 已提交
240
  // Implemented in db_impl_debug.cc
J
jorlow@chromium.org 已提交
241

242
  // Compact any files in the named level that overlap [*begin, *end]
243
  Status TEST_CompactRange(int level, const Slice* begin, const Slice* end,
244 245
                           ColumnFamilyHandle* column_family = nullptr,
                           bool disallow_trivial_move = false);
J
jorlow@chromium.org 已提交
246

247
  // Force current memtable contents to be flushed.
248
  Status TEST_FlushMemTable(bool wait = true);
J
jorlow@chromium.org 已提交
249

250
  // Wait for memtable compaction
251
  Status TEST_WaitForFlushMemTable(ColumnFamilyHandle* column_family = nullptr);
252 253 254 255

  // Wait for any compaction
  Status TEST_WaitForCompact();

J
jorlow@chromium.org 已提交
256 257 258
  // Return an internal iterator over the current state of the database.
  // The keys of this iterator are internal keys (see format.h).
  // The returned iterator should be deleted when no longer needed.
259 260
  Iterator* TEST_NewInternalIterator(
      Arena* arena, ColumnFamilyHandle* column_family = nullptr);
J
jorlow@chromium.org 已提交
261

262 263
  // Return the maximum overlapping data (in bytes) at next level for any
  // file at a level >= 1.
264 265
  int64_t TEST_MaxNextLevelOverlappingBytes(ColumnFamilyHandle* column_family =
                                                nullptr);
266

A
Abhishek Kona 已提交
267 268
  // Return the current manifest file no.
  uint64_t TEST_Current_Manifest_FileNo();
269

270
  // get total level0 file size. Only for testing.
271
  uint64_t TEST_GetLevel0TotalSize();
272

273 274
  void TEST_GetFilesMetaData(ColumnFamilyHandle* column_family,
                             std::vector<std::vector<FileMetaData>>* metadata);
275

276 277 278 279 280 281 282 283 284 285
  void TEST_LockMutex();

  void TEST_UnlockMutex();

  // REQUIRES: mutex locked
  void* TEST_BeginWrite();

  // REQUIRES: mutex locked
  // pass the pointer that you got from TEST_BeginWrite()
  void TEST_EndWrite(void* w);
286

287
  uint64_t TEST_MaxTotalInMemoryState() const {
288 289
    return max_total_in_memory_state_;
  }
290

291 292
  size_t TEST_LogsToFreeSize();

293
#endif  // ROCKSDB_LITE
I
Igor Canadi 已提交
294

I
Igor Canadi 已提交
295
  // Returns the list of live files in 'live' and the list
K
kailiu 已提交
296
  // of all files in the filesystem in 'candidate_files'.
I
Igor Canadi 已提交
297
  // If force == false and the last call was less than
298
  // db_options_.delete_obsolete_files_period_micros microseconds ago,
I
Igor Canadi 已提交
299 300
  // it will not fill up the job_context
  void FindObsoleteFiles(JobContext* job_context, bool force,
I
Igor Canadi 已提交
301 302 303 304 305 306
                         bool no_full_scan = false);

  // Diffs the files listed in filenames and those that do not
  // belong to live files are posibly removed. Also, removes all the
  // files in sst_delete_files and log_delete_files.
  // It is not necessary to hold the mutex when invoking this method.
I
Igor Canadi 已提交
307
  void PurgeObsoleteFiles(const JobContext& background_contet);
I
Igor Canadi 已提交
308

I
Igor Sugak 已提交
309
  ColumnFamilyHandle* DefaultColumnFamily() const override;
310

311 312
  const SnapshotList& snapshots() const { return snapshots_; }

313
  void CancelAllBackgroundWork(bool wait);
314

A
agiardullo 已提交
315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340
  // Find Super version and reference it. Based on options, it might return
  // the thread local cached one.
  // Call ReturnAndCleanupSuperVersion() when it is no longer needed.
  SuperVersion* GetAndRefSuperVersion(ColumnFamilyData* cfd);

  // Similar to the previous function but looks up based on a column family id.
  // nullptr will be returned if this column family no longer exists.
  // REQUIRED: this function should only be called on the write thread or if the
  // mutex is held.
  SuperVersion* GetAndRefSuperVersion(uint32_t column_family_id);

  // Un-reference the super version and return it to thread local cache if
  // needed. If it is the last reference of the super version. Clean it up
  // after un-referencing it.
  void ReturnAndCleanupSuperVersion(ColumnFamilyData* cfd, SuperVersion* sv);

  // Similar to the previous function but looks up based on a column family id.
  // nullptr will be returned if this column family no longer exists.
  // REQUIRED: this function should only be called on the write thread.
  void ReturnAndCleanupSuperVersion(uint32_t colun_family_id, SuperVersion* sv);

  // REQUIRED: this function should only be called on the write thread or if the
  // mutex is held.  Return value only valid until next call to this function or
  // mutex is released.
  ColumnFamilyHandle* GetColumnFamilyHandle(uint32_t column_family_id);

341
 protected:
H
heyongqiang 已提交
342 343
  Env* const env_;
  const std::string dbname_;
344
  unique_ptr<VersionSet> versions_;
345
  const DBOptions db_options_;
L
Lei Jin 已提交
346
  Statistics* stats_;
H
heyongqiang 已提交
347

348
  Iterator* NewInternalIterator(const ReadOptions&, ColumnFamilyData* cfd,
349
                                SuperVersion* super_version, Arena* arena);
350

351
  void NotifyOnFlushCompleted(ColumnFamilyData* cfd, FileMetaData* file_meta,
352 353
                              const MutableCFOptions& mutable_cf_options,
                              int job_id);
354

O
Ori Bernstein 已提交
355
  void NotifyOnCompactionCompleted(ColumnFamilyData* cfd,
356 357
                                   Compaction *c, const Status &st,
                                   const CompactionJobStats& job_stats,
358
                                   int job_id);
O
Ori Bernstein 已提交
359

Y
Yueh-Hsuan Chiang 已提交
360 361 362 363 364 365
  void NewThreadStatusCfInfo(ColumnFamilyData* cfd) const;

  void EraseThreadStatusCfInfo(ColumnFamilyData* cfd) const;

  void EraseThreadStatusDbInfo() const;

A
agiardullo 已提交
366 367 368
  Status WriteImpl(const WriteOptions& options, WriteBatch* updates,
                   WriteCallback* callback);

J
jorlow@chromium.org 已提交
369 370
 private:
  friend class DB;
371
  friend class InternalStats;
I
Igor Canadi 已提交
372
#ifndef ROCKSDB_LITE
L
Lei Jin 已提交
373
  friend class ForwardIterator;
I
Igor Canadi 已提交
374
#endif
375
  friend struct SuperVersion;
L
Lei Jin 已提交
376
  friend class CompactedDBImpl;
A
agiardullo 已提交
377 378 379
#ifndef NDEBUG
  friend class XFTransactionWriteHandler;
#endif
380
  struct CompactionState;
381

S
Stanislau Hlebik 已提交
382
  struct WriteContext;
J
jorlow@chromium.org 已提交
383 384 385 386 387 388

  Status NewDB();

  // Recover the descriptor from persistent storage.  May do a significant
  // amount of work to recover recently logged updates.  Any changes to
  // be made to the descriptor are added to *edit.
389 390
  Status Recover(const std::vector<ColumnFamilyDescriptor>& column_families,
                 bool read_only = false, bool error_if_log_file_exist = false);
J
jorlow@chromium.org 已提交
391 392 393

  void MaybeIgnoreError(Status* s) const;

394 395
  const Status CreateArchivalDirectory();

J
jorlow@chromium.org 已提交
396 397 398
  // Delete any unneeded files and stale in-memory entries.
  void DeleteObsoleteFiles();

I
Igor Canadi 已提交
399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416
  // Background process needs to call
  //     auto x = CaptureCurrentFileNumberInPendingOutputs()
  //     <do something>
  //     ReleaseFileNumberFromPendingOutputs(x)
  // This will protect any temporary files created while <do something> is
  // executing from being deleted.
  // -----------
  // This function will capture current file number and append it to
  // pending_outputs_. This will prevent any background process to delete any
  // file created after this point.
  std::list<uint64_t>::iterator CaptureCurrentFileNumberInPendingOutputs();
  // This function should be called with the result of
  // CaptureCurrentFileNumberInPendingOutputs(). It then marks that any file
  // created between the calls CaptureCurrentFileNumberInPendingOutputs() and
  // ReleaseFileNumberFromPendingOutputs() can now be deleted (if it's not live
  // and blocked by any other pending_outputs_ calls)
  void ReleaseFileNumberFromPendingOutputs(std::list<uint64_t>::iterator v);

417
  // Flush the in-memory write buffer to storage.  Switches to a new
J
jorlow@chromium.org 已提交
418
  // log-file/memtable and writes a new descriptor iff successful.
I
Igor Canadi 已提交
419 420 421 422
  Status FlushMemTableToOutputFile(ColumnFamilyData* cfd,
                                   const MutableCFOptions& mutable_cf_options,
                                   bool* madeProgress, JobContext* job_context,
                                   LogBuffer* log_buffer);
J
jorlow@chromium.org 已提交
423

S
Stanislau Hlebik 已提交
424 425 426
  // REQUIRES: log_numbers are sorted in ascending order
  Status RecoverLogFiles(const std::vector<uint64_t>& log_numbers,
                         SequenceNumber* max_sequence, bool read_only);
J
jorlow@chromium.org 已提交
427

428 429 430 431 432
  // The following two methods are used to flush a memtable to
  // storage. The first one is used atdatabase RecoveryTime (when the
  // database is opened) and is heavyweight because it holds the mutex
  // for the entire period. The second method WriteLevel0Table supports
  // concurrent flush memtables to storage.
433 434
  Status WriteLevel0TableForRecovery(int job_id, ColumnFamilyData* cfd,
                                     MemTable* mem, VersionEdit* edit);
S
sdong 已提交
435 436 437 438

  // num_bytes: for slowdown case, delay time is calculated based on
  //            `num_bytes` going through.
  Status DelayWrite(uint64_t num_bytes, uint64_t expiration_time);
439

I
Igor Canadi 已提交
440
  Status ScheduleFlushes(WriteContext* context);
441

I
Igor Canadi 已提交
442
  Status SwitchMemtable(ColumnFamilyData* cfd, WriteContext* context);
S
Stanislau Hlebik 已提交
443

H
heyongqiang 已提交
444
  // Force current memtable contents to be flushed.
445
  Status FlushMemTable(ColumnFamilyData* cfd, const FlushOptions& options);
H
heyongqiang 已提交
446

447
  // Wait for memtable flushed
448
  Status WaitForFlushMemTable(ColumnFamilyData* cfd);
H
heyongqiang 已提交
449

450 451 452
  void RecordFlushIOStats();
  void RecordCompactionIOStats();

I
Igor Canadi 已提交
453
#ifndef ROCKSDB_LITE
454 455 456
  Status CompactFilesImpl(
      const CompactionOptions& compact_options, ColumnFamilyData* cfd,
      Version* version, const std::vector<std::string>& input_file_names,
457 458
      const int output_level, int output_path_id, JobContext* job_context,
      LogBuffer* log_buffer);
I
Igor Canadi 已提交
459
#endif  // ROCKSDB_LITE
460 461 462

  ColumnFamilyData* GetColumnFamilyDataByName(const std::string& cf_name);

463
  void MaybeScheduleFlushOrCompaction();
464 465
  void SchedulePendingFlush(ColumnFamilyData* cfd);
  void SchedulePendingCompaction(ColumnFamilyData* cfd);
466 467 468 469
  static void BGWorkCompaction(void* db);
  static void BGWorkFlush(void* db);
  void BackgroundCallCompaction();
  void BackgroundCallFlush();
I
Igor Canadi 已提交
470
  Status BackgroundCompaction(bool* madeProgress, JobContext* job_context,
471
                              LogBuffer* log_buffer);
I
Igor Canadi 已提交
472
  Status BackgroundFlush(bool* madeProgress, JobContext* job_context,
H
Haobo Xu 已提交
473
                         LogBuffer* log_buffer);
J
jorlow@chromium.org 已提交
474

I
Igor Canadi 已提交
475 476 477
  // This function is called as part of compaction. It enables Flush process to
  // preempt compaction, since it's higher prioirty
  uint64_t CallFlushDuringCompaction(ColumnFamilyData* cfd,
I
Igor Canadi 已提交
478 479 480
                                     const MutableCFOptions& mutable_cf_options,
                                     JobContext* job_context,
                                     LogBuffer* log_buffer);
I
Igor Canadi 已提交
481

482 483
  void PrintStatistics();

484
  // dump rocksdb.stats to LOG
485 486
  void MaybeDumpStats();

487 488
  // Return the minimum empty level that could hold the total data in the
  // input level. Return the input level, if such level could not be found.
489 490
  int FindMinimumEmptyLevelFitting(ColumnFamilyData* cfd,
      const MutableCFOptions& mutable_cf_options, int level);
491

492 493 494
  // Move the files in the input level to the target level.
  // If target_level < 0, automatically calculate the minimum level that could
  // hold the data set.
I
Igor Canadi 已提交
495
  Status ReFitLevel(ColumnFamilyData* cfd, int level, int target_level = -1);
496

497 498 499 500 501 502
  // helper functions for adding and removing from flush & compaction queues
  void AddToCompactionQueue(ColumnFamilyData* cfd);
  ColumnFamilyData* PopFirstFromCompactionQueue();
  void AddToFlushQueue(ColumnFamilyData* cfd);
  ColumnFamilyData* PopFirstFromFlushQueue();

J
jorlow@chromium.org 已提交
503
  // table_cache_ provides its own synchronization
I
Igor Canadi 已提交
504
  std::shared_ptr<Cache> table_cache_;
J
jorlow@chromium.org 已提交
505

506
  // Lock over the persistent DB state.  Non-nullptr iff successfully acquired.
J
jorlow@chromium.org 已提交
507 508 509
  FileLock* db_lock_;

  // State below is protected by mutex_
510
  InstrumentedMutex mutex_;
I
Igor Canadi 已提交
511
  std::atomic<bool> shutting_down_;
512 513 514 515 516 517 518 519
  // This condition variable is signaled on these conditions:
  // * whenever bg_compaction_scheduled_ goes down to 0
  // * if bg_manual_only_ > 0, whenever a compaction finishes, even if it hasn't
  // made any progress
  // * whenever a compaction made any progress
  // * whenever bg_flush_scheduled_ value decreases (i.e. whenever a flush is
  // done, even if it didn't make any progress)
  // * whenever there is an error in background flush or compaction
520
  InstrumentedCondVar bg_cv_;
521
  uint64_t logfile_number_;
522
  unique_ptr<log::Writer> log_;
523
  bool log_dir_synced_;
I
Igor Canadi 已提交
524
  bool log_empty_;
525
  ColumnFamilyHandleImpl* default_cf_handle_;
526
  InternalStats* default_cf_internal_stats_;
527
  unique_ptr<ColumnFamilyMemTablesImpl> column_family_memtables_;
I
Igor Canadi 已提交
528 529 530 531 532 533 534 535 536 537 538 539 540
  struct LogFileNumberSize {
    explicit LogFileNumberSize(uint64_t _number)
        : number(_number), size(0), getting_flushed(false) {}
    void AddSize(uint64_t new_size) { size += new_size; }
    uint64_t number;
    uint64_t size;
    bool getting_flushed;
  };
  std::deque<LogFileNumberSize> alive_log_files_;
  uint64_t total_log_size_;
  // only used for dynamically adjusting max_total_wal_size. it is a sum of
  // [write_buffer_size * max_write_buffer_number] over all column families
  uint64_t max_total_in_memory_state_;
541 542 543
  // If true, we have only one (default) column family. We use this to optimize
  // some code-paths
  bool single_column_family_mode_;
544 545 546
  // If this is non-empty, we need to delete these log files in background
  // threads. Protected by db mutex.
  autovector<log::Writer*> logs_to_free_;
I
Igor Canadi 已提交
547

S
sdong 已提交
548 549
  bool is_snapshot_supported_;

550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577
  // Class to maintain directories for all database paths other than main one.
  class Directories {
   public:
    Status SetDirectories(Env* env, const std::string& dbname,
                          const std::string& wal_dir,
                          const std::vector<DbPath>& data_paths);

    Directory* GetDataDir(size_t path_id);

    Directory* GetWalDir() {
      if (wal_dir_) {
        return wal_dir_.get();
      }
      return db_dir_.get();
    }

    Directory* GetDbDir() { return db_dir_.get(); }

   private:
    std::unique_ptr<Directory> db_dir_;
    std::vector<std::unique_ptr<Directory>> data_dirs_;
    std::unique_ptr<Directory> wal_dir_;

    Status CreateAndNewDirectory(Env* env, const std::string& dirname,
                                 std::unique_ptr<Directory>* directory) const;
  };

  Directories directories_;
578

579 580
  WriteBuffer write_buffer_;

I
Igor Canadi 已提交
581 582
  WriteThread write_thread_;

583
  WriteBatch tmp_batch_;
584

585
  WriteController write_controller_;
S
sdong 已提交
586 587 588 589 590

  // Size of the last batch group. In slowdown mode, next write needs to
  // sleep if it uses up the quota.
  uint64_t last_batch_group_size_;

I
Igor Canadi 已提交
591
  FlushScheduler flush_scheduler_;
592

J
jorlow@chromium.org 已提交
593 594
  SnapshotList snapshots_;

I
Igor Canadi 已提交
595 596 597 598 599 600 601 602 603 604
  // For each background job, pending_outputs_ keeps the current file number at
  // the time that background job started.
  // FindObsoleteFiles()/PurgeObsoleteFiles() never deletes any file that has
  // number bigger than any of the file number in pending_outputs_. Since file
  // numbers grow monotonically, this also means that pending_outputs_ is always
  // sorted. After a background job is done executing, its file number is
  // deleted from pending_outputs_, which allows PurgeObsoleteFiles() to clean
  // it up.
  // State is protected with db mutex.
  std::list<uint64_t> pending_outputs_;
J
jorlow@chromium.org 已提交
605

606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631
  // flush_queue_ and compaction_queue_ hold column families that we need to
  // flush and compact, respectively.
  // A column family is inserted into flush_queue_ when it satisfies condition
  // cfd->imm()->IsFlushPending()
  // A column family is inserted into compaction_queue_ when it satisfied
  // condition cfd->NeedsCompaction()
  // Column families in this list are all Ref()-erenced
  // TODO(icanadi) Provide some kind of ReferencedColumnFamily class that will
  // do RAII on ColumnFamilyData
  // Column families are in this queue when they need to be flushed or
  // compacted. Consumers of these queues are flush and compaction threads. When
  // column family is put on this queue, we increase unscheduled_flushes_ and
  // unscheduled_compactions_. When these variables are bigger than zero, that
  // means we need to schedule background threads for compaction and thread.
  // Once the background threads are scheduled, we decrease unscheduled_flushes_
  // and unscheduled_compactions_. That way we keep track of number of
  // compaction and flush threads we need to schedule. This scheduling is done
  // in MaybeScheduleFlushOrCompaction()
  // invariant(column family present in flush_queue_ <==>
  // ColumnFamilyData::pending_flush_ == true)
  std::deque<ColumnFamilyData*> flush_queue_;
  // invariant(column family present in compaction_queue_ <==>
  // ColumnFamilyData::pending_compaction_ == true)
  std::deque<ColumnFamilyData*> compaction_queue_;
  int unscheduled_flushes_;
  int unscheduled_compactions_;
632

633
  // count how many background compactions are running or have been scheduled
634
  int bg_compaction_scheduled_;
J
jorlow@chromium.org 已提交
635

636 637 638 639 640
  // If non-zero, MaybeScheduleFlushOrCompaction() will only schedule manual
  // compactions (if manual_compaction_ is not null). This mechanism enables
  // manual compactions to wait until all other compactions are finished.
  int bg_manual_only_;

641 642 643
  // number of background memtable flush jobs, submitted to the HIGH pool
  int bg_flush_scheduled_;

H
hans@chromium.org 已提交
644 645
  // Information for a manual compaction
  struct ManualCompaction {
I
Igor Canadi 已提交
646
    ColumnFamilyData* cfd;
647 648
    int input_level;
    int output_level;
649
    uint32_t output_path_id;
G
Gabor Cselle 已提交
650
    bool done;
L
Lei Jin 已提交
651
    Status status;
652 653 654 655 656
    bool in_progress;             // compaction request being processed?
    const InternalKey* begin;     // nullptr means beginning of key range
    const InternalKey* end;       // nullptr means end of key range
    InternalKey tmp_storage;      // Used to keep track of compaction progress
    bool disallow_trivial_move;   // Force actual compaction to run
H
hans@chromium.org 已提交
657 658
  };
  ManualCompaction* manual_compaction_;
J
jorlow@chromium.org 已提交
659 660 661 662

  // Have we encountered a background error in paranoid mode?
  Status bg_error_;

663
  // shall we disable deletion of obsolete files
664 665 666 667 668 669
  // if 0 the deletion is enabled.
  // if non-zero, files will not be getting deleted
  // This enables two different threads to call
  // EnableFileDeletions() and DisableFileDeletions()
  // without any synchronization
  int disable_delete_obsolete_files_;
670

I
Igor Canadi 已提交
671 672
  // next time when we should run DeleteObsoleteFiles with full scan
  uint64_t delete_obsolete_files_next_run_;
673

674
  // last time stats were dumped to LOG
H
Haobo Xu 已提交
675
  std::atomic<uint64_t> last_stats_dump_time_microsec_;
676

677 678 679 680
  // Each flush or compaction gets its own job id. this counter makes sure
  // they're unique
  std::atomic<int> next_job_id_;

681 682
  bool flush_on_destroy_; // Used when disableWAL is true.

H
heyongqiang 已提交
683
  static const int KEEP_LOG_FILE_NUM = 1000;
D
Dmitri Smirnov 已提交
684 685 686
  // MSVC version 1800 still does not have constexpr for ::max()
  static const uint64_t kNoTimeOut = UINT64_MAX;

H
heyongqiang 已提交
687
  std::string db_absolute_path_;
H
heyongqiang 已提交
688

689
  // The options to access storage files
L
Lei Jin 已提交
690
  const EnvOptions env_options_;
691

I
Igor Canadi 已提交
692 693 694 695
#ifndef ROCKSDB_LITE
  WalManager wal_manager_;
#endif  // ROCKSDB_LITE

I
Igor Canadi 已提交
696 697 698
  // Unified interface for logging events
  EventLogger event_logger_;

699 700 701 702 703 704
  // A value of true temporarily disables scheduling of background work
  bool bg_work_gate_closed_;

  // Guard against multiple concurrent refitting
  bool refitting_level_;

705 706 707
  // Indicate DB was opened successfully
  bool opened_successfully_;

J
jorlow@chromium.org 已提交
708 709 710 711
  // No copying allowed
  DBImpl(const DBImpl&);
  void operator=(const DBImpl&);

712 713 714 715 716 717
  // Return the earliest snapshot where seqno is visible.
  // Store the snapshot right before that, if any, in prev_snapshot
  inline SequenceNumber findEarliestVisibleSnapshot(
    SequenceNumber in,
    std::vector<SequenceNumber>& snapshots,
    SequenceNumber* prev_snapshot);
718

I
Igor Canadi 已提交
719
  // Background threads call this function, which is just a wrapper around
I
Igor Canadi 已提交
720 721 722
  // the InstallSuperVersion() function. Background threads carry
  // job_context which can have new_superversion already
  // allocated.
I
Igor Canadi 已提交
723
  void InstallSuperVersionAndScheduleWorkWrapper(
I
Igor Canadi 已提交
724 725
      ColumnFamilyData* cfd, JobContext* job_context,
      const MutableCFOptions& mutable_cf_options);
L
Lei Jin 已提交
726

727 728 729
  // All ColumnFamily state changes go through this function. Here we analyze
  // the new state and we schedule background work if we detect that the new
  // state needs flush or compaction.
I
Igor Canadi 已提交
730 731 732
  SuperVersion* InstallSuperVersionAndScheduleWork(
      ColumnFamilyData* cfd, SuperVersion* new_sv,
      const MutableCFOptions& mutable_cf_options);
I
Igor Canadi 已提交
733

I
Igor Canadi 已提交
734
#ifndef ROCKSDB_LITE
I
Igor Canadi 已提交
735 736 737
  using DB::GetPropertiesOfAllTables;
  virtual Status GetPropertiesOfAllTables(ColumnFamilyHandle* column_family,
                                          TablePropertiesCollection* props)
738
      override;
I
Igor Canadi 已提交
739
#endif  // ROCKSDB_LITE
740

741 742
  // Function that Get and KeyMayExist call with no_io true or false
  // Note: 'value_found' from KeyMayExist propagates here
743 744 745
  Status GetImpl(const ReadOptions& options, ColumnFamilyHandle* column_family,
                 const Slice& key, std::string* value,
                 bool* value_found = nullptr);
746 747 748 749

  bool GetIntPropertyInternal(ColumnFamilyHandle* column_family,
                              DBPropertyType property_type,
                              bool need_out_of_mutex, uint64_t* value);
J
jorlow@chromium.org 已提交
750 751 752 753 754 755 756
};

// Sanitize db options.  The caller should delete result.info_log if
// it is not equal to src.info_log.
extern Options SanitizeOptions(const std::string& db,
                               const InternalKeyComparator* icmp,
                               const Options& src);
757
extern DBOptions SanitizeOptions(const std::string& db, const DBOptions& src);
S
Siying Dong 已提交
758

M
miguelportilla 已提交
759 760 761 762 763 764 765
// Fix user-supplied options to be reasonable
template <class T, class V>
static void ClipToRange(T* ptr, V minvalue, V maxvalue) {
  if (static_cast<V>(*ptr) > maxvalue) *ptr = maxvalue;
  if (static_cast<V>(*ptr) < minvalue) *ptr = minvalue;
}

766
}  // namespace rocksdb