chromium/components/services/storage/indexed_db/scopes/leveldb_scopes_test_utils.cc

// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "components/services/storage/indexed_db/scopes/leveldb_scopes_test_utils.h"

#include "base/memory/ptr_util.h"
#include "base/no_destructor.h"
#include "base/run_loop.h"
#include "base/strings/stringprintf.h"
#include "base/synchronization/waitable_event_watcher.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/bind.h"
#include "third_party/leveldatabase/env_chromium.h"
#include "third_party/leveldatabase/leveldb_chrome.h"
#include "third_party/leveldatabase/src/include/leveldb/comparator.h"
#include "third_party/leveldatabase/src/include/leveldb/db.h"
#include "third_party/leveldatabase/src/include/leveldb/filter_policy.h"

namespace content {
namespace {

constexpr size_t kWriteBufferSize = …;

leveldb_env::Options GetLevelDBOptions() { … }

}  // namespace

constexpr const size_t LevelDBScopesTestBase::kWriteBatchSizeForTesting;

LevelDBScopesTestBase::LevelDBScopesTestBase() = default;
LevelDBScopesTestBase::~LevelDBScopesTestBase() = default;

void LevelDBScopesTestBase::SetUp() { … }

void LevelDBScopesTestBase::TearDown() { … }

leveldb::Status LevelDBScopesTestBase::DestroyDB() { … }

void LevelDBScopesTestBase::CloseScopesAndDestroyLevelDBState() { … }

void LevelDBScopesTestBase::SetUpRealDatabase() { … }

void LevelDBScopesTestBase::SetUpBreakableDB(
    base::OnceCallback<void(leveldb::Status)>* break_db) { … }

void LevelDBScopesTestBase::SetUpFlakyDB(
    std::queue<FakeLevelDBFactory::FlakePoint> flake_points) { … }

void LevelDBScopesTestBase::WriteScopesMetadata(int64_t scope_number,
                                                bool ignore_cleanup_tasks) { … }

void LevelDBScopesTestBase::WriteUndoTask(int64_t scope_number,
                                          int64_t sequence_number) { … }

void LevelDBScopesTestBase::WriteCleanupTask(int64_t scope_number,
                                             int64_t sequence_number) { … }

void LevelDBScopesTestBase::WriteLargeValue(const std::string& key) { … }

leveldb::Status LevelDBScopesTestBase::LoadAt(const std::string& key) { … }

leveldb::Status LevelDBScopesTestBase::LoadScopeMetadata(int64_t scope_number) { … }

leveldb::Status LevelDBScopesTestBase::LoadUndoTask(int64_t scope_number,
                                                    int64_t sequence_number) { … }

leveldb::Status LevelDBScopesTestBase::LoadCleanupTask(
    int64_t scope_number,
    int64_t sequence_number) { … }

bool LevelDBScopesTestBase::IsPrefixedRangeEmptyInDB(leveldb::Slice key) { … }

bool LevelDBScopesTestBase::IsScopeCleanedUp(int64_t scope_number) { … }

bool LevelDBScopesTestBase::ScopeDataExistsOnDisk() { … }

PartitionedLockManager::PartitionedLockRequest
LevelDBScopesTestBase::CreateSimpleSharedLock() { … }

PartitionedLockManager::PartitionedLockRequest
LevelDBScopesTestBase::CreateSimpleExclusiveLock() { … }

PartitionedLockManager::PartitionedLockRequest
LevelDBScopesTestBase::CreateSharedLock(int i) { … }

PartitionedLockManager::PartitionedLockRequest
LevelDBScopesTestBase::CreateExclusiveLock(int i) { … }

const base::FilePath& LevelDBScopesTestBase::DatabaseDirFilePath() { … }

leveldb::Status LevelDBScopesTestBase::CreateAndSaveLevelDBState() { … }

}  // namespace content