Disk cache: Reference CL for the implementation of file format version 3.

net/disk_cache/stress_cache.cc

 // Copyright (c) 2012 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 is a simple application that stress-tests the crash recovery of the disk
 // cache. The main application starts a copy of itself on a loop, checking the
 // exit code of the child process. When the child dies in an unexpected way,
 // the main application quits.
 
 // The child application has two threads: one to exercise the cache in an
@@ skipping 90 matching lines @@
 void StressTheCache(int iteration) {
   int cache_size = 0x2000000;  // 32MB.
   uint32 mask = 0xfff;  // 4096 entries.
 
   base::FilePath path;
   PathService::Get(base::DIR_TEMP, &path);
   path = path.AppendASCII("cache_test_stress");
 
   base::Thread cache_thread("CacheThread");
   if (!cache_thread.StartWithOptions(
-          base::Thread::Options(MessageLoop::TYPE_IO, 0)))
+          base::Thread::Options(base::MessageLoop::TYPE_IO, 0)))
     return;
 
   disk_cache::BackendImpl* cache =
-      new disk_cache::BackendImpl(path, mask, cache_thread.message_loop_proxy(),
+      new disk_cache::BackendImpl(path, mask,
+                                  cache_thread.message_loop_proxy().get(),
                                   NULL);
   cache->SetMaxSize(cache_size);
   cache->SetFlags(disk_cache::kNoLoadProtection);
 
   net::TestCompletionCallback cb;
   int rv = cache->Init(cb.callback());
 
   if (cb.GetResult(rv) != net::OK) {
     printf("Unable to initialize cache.\n");
     return;
@@ skipping 35 matching lines @@
     net::TestCompletionCallback cb;
     rv = cache->OpenEntry(keys[key], &entries[slot], cb.callback());
     if (cb.GetResult(rv) != net::OK) {
       rv = cache->CreateEntry(keys[key], &entries[slot], cb.callback());
       CHECK_EQ(net::OK, cb.GetResult(rv));
     }
 
     base::snprintf(buffer->data(), kSize,
                    "i: %d iter: %d, size: %d, truncate: %d     ", i, iteration,
                    size, truncate ? 1 : 0);
-    rv = entries[slot]->WriteData(0, 0, buffer, size, cb.callback(), truncate);
+    rv = entries[slot]->WriteData(0, 0, buffer.get(), size, cb.callback(),
+                                  truncate);
     CHECK_EQ(size, cb.GetResult(rv));
 
     if (rand() % 100 > 80) {
       key = rand() % kNumKeys;
       net::TestCompletionCallback cb2;
       rv = cache->DoomEntry(keys[key], cb2.callback());
       cb2.GetResult(rv);
     }
 
     if (!(i % 100))
       printf("Entries: %d    \r", i);
   }
 }
 
 // We want to prevent the timer thread from killing the process while we are
 // waiting for the debugger to attach.
 bool g_crashing = false;
 
 // RunSoon() and CrashCallback() reference each other, unfortunately.
-void RunSoon(MessageLoop* target_loop);
+void RunSoon(base::MessageLoop* target_loop);
 
 void CrashCallback() {
   // Keep trying to run.
-  RunSoon(MessageLoop::current());
+  RunSoon(base::MessageLoop::current());
 
   if (g_crashing)
     return;
 
   if (rand() % 100 > 30) {
     printf("sweet death...\n");
 #if defined(OS_WIN)
     // Windows does more work on _exit() that we would like, so we use Kill.
     base::KillProcessById(base::GetCurrentProcId(), kExpectedCrash, false);
 #elif defined(OS_POSIX)
     // On POSIX, _exit() will terminate the process with minimal cleanup,
     // and it is cleaner than killing.
     _exit(kExpectedCrash);
 #endif
   }
 }
 
-void RunSoon(MessageLoop* target_loop) {
+void RunSoon(base::MessageLoop* target_loop) {
   const base::TimeDelta kTaskDelay = base::TimeDelta::FromSeconds(10);
   target_loop->PostDelayedTask(
       FROM_HERE, base::Bind(&CrashCallback), kTaskDelay);
 }
 
 // We leak everything here :)
 bool StartCrashThread() {
   base::Thread* thread = new base::Thread("party_crasher");
   if (!thread->Start())
     return false;
@@ skipping 44 matching lines @@
   logging::LogEventProvider::Initialize(kStressCacheTraceProviderName);
 #else
   CommandLine::Init(argc, argv);
   logging::InitLogging(NULL, logging::LOG_ONLY_TO_SYSTEM_DEBUG_LOG,
                        logging::LOCK_LOG_FILE, logging::DELETE_OLD_LOG_FILE,
                        logging::DISABLE_DCHECK_FOR_NON_OFFICIAL_RELEASE_BUILDS);
 #endif
 
   // Some time for the memory manager to flush stuff.
   base::PlatformThread::Sleep(base::TimeDelta::FromSeconds(3));
-  MessageLoop message_loop(MessageLoop::TYPE_IO);
+  base::MessageLoop message_loop(base::MessageLoop::TYPE_IO);
 
   char* end;
   long int iteration = strtol(argv[1], &end, 0);
 
   if (!StartCrashThread()) {
     printf("failed to start thread\n");
     return kError;
   }
 
   StressTheCache(iteration);
   return 0;
 }