Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(18)

Side by Side Diff: net/disk_cache/blockfile/entry_impl.cc

Issue 2315613002: Extracted NetLog class's inner enum types into their own enum classes and (Closed)
Patch Set: Ran "git cl format" on code. Much formatting ensued. Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/cert/multi_threaded_cert_verifier.cc ('k') | net/disk_cache/blockfile/sparse_control.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 "net/disk_cache/blockfile/entry_impl.h" 5 #include "net/disk_cache/blockfile/entry_impl.h"
6 6
7 #include <limits> 7 #include <limits>
8 8
9 #include "base/hash.h" 9 #include "base/hash.h"
10 #include "base/macros.h" 10 #include "base/macros.h"
11 #include "base/message_loop/message_loop.h" 11 #include "base/message_loop/message_loop.h"
12 #include "base/strings/string_util.h" 12 #include "base/strings/string_util.h"
13 #include "net/base/io_buffer.h" 13 #include "net/base/io_buffer.h"
14 #include "net/base/net_errors.h" 14 #include "net/base/net_errors.h"
15 #include "net/disk_cache/blockfile/backend_impl.h" 15 #include "net/disk_cache/blockfile/backend_impl.h"
16 #include "net/disk_cache/blockfile/bitmap.h" 16 #include "net/disk_cache/blockfile/bitmap.h"
17 #include "net/disk_cache/blockfile/disk_format.h" 17 #include "net/disk_cache/blockfile/disk_format.h"
18 #include "net/disk_cache/blockfile/histogram_macros.h" 18 #include "net/disk_cache/blockfile/histogram_macros.h"
19 #include "net/disk_cache/blockfile/sparse_control.h" 19 #include "net/disk_cache/blockfile/sparse_control.h"
20 #include "net/disk_cache/cache_util.h" 20 #include "net/disk_cache/cache_util.h"
21 #include "net/disk_cache/net_log_parameters.h" 21 #include "net/disk_cache/net_log_parameters.h"
22 #include "net/log/net_log_event_type.h"
23 #include "net/log/net_log_source_type.h"
22 24
23 // Provide a BackendImpl object to macros from histogram_macros.h. 25 // Provide a BackendImpl object to macros from histogram_macros.h.
24 #define CACHE_UMA_BACKEND_IMPL_OBJ backend_ 26 #define CACHE_UMA_BACKEND_IMPL_OBJ backend_
25 27
26 using base::Time; 28 using base::Time;
27 using base::TimeDelta; 29 using base::TimeDelta;
28 using base::TimeTicks; 30 using base::TimeTicks;
29 31
30 namespace { 32 namespace {
31 33
32 // Index for the file used to store the key, if any (files_[kKeyFileIndex]). 34 // Index for the file used to store the key, if any (files_[kKeyFileIndex]).
33 const int kKeyFileIndex = 3; 35 const int kKeyFileIndex = 3;
34 36
35 // This class implements FileIOCallback to buffer the callback from a file IO 37 // This class implements FileIOCallback to buffer the callback from a file IO
36 // operation from the actual net class. 38 // operation from the actual net class.
37 class SyncCallback: public disk_cache::FileIOCallback { 39 class SyncCallback: public disk_cache::FileIOCallback {
38 public: 40 public:
39 // |end_event_type| is the event type to log on completion. Logs nothing on 41 // |end_event_type| is the event type to log on completion. Logs nothing on
40 // discard, or when the NetLog is not set to log all events. 42 // discard, or when the NetLog is not set to log all events.
41 SyncCallback(disk_cache::EntryImpl* entry, net::IOBuffer* buffer, 43 SyncCallback(disk_cache::EntryImpl* entry,
44 net::IOBuffer* buffer,
42 const net::CompletionCallback& callback, 45 const net::CompletionCallback& callback,
43 net::NetLog::EventType end_event_type) 46 net::NetLogEventType end_event_type)
44 : entry_(entry), callback_(callback), buf_(buffer), 47 : entry_(entry),
45 start_(TimeTicks::Now()), end_event_type_(end_event_type) { 48 callback_(callback),
49 buf_(buffer),
50 start_(TimeTicks::Now()),
51 end_event_type_(end_event_type) {
46 entry->AddRef(); 52 entry->AddRef();
47 entry->IncrementIoCount(); 53 entry->IncrementIoCount();
48 } 54 }
49 ~SyncCallback() override {} 55 ~SyncCallback() override {}
50 56
51 void OnFileIOComplete(int bytes_copied) override; 57 void OnFileIOComplete(int bytes_copied) override;
52 void Discard(); 58 void Discard();
53 59
54 private: 60 private:
55 disk_cache::EntryImpl* entry_; 61 disk_cache::EntryImpl* entry_;
56 net::CompletionCallback callback_; 62 net::CompletionCallback callback_;
57 scoped_refptr<net::IOBuffer> buf_; 63 scoped_refptr<net::IOBuffer> buf_;
58 TimeTicks start_; 64 TimeTicks start_;
59 const net::NetLog::EventType end_event_type_; 65 const net::NetLogEventType end_event_type_;
60 66
61 DISALLOW_COPY_AND_ASSIGN(SyncCallback); 67 DISALLOW_COPY_AND_ASSIGN(SyncCallback);
62 }; 68 };
63 69
64 void SyncCallback::OnFileIOComplete(int bytes_copied) { 70 void SyncCallback::OnFileIOComplete(int bytes_copied) {
65 entry_->DecrementIoCount(); 71 entry_->DecrementIoCount();
66 if (!callback_.is_null()) { 72 if (!callback_.is_null()) {
67 if (entry_->net_log().IsCapturing()) { 73 if (entry_->net_log().IsCapturing()) {
68 entry_->net_log().EndEvent( 74 entry_->net_log().EndEvent(
69 end_event_type_, 75 end_event_type_,
(...skipping 242 matching lines...) Expand 10 before | Expand all | Expand 10 after
312 return; 318 return;
313 319
314 SetPointerForInvalidEntry(backend_->GetCurrentEntryId()); 320 SetPointerForInvalidEntry(backend_->GetCurrentEntryId());
315 backend_->InternalDoomEntry(this); 321 backend_->InternalDoomEntry(this);
316 } 322 }
317 323
318 int EntryImpl::ReadDataImpl(int index, int offset, IOBuffer* buf, int buf_len, 324 int EntryImpl::ReadDataImpl(int index, int offset, IOBuffer* buf, int buf_len,
319 const CompletionCallback& callback) { 325 const CompletionCallback& callback) {
320 if (net_log_.IsCapturing()) { 326 if (net_log_.IsCapturing()) {
321 net_log_.BeginEvent( 327 net_log_.BeginEvent(
322 net::NetLog::TYPE_ENTRY_READ_DATA, 328 net::NetLogEventType::ENTRY_READ_DATA,
323 CreateNetLogReadWriteDataCallback(index, offset, buf_len, false)); 329 CreateNetLogReadWriteDataCallback(index, offset, buf_len, false));
324 } 330 }
325 331
326 int result = InternalReadData(index, offset, buf, buf_len, callback); 332 int result = InternalReadData(index, offset, buf, buf_len, callback);
327 333
328 if (result != net::ERR_IO_PENDING && net_log_.IsCapturing()) { 334 if (result != net::ERR_IO_PENDING && net_log_.IsCapturing()) {
329 net_log_.EndEvent( 335 net_log_.EndEvent(net::NetLogEventType::ENTRY_READ_DATA,
330 net::NetLog::TYPE_ENTRY_READ_DATA, 336 CreateNetLogReadWriteCompleteCallback(result));
331 CreateNetLogReadWriteCompleteCallback(result));
332 } 337 }
333 return result; 338 return result;
334 } 339 }
335 340
336 int EntryImpl::WriteDataImpl(int index, int offset, IOBuffer* buf, int buf_len, 341 int EntryImpl::WriteDataImpl(int index, int offset, IOBuffer* buf, int buf_len,
337 const CompletionCallback& callback, 342 const CompletionCallback& callback,
338 bool truncate) { 343 bool truncate) {
339 if (net_log_.IsCapturing()) { 344 if (net_log_.IsCapturing()) {
340 net_log_.BeginEvent( 345 net_log_.BeginEvent(
341 net::NetLog::TYPE_ENTRY_WRITE_DATA, 346 net::NetLogEventType::ENTRY_WRITE_DATA,
342 CreateNetLogReadWriteDataCallback(index, offset, buf_len, truncate)); 347 CreateNetLogReadWriteDataCallback(index, offset, buf_len, truncate));
343 } 348 }
344 349
345 int result = InternalWriteData(index, offset, buf, buf_len, callback, 350 int result = InternalWriteData(index, offset, buf, buf_len, callback,
346 truncate); 351 truncate);
347 352
348 if (result != net::ERR_IO_PENDING && net_log_.IsCapturing()) { 353 if (result != net::ERR_IO_PENDING && net_log_.IsCapturing()) {
349 net_log_.EndEvent( 354 net_log_.EndEvent(net::NetLogEventType::ENTRY_WRITE_DATA,
350 net::NetLog::TYPE_ENTRY_WRITE_DATA, 355 CreateNetLogReadWriteCompleteCallback(result));
351 CreateNetLogReadWriteCompleteCallback(result));
352 } 356 }
353 return result; 357 return result;
354 } 358 }
355 359
356 int EntryImpl::ReadSparseDataImpl(int64_t offset, 360 int EntryImpl::ReadSparseDataImpl(int64_t offset,
357 IOBuffer* buf, 361 IOBuffer* buf,
358 int buf_len, 362 int buf_len,
359 const CompletionCallback& callback) { 363 const CompletionCallback& callback) {
360 DCHECK(node_.Data()->dirty || read_only_); 364 DCHECK(node_.Data()->dirty || read_only_);
361 int result = InitSparseData(); 365 int result = InitSparseData();
(...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after
459 463
460 bool EntryImpl::IsSameEntry(const std::string& key, uint32_t hash) { 464 bool EntryImpl::IsSameEntry(const std::string& key, uint32_t hash) {
461 if (entry_.Data()->hash != hash || 465 if (entry_.Data()->hash != hash ||
462 static_cast<size_t>(entry_.Data()->key_len) != key.size()) 466 static_cast<size_t>(entry_.Data()->key_len) != key.size())
463 return false; 467 return false;
464 468
465 return (key.compare(GetKey()) == 0); 469 return (key.compare(GetKey()) == 0);
466 } 470 }
467 471
468 void EntryImpl::InternalDoom() { 472 void EntryImpl::InternalDoom() {
469 net_log_.AddEvent(net::NetLog::TYPE_ENTRY_DOOM); 473 net_log_.AddEvent(net::NetLogEventType::ENTRY_DOOM);
470 DCHECK(node_.HasData()); 474 DCHECK(node_.HasData());
471 if (!node_.Data()->dirty) { 475 if (!node_.Data()->dirty) {
472 node_.Data()->dirty = backend_->GetCurrentEntryId(); 476 node_.Data()->dirty = backend_->GetCurrentEntryId();
473 node_.Store(); 477 node_.Store();
474 } 478 }
475 doomed_ = true; 479 doomed_ = true;
476 } 480 }
477 481
478 void EntryImpl::DeleteEntryData(bool everything) { 482 void EntryImpl::DeleteEntryData(bool everything) {
479 DCHECK(doomed_ || !everything); 483 DCHECK(doomed_ || !everything);
(...skipping 244 matching lines...) Expand 10 before | Expand all | Expand 10 after
724 case kWriteAsync1: 728 case kWriteAsync1:
725 CACHE_UMA(AGE_MS, "AsyncWriteDispatchTime", 0, start); 729 CACHE_UMA(AGE_MS, "AsyncWriteDispatchTime", 0, start);
726 break; 730 break;
727 default: 731 default:
728 NOTREACHED(); 732 NOTREACHED();
729 } 733 }
730 } 734 }
731 735
732 void EntryImpl::BeginLogging(net::NetLog* net_log, bool created) { 736 void EntryImpl::BeginLogging(net::NetLog* net_log, bool created) {
733 DCHECK(!net_log_.net_log()); 737 DCHECK(!net_log_.net_log());
734 net_log_ = net::BoundNetLog::Make( 738 net_log_ =
735 net_log, net::NetLog::SOURCE_DISK_CACHE_ENTRY); 739 net::BoundNetLog::Make(net_log, net::NetLogSourceType::DISK_CACHE_ENTRY);
736 net_log_.BeginEvent( 740 net_log_.BeginEvent(net::NetLogEventType::DISK_CACHE_ENTRY_IMPL,
737 net::NetLog::TYPE_DISK_CACHE_ENTRY_IMPL, 741 CreateNetLogEntryCreationCallback(this, created));
738 CreateNetLogEntryCreationCallback(this, created));
739 } 742 }
740 743
741 const net::BoundNetLog& EntryImpl::net_log() const { 744 const net::BoundNetLog& EntryImpl::net_log() const {
742 return net_log_; 745 return net_log_;
743 } 746 }
744 747
745 // static 748 // static
746 int EntryImpl::NumBlocksForEntry(int key_size) { 749 int EntryImpl::NumBlocksForEntry(int key_size) {
747 // The longest key that can be stored using one block. 750 // The longest key that can be stored using one block.
748 int key1_len = 751 int key1_len =
(...skipping 195 matching lines...) Expand 10 before | Expand all | Expand 10 after
944 947
945 // Remove this entry from the list of open entries. 948 // Remove this entry from the list of open entries.
946 backend_->OnEntryDestroyBegin(entry_.address()); 949 backend_->OnEntryDestroyBegin(entry_.address());
947 950
948 if (doomed_) { 951 if (doomed_) {
949 DeleteEntryData(true); 952 DeleteEntryData(true);
950 } else { 953 } else {
951 #if defined(NET_BUILD_STRESS_CACHE) 954 #if defined(NET_BUILD_STRESS_CACHE)
952 SanityCheck(); 955 SanityCheck();
953 #endif 956 #endif
954 net_log_.AddEvent(net::NetLog::TYPE_ENTRY_CLOSE); 957 net_log_.AddEvent(net::NetLogEventType::ENTRY_CLOSE);
955 bool ret = true; 958 bool ret = true;
956 for (int index = 0; index < kNumStreams; index++) { 959 for (int index = 0; index < kNumStreams; index++) {
957 if (user_buffers_[index].get()) { 960 if (user_buffers_[index].get()) {
958 ret = Flush(index, 0); 961 ret = Flush(index, 0);
959 if (!ret) 962 if (!ret)
960 LOG(ERROR) << "Failed to save user data"; 963 LOG(ERROR) << "Failed to save user data";
961 } 964 }
962 if (unreported_size_[index]) { 965 if (unreported_size_[index]) {
963 backend_->ModifyStorageSize( 966 backend_->ModifyStorageSize(
964 entry_.Data()->data_size[index] - unreported_size_[index], 967 entry_.Data()->data_size[index] - unreported_size_[index],
965 entry_.Data()->data_size[index]); 968 entry_.Data()->data_size[index]);
966 } 969 }
967 } 970 }
968 971
969 if (!ret) { 972 if (!ret) {
970 // There was a failure writing the actual data. Mark the entry as dirty. 973 // There was a failure writing the actual data. Mark the entry as dirty.
971 int current_id = backend_->GetCurrentEntryId(); 974 int current_id = backend_->GetCurrentEntryId();
972 node_.Data()->dirty = current_id == 1 ? -1 : current_id - 1; 975 node_.Data()->dirty = current_id == 1 ? -1 : current_id - 1;
973 node_.Store(); 976 node_.Store();
974 } else if (node_.HasData() && !dirty_ && node_.Data()->dirty) { 977 } else if (node_.HasData() && !dirty_ && node_.Data()->dirty) {
975 node_.Data()->dirty = 0; 978 node_.Data()->dirty = 0;
976 node_.Store(); 979 node_.Store();
977 } 980 }
978 } 981 }
979 982
980 Trace("~EntryImpl out 0x%p", reinterpret_cast<void*>(this)); 983 Trace("~EntryImpl out 0x%p", reinterpret_cast<void*>(this));
981 net_log_.EndEvent(net::NetLog::TYPE_DISK_CACHE_ENTRY_IMPL); 984 net_log_.EndEvent(net::NetLogEventType::DISK_CACHE_ENTRY_IMPL);
982 backend_->OnEntryDestroyEnd(); 985 backend_->OnEntryDestroyEnd();
983 } 986 }
984 987
985 // ------------------------------------------------------------------------ 988 // ------------------------------------------------------------------------
986 989
987 int EntryImpl::InternalReadData(int index, int offset, 990 int EntryImpl::InternalReadData(int index, int offset,
988 IOBuffer* buf, int buf_len, 991 IOBuffer* buf, int buf_len,
989 const CompletionCallback& callback) { 992 const CompletionCallback& callback) {
990 DCHECK(node_.Data()->dirty || read_only_); 993 DCHECK(node_.Data()->dirty || read_only_);
991 DVLOG(2) << "Read from " << index << " at " << offset << " : " << buf_len; 994 DVLOG(2) << "Read from " << index << " at " << offset << " : " << buf_len;
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after
1039 size_t file_offset = offset; 1042 size_t file_offset = offset;
1040 if (address.is_block_file()) { 1043 if (address.is_block_file()) {
1041 DCHECK_LE(offset + buf_len, kMaxBlockSize); 1044 DCHECK_LE(offset + buf_len, kMaxBlockSize);
1042 file_offset += address.start_block() * address.BlockSize() + 1045 file_offset += address.start_block() * address.BlockSize() +
1043 kBlockHeaderSize; 1046 kBlockHeaderSize;
1044 } 1047 }
1045 1048
1046 SyncCallback* io_callback = NULL; 1049 SyncCallback* io_callback = NULL;
1047 if (!callback.is_null()) { 1050 if (!callback.is_null()) {
1048 io_callback = new SyncCallback(this, buf, callback, 1051 io_callback = new SyncCallback(this, buf, callback,
1049 net::NetLog::TYPE_ENTRY_READ_DATA); 1052 net::NetLogEventType::ENTRY_READ_DATA);
1050 } 1053 }
1051 1054
1052 TimeTicks start_async = TimeTicks::Now(); 1055 TimeTicks start_async = TimeTicks::Now();
1053 1056
1054 bool completed; 1057 bool completed;
1055 if (!file->Read(buf->data(), buf_len, file_offset, io_callback, &completed)) { 1058 if (!file->Read(buf->data(), buf_len, file_offset, io_callback, &completed)) {
1056 if (io_callback) 1059 if (io_callback)
1057 io_callback->Discard(); 1060 io_callback->Discard();
1058 DoomImpl(); 1061 DoomImpl();
1059 return net::ERR_CACHE_READ_FAILURE; 1062 return net::ERR_CACHE_READ_FAILURE;
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
1143 if (!file->SetLength(offset + buf_len)) 1146 if (!file->SetLength(offset + buf_len))
1144 return net::ERR_FAILED; 1147 return net::ERR_FAILED;
1145 } 1148 }
1146 1149
1147 if (!buf_len) 1150 if (!buf_len)
1148 return 0; 1151 return 0;
1149 1152
1150 SyncCallback* io_callback = NULL; 1153 SyncCallback* io_callback = NULL;
1151 if (!callback.is_null()) { 1154 if (!callback.is_null()) {
1152 io_callback = new SyncCallback(this, buf, callback, 1155 io_callback = new SyncCallback(this, buf, callback,
1153 net::NetLog::TYPE_ENTRY_WRITE_DATA); 1156 net::NetLogEventType::ENTRY_WRITE_DATA);
1154 } 1157 }
1155 1158
1156 TimeTicks start_async = TimeTicks::Now(); 1159 TimeTicks start_async = TimeTicks::Now();
1157 1160
1158 bool completed; 1161 bool completed;
1159 if (!file->Write(buf->data(), buf_len, file_offset, io_callback, 1162 if (!file->Write(buf->data(), buf_len, file_offset, io_callback,
1160 &completed)) { 1163 &completed)) {
1161 if (io_callback) 1164 if (io_callback)
1162 io_callback->Discard(); 1165 io_callback->Discard();
1163 return net::ERR_CACHE_WRITE_FAILURE; 1166 return net::ERR_CACHE_WRITE_FAILURE;
(...skipping 394 matching lines...) Expand 10 before | Expand all | Expand 10 after
1558 Trace("%s 0x%p 0x%x 0x%x", msg, reinterpret_cast<void*>(this), 1561 Trace("%s 0x%p 0x%x 0x%x", msg, reinterpret_cast<void*>(this),
1559 entry_.address().value(), node_.address().value()); 1562 entry_.address().value(), node_.address().value());
1560 1563
1561 Trace(" data: 0x%x 0x%x 0x%x", entry_.Data()->data_addr[0], 1564 Trace(" data: 0x%x 0x%x 0x%x", entry_.Data()->data_addr[0],
1562 entry_.Data()->data_addr[1], entry_.Data()->long_key); 1565 entry_.Data()->data_addr[1], entry_.Data()->long_key);
1563 1566
1564 Trace(" doomed: %d 0x%x", doomed_, dirty); 1567 Trace(" doomed: %d 0x%x", doomed_, dirty);
1565 } 1568 }
1566 1569
1567 } // namespace disk_cache 1570 } // namespace disk_cache
OLDNEW
« no previous file with comments | « net/cert/multi_threaded_cert_verifier.cc ('k') | net/disk_cache/blockfile/sparse_control.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698