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 manifest_ops.cc
Raw

deps/rocksdb/db/manifest_ops.cc 

//  Copyright (c) Meta Platforms, Inc. and affiliates.

//

//  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).



#include "db/manifest_ops.h"



#include "file/filename.h"



namespace ROCKSDB_NAMESPACE {



Status GetCurrentManifestPath(const std::string& dbname, FileSystem* fs,

                              bool is_retry, std::string* manifest_path,

                              uint64_t* manifest_file_number) {

  assert(fs != nullptr);

  assert(manifest_path != nullptr);

  assert(manifest_file_number != nullptr);



  IOOptions opts;

  std::string fname;

  if (is_retry) {

    opts.verify_and_reconstruct_read = true;

  }

  Status s = ReadFileToString(fs, CurrentFileName(dbname), opts, &fname);

  if (!s.ok()) {

    return s;

  }

  if (fname.empty() || fname.back() != '\n') {

    return Status::Corruption("CURRENT file does not end with newline");

  }

  // remove the trailing '\n'

  fname.resize(fname.size() - 1);

  FileType type;

  bool parse_ok = ParseFileName(fname, manifest_file_number, &type);

  if (!parse_ok || type != kDescriptorFile) {

    return Status::Corruption("CURRENT file corrupted");

  }

  *manifest_path = dbname;

  if (dbname.back() != '/') {

    manifest_path->push_back('/');

  }

  manifest_path->append(fname);

  return Status::OK();

}



}  // namespace ROCKSDB_NAMESPACE