Index: net/tools/cachetool/cachetool.cc |
diff --git a/net/tools/cachetool/cachetool.cc b/net/tools/cachetool/cachetool.cc |
deleted file mode 100644 |
index 4cb94cd3fa128230202657904b6bc78a37fd2abd..0000000000000000000000000000000000000000 |
--- a/net/tools/cachetool/cachetool.cc |
+++ /dev/null |
@@ -1,214 +0,0 @@ |
-// Copyright 2016 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. |
- |
-#include <iostream> |
- |
-#include "base/at_exit.h" |
-#include "base/command_line.h" |
-#include "base/files/file_path.h" |
-#include "base/logging.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/message_loop/message_loop.h" |
-#include "base/strings/string_number_conversions.h" |
-#include "net/base/io_buffer.h" |
-#include "net/base/test_completion_callback.h" |
-#include "net/disk_cache/disk_cache.h" |
-#include "net/disk_cache/simple/simple_backend_impl.h" |
-#include "net/http/http_cache.h" |
-#include "net/http/http_response_headers.h" |
-#include "net/http/http_util.h" |
- |
-using disk_cache::Backend; |
-using disk_cache::Entry; |
-using disk_cache::SimpleBackendImpl; |
- |
-namespace { |
- |
-base::MessageLoopForIO* g_message_loop = nullptr; |
- |
-scoped_ptr<SimpleBackendImpl> CreateSimpleBackend( |
- const base::FilePath& cache_path) { |
- scoped_ptr<SimpleBackendImpl> cache_backend(new SimpleBackendImpl( |
- cache_path, 0, net::DISK_CACHE, g_message_loop->task_runner(), NULL)); |
- |
- net::TestCompletionCallback cb; |
- int rv = cache_backend->Init(cb.callback()); |
- if (cb.GetResult(rv) != net::OK) |
- return nullptr; |
- return cache_backend; |
-} |
- |
-// Print all of a cache's keys to stdout. |
-bool ListKeys(Backend* cache_backend) { |
- scoped_ptr<Backend::Iterator> entry_iterator = |
- cache_backend->CreateIterator(); |
- Entry* entry = nullptr; |
- net::TestCompletionCallback cb; |
- int rv = entry_iterator->OpenNextEntry(&entry, cb.callback()); |
- while (cb.GetResult(rv) == net::OK) { |
- std::string url = entry->GetKey(); |
- std::cout << url << std::endl; |
- entry->Close(); |
- entry = nullptr; |
- rv = entry_iterator->OpenNextEntry(&entry, cb.callback()); |
- } |
- return true; |
-} |
- |
-// Print a key's stream to stdout. |
-bool GetKeyStream(Backend* cache_backend, const std::string& key, int index) { |
- if (index < 0 || index > 2) { |
- std::cerr << "Invalid stream index." << std::endl; |
- return false; |
- } |
- |
- Entry* cache_entry; |
- net::TestCompletionCallback cb; |
- int rv = cache_backend->OpenEntry(key, &cache_entry, cb.callback()); |
- if (cb.GetResult(rv) != net::OK) { |
- std::cerr << "Couldn't find key's entry." << std::endl; |
- return false; |
- } |
- |
- const int kInitBufferSize = 8192; |
- scoped_refptr<net::GrowableIOBuffer> buffer(new net::GrowableIOBuffer()); |
- buffer->SetCapacity(kInitBufferSize); |
- while (true) { |
- rv = cache_entry->ReadData(index, buffer->offset(), buffer.get(), |
- buffer->capacity() - buffer->offset(), |
- cb.callback()); |
- rv = cb.GetResult(rv); |
- if (rv < 0) { |
- cache_entry->Close(); |
- std::cerr << "Stream read error." << std::endl; |
- return false; |
- } |
- buffer->set_offset(buffer->offset() + rv); |
- if (rv == 0) |
- break; |
- buffer->SetCapacity(buffer->offset() * 2); |
- } |
- cache_entry->Close(); |
- if (index == 0) { |
- net::HttpResponseInfo response_info; |
- bool truncated_response_info = false; |
- net::HttpCache::ParseResponseInfo(buffer->StartOfBuffer(), buffer->offset(), |
- &response_info, &truncated_response_info); |
- if (truncated_response_info) { |
- std::cerr << "Truncated HTTP response." << std::endl; |
- return false; |
- } |
- std::cout << net::HttpUtil::ConvertHeadersBackToHTTPResponse( |
- response_info.headers->raw_headers()); |
- } else { |
- std::cout.write(buffer->StartOfBuffer(), buffer->offset()); |
- } |
- return true; |
-} |
- |
-// Delete a specified key from the cache. |
-bool DeleteKey(Backend* cache_backend, const std::string& key) { |
- net::TestCompletionCallback cb; |
- int rv = cache_backend->DoomEntry(key, cb.callback()); |
- if (cb.GetResult(rv) != net::OK) { |
- std::cerr << "Couldn't delete key." << std::endl; |
- return false; |
- } |
- return true; |
-} |
- |
-// Print the command line help. |
-void PrintHelp() { |
- std::cout << "cachetool <cache_path> <cache_backend_type> <subcommand> ..." |
- << std::endl |
- << std::endl; |
- std::cout << "Available cache back-end types: simple"; |
- std::cout << "Available subcommands:" << std::endl; |
- std::cout << " validate: Verify that the cache can be opened and return, " |
- << "confirming the cache exists and is of the right type." |
- << std::endl; |
- std::cout << " list_keys: List all keys in the cache." << std::endl; |
- std::cout << " get_stream <key> <index>: Print a particular stream for a" |
- << " given key." << std::endl; |
- std::cout << " delete_key <key>: Delete key from cache." << std::endl; |
- std::cout << "Expected values of <index> are:" << std::endl; |
- std::cout << " 0 (HTTP response headers)" << std::endl; |
- std::cout << " 1 (transport encoded content)" << std::endl; |
- std::cout << " 2 (compiled content)" << std::endl; |
-} |
- |
-} // namespace |
- |
-int main(int argc, char* argv[]) { |
- base::AtExitManager at_exit_manager; |
- base::MessageLoopForIO message_loop; |
- base::CommandLine::Init(argc, argv); |
- const base::CommandLine& command_line = |
- *base::CommandLine::ForCurrentProcess(); |
- |
- base::CommandLine::StringVector args = command_line.GetArgs(); |
- if (args.size() < 3U) { |
- PrintHelp(); |
- return 1; |
- } |
- |
- base::FilePath cache_path(args[0]); |
- std::string cache_backend_type(args[1]); |
- std::string subcommand(args[2]); |
- |
- g_message_loop = &message_loop; |
- scoped_ptr<Backend> cache_backend; |
- if (cache_backend_type == "simple") { |
- cache_backend = CreateSimpleBackend(cache_path); |
- } else { |
- std::cerr << "Unknown cache type." << std::endl; |
- PrintHelp(); |
- return 1; |
- } |
- |
- if (!cache_backend) { |
- std::cerr << "Invalid cache." << std::endl; |
- PrintHelp(); |
- return 1; |
- } |
- |
- bool successful_command = false; |
- if (subcommand == "validate") { |
- if (args.size() != 3) { |
- PrintHelp(); |
- return 1; |
- } |
- successful_command = true; |
- } else if (subcommand == "list_keys") { |
- if (args.size() != 3) { |
- PrintHelp(); |
- return 1; |
- } |
- successful_command = ListKeys(cache_backend.get()); |
- } else if (subcommand == "get_stream") { |
- if (args.size() != 5) { |
- PrintHelp(); |
- return 1; |
- } |
- std::string key(args[3]); |
- int index = 0; |
- if (!base::StringToInt(args[4], &index)) { |
- std::cerr << "<index> must be an integer." << std::endl; |
- PrintHelp(); |
- return 1; |
- } |
- successful_command = GetKeyStream(cache_backend.get(), key, index); |
- } else if (subcommand == "delete_key") { |
- if (args.size() != 4) { |
- PrintHelp(); |
- return 1; |
- } |
- std::string key(args[3]); |
- successful_command = DeleteKey(cache_backend.get(), key); |
- } else { |
- std::cerr << "Unknown subcommand." << std::endl; |
- PrintHelp(); |
- } |
- return !successful_command; |
-} |