| Index: net/tools/crash_cache/crash_cache.cc
|
| diff --git a/net/tools/crash_cache/crash_cache.cc b/net/tools/crash_cache/crash_cache.cc
|
| deleted file mode 100644
|
| index 34eaafabf4b7b1bb8b61204defae3c93d531754b..0000000000000000000000000000000000000000
|
| --- a/net/tools/crash_cache/crash_cache.cc
|
| +++ /dev/null
|
| @@ -1,381 +0,0 @@
|
| -// Copyright (c) 2011 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -// This command-line program generates the set of files needed for the crash-
|
| -// cache unit tests (DiskCacheTest,CacheBackend_Recover*). This program only
|
| -// works properly on debug mode, because the crash functionality is not compiled
|
| -// on release builds of the cache.
|
| -
|
| -#include <string>
|
| -
|
| -#include "base/at_exit.h"
|
| -#include "base/command_line.h"
|
| -#include "base/files/file_util.h"
|
| -#include "base/logging.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/path_service.h"
|
| -#include "base/process/kill.h"
|
| -#include "base/process/launch.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/string_util.h"
|
| -#include "base/strings/utf_string_conversions.h"
|
| -#include "base/threading/thread.h"
|
| -#include "net/base/net_errors.h"
|
| -#include "net/base/net_export.h"
|
| -#include "net/base/test_completion_callback.h"
|
| -#include "net/disk_cache/blockfile/backend_impl.h"
|
| -#include "net/disk_cache/blockfile/rankings.h"
|
| -#include "net/disk_cache/disk_cache.h"
|
| -#include "net/disk_cache/disk_cache_test_util.h"
|
| -
|
| -using base::Time;
|
| -
|
| -enum Errors {
|
| - GENERIC = -1,
|
| - ALL_GOOD = 0,
|
| - INVALID_ARGUMENT = 1,
|
| - CRASH_OVERWRITE,
|
| - NOT_REACHED
|
| -};
|
| -
|
| -using disk_cache::RankCrashes;
|
| -
|
| -// Starts a new process, to generate the files.
|
| -int RunSlave(RankCrashes action) {
|
| - base::FilePath exe;
|
| - PathService::Get(base::FILE_EXE, &exe);
|
| -
|
| - base::CommandLine cmdline(exe);
|
| - cmdline.AppendArg(base::IntToString(action));
|
| -
|
| - base::Process process = base::LaunchProcess(cmdline, base::LaunchOptions());
|
| - if (!process.IsValid()) {
|
| - printf("Unable to run test %d\n", action);
|
| - return GENERIC;
|
| - }
|
| -
|
| - int exit_code;
|
| -
|
| - if (!process.WaitForExit(&exit_code)) {
|
| - printf("Unable to get return code, test %d\n", action);
|
| - return GENERIC;
|
| - }
|
| - if (ALL_GOOD != exit_code)
|
| - printf("Test %d failed, code %d\n", action, exit_code);
|
| -
|
| - return exit_code;
|
| -}
|
| -
|
| -// Main loop for the master process.
|
| -int MasterCode() {
|
| - for (int i = disk_cache::NO_CRASH + 1; i < disk_cache::MAX_CRASH; i++) {
|
| - int ret = RunSlave(static_cast<RankCrashes>(i));
|
| - if (ALL_GOOD != ret)
|
| - return ret;
|
| - }
|
| -
|
| - return ALL_GOOD;
|
| -}
|
| -
|
| -// -----------------------------------------------------------------------
|
| -
|
| -namespace disk_cache {
|
| -NET_EXPORT_PRIVATE extern RankCrashes g_rankings_crash;
|
| -}
|
| -
|
| -const char kCrashEntryName[] = "the first key";
|
| -
|
| -// Creates the destinaton folder for this run, and returns it on full_path.
|
| -bool CreateTargetFolder(const base::FilePath& path, RankCrashes action,
|
| - base::FilePath* full_path) {
|
| - const char* const folders[] = {
|
| - "",
|
| - "insert_empty1",
|
| - "insert_empty2",
|
| - "insert_empty3",
|
| - "insert_one1",
|
| - "insert_one2",
|
| - "insert_one3",
|
| - "insert_load1",
|
| - "insert_load2",
|
| - "remove_one1",
|
| - "remove_one2",
|
| - "remove_one3",
|
| - "remove_one4",
|
| - "remove_head1",
|
| - "remove_head2",
|
| - "remove_head3",
|
| - "remove_head4",
|
| - "remove_tail1",
|
| - "remove_tail2",
|
| - "remove_tail3",
|
| - "remove_load1",
|
| - "remove_load2",
|
| - "remove_load3"
|
| - };
|
| - static_assert(arraysize(folders) == disk_cache::MAX_CRASH, "sync folders");
|
| - DCHECK(action > disk_cache::NO_CRASH && action < disk_cache::MAX_CRASH);
|
| -
|
| - *full_path = path.AppendASCII(folders[action]);
|
| -
|
| - if (base::PathExists(*full_path))
|
| - return false;
|
| -
|
| - return base::CreateDirectory(*full_path);
|
| -}
|
| -
|
| -// Makes sure that any pending task is processed.
|
| -void FlushQueue(disk_cache::Backend* cache) {
|
| - net::TestCompletionCallback cb;
|
| - int rv =
|
| - reinterpret_cast<disk_cache::BackendImpl*>(cache)->FlushQueueForTest(
|
| - cb.callback());
|
| - cb.GetResult(rv); // Ignore the result;
|
| -}
|
| -
|
| -bool CreateCache(const base::FilePath& path,
|
| - base::Thread* thread,
|
| - disk_cache::Backend** cache,
|
| - net::TestCompletionCallback* cb) {
|
| - int size = 1024 * 1024;
|
| - disk_cache::BackendImpl* backend = new disk_cache::BackendImpl(
|
| - path, thread->message_loop_proxy().get(), NULL);
|
| - backend->SetMaxSize(size);
|
| - backend->SetType(net::DISK_CACHE);
|
| - backend->SetFlags(disk_cache::kNoRandom);
|
| - int rv = backend->Init(cb->callback());
|
| - *cache = backend;
|
| - return (cb->GetResult(rv) == net::OK && !(*cache)->GetEntryCount());
|
| -}
|
| -
|
| -// Generates the files for an empty and one item cache.
|
| -int SimpleInsert(const base::FilePath& path, RankCrashes action,
|
| - base::Thread* cache_thread) {
|
| - net::TestCompletionCallback cb;
|
| - disk_cache::Backend* cache;
|
| - if (!CreateCache(path, cache_thread, &cache, &cb))
|
| - return GENERIC;
|
| -
|
| - const char* test_name = "some other key";
|
| -
|
| - if (action <= disk_cache::INSERT_EMPTY_3) {
|
| - test_name = kCrashEntryName;
|
| - disk_cache::g_rankings_crash = action;
|
| - }
|
| -
|
| - disk_cache::Entry* entry;
|
| - int rv = cache->CreateEntry(test_name, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| -
|
| - DCHECK(action <= disk_cache::INSERT_ONE_3);
|
| - disk_cache::g_rankings_crash = action;
|
| - test_name = kCrashEntryName;
|
| -
|
| - rv = cache->CreateEntry(test_name, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - return NOT_REACHED;
|
| -}
|
| -
|
| -// Generates the files for a one item cache, and removing the head.
|
| -int SimpleRemove(const base::FilePath& path, RankCrashes action,
|
| - base::Thread* cache_thread) {
|
| - DCHECK(action >= disk_cache::REMOVE_ONE_1);
|
| - DCHECK(action <= disk_cache::REMOVE_TAIL_3);
|
| -
|
| - net::TestCompletionCallback cb;
|
| - disk_cache::Backend* cache;
|
| - if (!CreateCache(path, cache_thread, &cache, &cb))
|
| - return GENERIC;
|
| -
|
| - disk_cache::Entry* entry;
|
| - int rv = cache->CreateEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| -
|
| - if (action >= disk_cache::REMOVE_TAIL_1) {
|
| - rv = cache->CreateEntry("some other key", &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| - }
|
| -
|
| - rv = cache->OpenEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - disk_cache::g_rankings_crash = action;
|
| - entry->Doom();
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| -
|
| - return NOT_REACHED;
|
| -}
|
| -
|
| -int HeadRemove(const base::FilePath& path, RankCrashes action,
|
| - base::Thread* cache_thread) {
|
| - DCHECK(action >= disk_cache::REMOVE_HEAD_1);
|
| - DCHECK(action <= disk_cache::REMOVE_HEAD_4);
|
| -
|
| - net::TestCompletionCallback cb;
|
| - disk_cache::Backend* cache;
|
| - if (!CreateCache(path, cache_thread, &cache, &cb))
|
| - return GENERIC;
|
| -
|
| - disk_cache::Entry* entry;
|
| - int rv = cache->CreateEntry("some other key", &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| - rv = cache->CreateEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| -
|
| - rv = cache->OpenEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - disk_cache::g_rankings_crash = action;
|
| - entry->Doom();
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| -
|
| - return NOT_REACHED;
|
| -}
|
| -
|
| -// Generates the files for insertion and removals on heavy loaded caches.
|
| -int LoadOperations(const base::FilePath& path, RankCrashes action,
|
| - base::Thread* cache_thread) {
|
| - DCHECK(action >= disk_cache::INSERT_LOAD_1);
|
| -
|
| - // Work with a tiny index table (16 entries).
|
| - disk_cache::BackendImpl* cache = new disk_cache::BackendImpl(
|
| - path, 0xf, cache_thread->message_loop_proxy().get(), NULL);
|
| - if (!cache->SetMaxSize(0x100000))
|
| - return GENERIC;
|
| -
|
| - // No experiments and use a simple LRU.
|
| - cache->SetFlags(disk_cache::kNoRandom);
|
| - net::TestCompletionCallback cb;
|
| - int rv = cache->Init(cb.callback());
|
| - if (cb.GetResult(rv) != net::OK || cache->GetEntryCount())
|
| - return GENERIC;
|
| -
|
| - int seed = static_cast<int>(Time::Now().ToInternalValue());
|
| - srand(seed);
|
| -
|
| - disk_cache::Entry* entry;
|
| - for (int i = 0; i < 100; i++) {
|
| - std::string key = GenerateKey(true);
|
| - rv = cache->CreateEntry(key, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| - if (50 == i && action >= disk_cache::REMOVE_LOAD_1) {
|
| - rv = cache->CreateEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| - }
|
| - }
|
| -
|
| - if (action <= disk_cache::INSERT_LOAD_2) {
|
| - disk_cache::g_rankings_crash = action;
|
| -
|
| - rv = cache->CreateEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| - }
|
| -
|
| - rv = cache->OpenEntry(kCrashEntryName, &entry, cb.callback());
|
| - if (cb.GetResult(rv) != net::OK)
|
| - return GENERIC;
|
| -
|
| - disk_cache::g_rankings_crash = action;
|
| -
|
| - entry->Doom();
|
| - entry->Close();
|
| - FlushQueue(cache);
|
| -
|
| - return NOT_REACHED;
|
| -}
|
| -
|
| -// Main function on the child process.
|
| -int SlaveCode(const base::FilePath& path, RankCrashes action) {
|
| - base::MessageLoopForIO message_loop;
|
| -
|
| - base::FilePath full_path;
|
| - if (!CreateTargetFolder(path, action, &full_path)) {
|
| - printf("Destination folder found, please remove it.\n");
|
| - return CRASH_OVERWRITE;
|
| - }
|
| -
|
| - base::Thread cache_thread("CacheThread");
|
| - if (!cache_thread.StartWithOptions(
|
| - base::Thread::Options(base::MessageLoop::TYPE_IO, 0)))
|
| - return GENERIC;
|
| -
|
| - if (action <= disk_cache::INSERT_ONE_3)
|
| - return SimpleInsert(full_path, action, &cache_thread);
|
| -
|
| - if (action <= disk_cache::INSERT_LOAD_2)
|
| - return LoadOperations(full_path, action, &cache_thread);
|
| -
|
| - if (action <= disk_cache::REMOVE_ONE_4)
|
| - return SimpleRemove(full_path, action, &cache_thread);
|
| -
|
| - if (action <= disk_cache::REMOVE_HEAD_4)
|
| - return HeadRemove(full_path, action, &cache_thread);
|
| -
|
| - if (action <= disk_cache::REMOVE_TAIL_3)
|
| - return SimpleRemove(full_path, action, &cache_thread);
|
| -
|
| - if (action <= disk_cache::REMOVE_LOAD_3)
|
| - return LoadOperations(full_path, action, &cache_thread);
|
| -
|
| - return NOT_REACHED;
|
| -}
|
| -
|
| -// -----------------------------------------------------------------------
|
| -
|
| -int main(int argc, const char* argv[]) {
|
| - // Setup an AtExitManager so Singleton objects will be destructed.
|
| - base::AtExitManager at_exit_manager;
|
| -
|
| - if (argc < 2)
|
| - return MasterCode();
|
| -
|
| - char* end;
|
| - RankCrashes action = static_cast<RankCrashes>(strtol(argv[1], &end, 0));
|
| - if (action <= disk_cache::NO_CRASH || action >= disk_cache::MAX_CRASH) {
|
| - printf("Invalid action\n");
|
| - return INVALID_ARGUMENT;
|
| - }
|
| -
|
| - base::FilePath path;
|
| - PathService::Get(base::DIR_SOURCE_ROOT, &path);
|
| - path = path.AppendASCII("net");
|
| - path = path.AppendASCII("data");
|
| - path = path.AppendASCII("cache_tests");
|
| - path = path.AppendASCII("new_crashes");
|
| -
|
| - return SlaveCode(path, action);
|
| -}
|
|
|