| OLD | NEW |
| 1 // Copyright (c) 2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2008 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/file_path.h" |
| 5 #include "base/logging.h" | 6 #include "base/logging.h" |
| 6 #include "base/message_loop.h" | 7 #include "base/message_loop.h" |
| 7 #include "base/scoped_ptr.h" | 8 #include "base/scoped_ptr.h" |
| 8 #include "base/string_util.h" | 9 #include "base/string_util.h" |
| 9 #include "googleurl/src/gurl.h" | 10 #include "googleurl/src/gurl.h" |
| 10 #include "net/base/io_buffer.h" | 11 #include "net/base/io_buffer.h" |
| 11 #include "net/disk_cache/backend_impl.h" | 12 #include "net/disk_cache/backend_impl.h" |
| 12 #include "net/disk_cache/entry_impl.h" | 13 #include "net/disk_cache/entry_impl.h" |
| 13 #include "net/http/http_cache.h" | 14 #include "net/http/http_cache.h" |
| 14 #include "net/http/http_response_headers.h" | 15 #include "net/http/http_response_headers.h" |
| (...skipping 279 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 294 } | 295 } |
| 295 } | 296 } |
| 296 | 297 |
| 297 bool MasterSM::DoInit() { | 298 bool MasterSM::DoInit() { |
| 298 DEBUGMSG("Master DoInit\n"); | 299 DEBUGMSG("Master DoInit\n"); |
| 299 DCHECK(state_ == MASTER_INITIAL); | 300 DCHECK(state_ == MASTER_INITIAL); |
| 300 | 301 |
| 301 if (dump_to_disk_) { | 302 if (dump_to_disk_) { |
| 302 writer_ = new DiskDumper(path_); | 303 writer_ = new DiskDumper(path_); |
| 303 } else { | 304 } else { |
| 304 cache_.reset(new disk_cache::BackendImpl(path_)); | 305 cache_.reset(new disk_cache::BackendImpl(FilePath::FromWStringHack(path_))); |
| 305 if (!cache_->Init()) { | 306 if (!cache_->Init()) { |
| 306 printf("Unable to initialize new files\n"); | 307 printf("Unable to initialize new files\n"); |
| 307 return false; | 308 return false; |
| 308 } | 309 } |
| 309 writer_ = new CacheDumper(cache_.get()); | 310 writer_ = new CacheDumper(cache_.get()); |
| 310 } | 311 } |
| 311 if (!writer_) | 312 if (!writer_) |
| 312 return false; | 313 return false; |
| 313 | 314 |
| 314 copied_entries_ = 0; | 315 copied_entries_ = 0; |
| (...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 502 printf("Unexpected failure\n"); | 503 printf("Unexpected failure\n"); |
| 503 SendQuit(); | 504 SendQuit(); |
| 504 } | 505 } |
| 505 | 506 |
| 506 // ----------------------------------------------------------------------- | 507 // ----------------------------------------------------------------------- |
| 507 | 508 |
| 508 class SlaveSM : public BaseSM { | 509 class SlaveSM : public BaseSM { |
| 509 public: | 510 public: |
| 510 SlaveSM(const std::wstring& path, HANDLE channel) | 511 SlaveSM(const std::wstring& path, HANDLE channel) |
| 511 : BaseSM(channel), iterator_(NULL) { | 512 : BaseSM(channel), iterator_(NULL) { |
| 512 cache_.reset(new disk_cache::BackendImpl(path)); | 513 cache_.reset(new disk_cache::BackendImpl(FilePath::FromWStringHack(path))); |
| 513 if (!cache_->Init()) { | 514 if (!cache_->Init()) { |
| 514 printf("Unable to open cache files\n"); | 515 printf("Unable to open cache files\n"); |
| 515 return; | 516 return; |
| 516 } | 517 } |
| 517 cache_->SetUpgradeMode(); | 518 cache_->SetUpgradeMode(); |
| 518 } | 519 } |
| 519 virtual ~SlaveSM(); | 520 virtual ~SlaveSM(); |
| 520 | 521 |
| 521 bool DoInit(); | 522 bool DoInit(); |
| 522 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context, | 523 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context, |
| (...skipping 296 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 819 | 820 |
| 820 SlaveSM slave(input_path, pipe); | 821 SlaveSM slave(input_path, pipe); |
| 821 if (!slave.DoInit()) { | 822 if (!slave.DoInit()) { |
| 822 printf("Unable to talk with the main process\n"); | 823 printf("Unable to talk with the main process\n"); |
| 823 return -1; | 824 return -1; |
| 824 } | 825 } |
| 825 | 826 |
| 826 loop.Run(); | 827 loop.Run(); |
| 827 return 0; | 828 return 0; |
| 828 } | 829 } |
| OLD | NEW |