| Index: net/disk_cache/entry_impl.cc
|
| ===================================================================
|
| --- net/disk_cache/entry_impl.cc (revision 70618)
|
| +++ net/disk_cache/entry_impl.cc (working copy)
|
| @@ -7,7 +7,6 @@
|
| #include "base/message_loop.h"
|
| #include "base/metrics/histogram.h"
|
| #include "base/string_util.h"
|
| -#include "base/values.h"
|
| #include "net/base/io_buffer.h"
|
| #include "net/base/net_errors.h"
|
| #include "net/disk_cache/backend_impl.h"
|
| @@ -25,93 +24,14 @@
|
| // Index for the file used to store the key, if any (files_[kKeyFileIndex]).
|
| const int kKeyFileIndex = 3;
|
|
|
| -// NetLog parameters for the creation of an EntryImpl. Contains an entry's name
|
| -// and whether it was created or opened.
|
| -class EntryCreationParameters : public net::NetLog::EventParameters {
|
| - public:
|
| - EntryCreationParameters(const std::string& key, bool created)
|
| - : key_(key), created_(created) {
|
| - }
|
| -
|
| - Value* ToValue() const {
|
| - DictionaryValue* dict = new DictionaryValue();
|
| - dict->SetString("key", key_);
|
| - dict->SetBoolean("created", created_);
|
| - return dict;
|
| - }
|
| -
|
| - private:
|
| - const std::string key_;
|
| - const bool created_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(EntryCreationParameters);
|
| -};
|
| -
|
| -// NetLog parameters for non-sparse reading and writing to an EntryImpl.
|
| -class ReadWriteDataParams : public net::NetLog::EventParameters {
|
| - public:
|
| - // For reads, |truncate| must be false.
|
| - ReadWriteDataParams(int index, int offset, int buf_len, bool truncate)
|
| - : index_(index), offset_(offset), buf_len_(buf_len), truncate_(truncate) {
|
| - }
|
| -
|
| - Value* ToValue() const {
|
| - DictionaryValue* dict = new DictionaryValue();
|
| - dict->SetInteger("index", index_);
|
| - dict->SetInteger("offset", offset_);
|
| - dict->SetInteger("buf_len", buf_len_);
|
| - if (truncate_)
|
| - dict->SetBoolean("truncate", truncate_);
|
| - return dict;
|
| - }
|
| -
|
| - private:
|
| - const int index_;
|
| - const int offset_;
|
| - const int buf_len_;
|
| - const bool truncate_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(ReadWriteDataParams);
|
| -};
|
| -
|
| -// NetLog parameters logged when non-sparse reads and writes complete.
|
| -class FileIOCompleteParameters : public net::NetLog::EventParameters {
|
| - public:
|
| - // |bytes_copied| is either the number of bytes copied or a network error
|
| - // code. |bytes_copied| must not be ERR_IO_PENDING, as it's not a valid
|
| - // result for an operation.
|
| - explicit FileIOCompleteParameters(int bytes_copied)
|
| - : bytes_copied_(bytes_copied) {
|
| - }
|
| -
|
| - Value* ToValue() const {
|
| - DCHECK_NE(bytes_copied_, net::ERR_IO_PENDING);
|
| - DictionaryValue* dict = new DictionaryValue();
|
| - if (bytes_copied_ < 0) {
|
| - dict->SetInteger("net_error", bytes_copied_);
|
| - } else {
|
| - dict->SetInteger("bytes_copied", bytes_copied_);
|
| - }
|
| - return dict;
|
| - }
|
| -
|
| - private:
|
| - const int bytes_copied_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(FileIOCompleteParameters);
|
| -};
|
| -
|
| // This class implements FileIOCallback to buffer the callback from a file IO
|
| // operation from the actual net class.
|
| class SyncCallback: public disk_cache::FileIOCallback {
|
| public:
|
| - // |end_event_type| is the event type to log on completion. Logs nothing on
|
| - // discard, or when the NetLog is not set to log all events.
|
| SyncCallback(disk_cache::EntryImpl* entry, net::IOBuffer* buffer,
|
| - net::CompletionCallback* callback,
|
| - net::NetLog::EventType end_event_type)
|
| + net::CompletionCallback* callback )
|
| : entry_(entry), callback_(callback), buf_(buffer),
|
| - start_(TimeTicks::Now()), end_event_type_(end_event_type) {
|
| + start_(TimeTicks::Now()) {
|
| entry->AddRef();
|
| entry->IncrementIoCount();
|
| }
|
| @@ -119,13 +39,11 @@
|
|
|
| virtual void OnFileIOComplete(int bytes_copied);
|
| void Discard();
|
| -
|
| private:
|
| disk_cache::EntryImpl* entry_;
|
| net::CompletionCallback* callback_;
|
| scoped_refptr<net::IOBuffer> buf_;
|
| TimeTicks start_;
|
| - net::NetLog::EventType end_event_type_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(SyncCallback);
|
| };
|
| @@ -133,11 +51,6 @@
|
| void SyncCallback::OnFileIOComplete(int bytes_copied) {
|
| entry_->DecrementIoCount();
|
| if (callback_) {
|
| - if (entry_->net_log().IsLoggingAllEvents()) {
|
| - entry_->net_log().EndEvent(
|
| - end_event_type_,
|
| - make_scoped_refptr(new FileIOCompleteParameters(bytes_copied)));
|
| - }
|
| entry_->ReportIOTime(disk_cache::EntryImpl::kAsyncIO, start_);
|
| callback_->Run(bytes_copied);
|
| }
|
| @@ -395,7 +308,6 @@
|
| if (doomed_) {
|
| DeleteEntryData(true);
|
| } else {
|
| - net_log_.AddEvent(net::NetLog::TYPE_DISK_CACHE_CLOSE, NULL);
|
| bool ret = true;
|
| for (int index = 0; index < kNumStreams; index++) {
|
| if (user_buffers_[index].get()) {
|
| @@ -421,7 +333,6 @@
|
| }
|
|
|
| Trace("~EntryImpl out 0x%p", reinterpret_cast<void*>(this));
|
| - net_log_.EndEvent(net::NetLog::TYPE_DISK_CACHE_ENTRY, NULL);
|
| backend_->OnEntryDestroyEnd();
|
| }
|
|
|
| @@ -576,46 +487,6 @@
|
|
|
| int EntryImpl::ReadDataImpl(int index, int offset, net::IOBuffer* buf,
|
| int buf_len, CompletionCallback* callback) {
|
| - if (net_log_.IsLoggingAllEvents()) {
|
| - net_log_.BeginEvent(
|
| - net::NetLog::TYPE_DISK_CACHE_READ_DATA,
|
| - make_scoped_refptr(
|
| - new ReadWriteDataParams(index, offset, buf_len, false)));
|
| - }
|
| -
|
| - int result = InternalReadData(index, offset, buf, buf_len, callback);
|
| -
|
| - if (result != net::ERR_IO_PENDING && net_log_.IsLoggingAllEvents()) {
|
| - net_log_.EndEvent(
|
| - net::NetLog::TYPE_DISK_CACHE_READ_DATA,
|
| - make_scoped_refptr(new FileIOCompleteParameters(result)));
|
| - }
|
| - return result;
|
| -}
|
| -
|
| -int EntryImpl::WriteDataImpl(int index, int offset, net::IOBuffer* buf,
|
| - int buf_len, CompletionCallback* callback,
|
| - bool truncate) {
|
| - if (net_log_.IsLoggingAllEvents()) {
|
| - net_log_.BeginEvent(
|
| - net::NetLog::TYPE_DISK_CACHE_WRITE_DATA,
|
| - make_scoped_refptr(
|
| - new ReadWriteDataParams(index, offset, buf_len, truncate)));
|
| - }
|
| -
|
| - int result = InternalWriteData(index, offset, buf, buf_len, callback,
|
| - truncate);
|
| -
|
| - if (result != net::ERR_IO_PENDING && net_log_.IsLoggingAllEvents()) {
|
| - net_log_.EndEvent(
|
| - net::NetLog::TYPE_DISK_CACHE_WRITE_DATA,
|
| - make_scoped_refptr(new FileIOCompleteParameters(result)));
|
| - }
|
| - return result;
|
| -}
|
| -
|
| -int EntryImpl::InternalReadData(int index, int offset, net::IOBuffer* buf,
|
| - int buf_len, CompletionCallback* callback) {
|
| DCHECK(node_.Data()->dirty || read_only_);
|
| DVLOG(2) << "Read from " << index << " at " << offset << " : " << buf_len;
|
| if (index < 0 || index >= kNumStreams)
|
| @@ -665,10 +536,8 @@
|
| }
|
|
|
| SyncCallback* io_callback = NULL;
|
| - if (callback) {
|
| - io_callback = new SyncCallback(this, buf, callback,
|
| - net::NetLog::TYPE_DISK_CACHE_READ_DATA);
|
| - }
|
| + if (callback)
|
| + io_callback = new SyncCallback(this, buf, callback);
|
|
|
| bool completed;
|
| if (!file->Read(buf->data(), buf_len, file_offset, io_callback, &completed)) {
|
| @@ -684,9 +553,9 @@
|
| return (completed || !callback) ? buf_len : net::ERR_IO_PENDING;
|
| }
|
|
|
| -int EntryImpl::InternalWriteData(int index, int offset, net::IOBuffer* buf,
|
| - int buf_len, CompletionCallback* callback,
|
| - bool truncate) {
|
| +int EntryImpl::WriteDataImpl(int index, int offset, net::IOBuffer* buf,
|
| + int buf_len, CompletionCallback* callback,
|
| + bool truncate) {
|
| DCHECK(node_.Data()->dirty || read_only_);
|
| DVLOG(2) << "Write to " << index << " at " << offset << " : " << buf_len;
|
| if (index < 0 || index >= kNumStreams)
|
| @@ -759,10 +628,8 @@
|
| return 0;
|
|
|
| SyncCallback* io_callback = NULL;
|
| - if (callback) {
|
| - io_callback = new SyncCallback(this, buf, callback,
|
| - net::NetLog::TYPE_DISK_CACHE_WRITE_DATA);
|
| - }
|
| + if (callback)
|
| + io_callback = new SyncCallback(this, buf, callback);
|
|
|
| bool completed;
|
| if (!file->Write(buf->data(), buf_len, file_offset, io_callback,
|
| @@ -890,7 +757,6 @@
|
| }
|
|
|
| void EntryImpl::InternalDoom() {
|
| - net_log_.AddEvent(net::NetLog::TYPE_DISK_CACHE_DOOM, NULL);
|
| DCHECK(node_.HasData());
|
| if (!node_.Data()->dirty) {
|
| node_.Data()->dirty = backend_->GetCurrentEntryId();
|
| @@ -1048,19 +914,6 @@
|
| }
|
| }
|
|
|
| -void EntryImpl::BeginLogging(net::NetLog* net_log, bool created) {
|
| - DCHECK(!net_log_.net_log());
|
| - net_log_ = net::BoundNetLog::Make(
|
| - net_log, net::NetLog::SOURCE_DISK_CACHE_ENTRY);
|
| - net_log_.BeginEvent(
|
| - net::NetLog::TYPE_DISK_CACHE_ENTRY,
|
| - make_scoped_refptr(new EntryCreationParameters(GetKey(), created)));
|
| -}
|
| -
|
| -const net::BoundNetLog& EntryImpl::net_log() const {
|
| - return net_log_;
|
| -}
|
| -
|
| // ------------------------------------------------------------------------
|
|
|
| bool EntryImpl::CreateDataBlock(int index, int size) {
|
|
|