Packages

rocksdb

1.0.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 db error_handler.h
Raw

deps/rocksdb/db/error_handler.h 

//  Copyright (c) 2018-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 "monitoring/instrumented_mutex.h"

#include "options/db_options.h"

#include "rocksdb/listener.h"

#include "rocksdb/status.h"



namespace rocksdb {



class DBImpl;



class ErrorHandler {

  public:

   ErrorHandler(DBImpl* db, const ImmutableDBOptions& db_options,

                InstrumentedMutex* db_mutex)

       : db_(db),

         db_options_(db_options),

         bg_error_(Status::OK()),

         recovery_error_(Status::OK()),

         db_mutex_(db_mutex),

         auto_recovery_(false),

         recovery_in_prog_(false) {}

   ~ErrorHandler() {}



   void EnableAutoRecovery() { auto_recovery_ = true; }



   Status::Severity GetErrorSeverity(BackgroundErrorReason reason,

                                     Status::Code code,

                                     Status::SubCode subcode);



   Status SetBGError(const Status& bg_err, BackgroundErrorReason reason);



   Status GetBGError() { return bg_error_; }



   Status GetRecoveryError() { return recovery_error_; }



   Status ClearBGError();



   bool IsDBStopped() {

     return !bg_error_.ok() &&

            bg_error_.severity() >= Status::Severity::kHardError;

    }



    bool IsBGWorkStopped() {

      return !bg_error_.ok() &&

             (bg_error_.severity() >= Status::Severity::kHardError ||

              !auto_recovery_);

    }



    bool IsRecoveryInProgress() { return recovery_in_prog_; }



    Status RecoverFromBGError(bool is_manual = false);

    void CancelErrorRecovery();



   private:

    DBImpl* db_;

    const ImmutableDBOptions& db_options_;

    Status bg_error_;

    // A seperate Status variable used to record any errors during the

    // recovery process from hard errors

    Status recovery_error_;

    InstrumentedMutex* db_mutex_;

    // A flag indicating whether automatic recovery from errors is enabled

    bool auto_recovery_;

    bool recovery_in_prog_;



    Status OverrideNoSpaceError(Status bg_error, bool* auto_recovery);

    void RecoverFromNoSpace();

};



}