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

//

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

#include "file/read_write_util.h"

#include <cassert>

#include <sstream>

#include "test_util/sync_point.h"

namespace ROCKSDB_NAMESPACE {

IOStatus NewWritableFile(FileSystem* fs, const std::string& fname,

                         std::unique_ptr<FSWritableFile>* result,

                         const FileOptions& options) {

  TEST_SYNC_POINT_CALLBACK("NewWritableFile::FileOptions.temperature",

                           const_cast<Temperature*>(&options.temperature));

  IOStatus s = fs->NewWritableFile(fname, options, result, nullptr);

  TEST_KILL_RANDOM_WITH_WEIGHT("NewWritableFile:0", REDUCE_ODDS2);

  return s;

}

IOStatus GetFileSizeFromOpenFileOrPath(

    FSRandomAccessFile* file, FileSystem* fs, const std::string& fname,

    uint64_t* file_size, IODebugContext* dbg, FileSizeFallback fallback,

    BeforePathFileSizeFallback before_path_fallback) {

  assert(file != nullptr);

  assert(fs != nullptr);

  assert(file_size != nullptr);

  IOStatus s = file->GetFileSize(file_size);

  if (s.ok()) {

    return s;

  }

  if (fallback == FileSizeFallback::kAnyOpenFileError || s.IsNotSupported()) {

    if (before_path_fallback != nullptr) {

      before_path_fallback();

    }

    return fs->GetFileSize(fname, IOOptions(), file_size, dbg);

  }

  return s;

}

#ifndef NDEBUG

bool IsFileSectorAligned(const size_t off, size_t sector_size) {

  return off % sector_size == 0;

}

#endif  // NDEBUG

}  // namespace ROCKSDB_NAMESPACE