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

Unified Diff: net/disk_cache/entry_impl.cc

Issue 6005015: Revert 70618 - First pass at adding http/backend cache events to the NetLog. ... (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src/
Patch Set: Created 9 years, 11 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/disk_cache/entry_impl.h ('k') | net/disk_cache/sparse_control.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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) {
« no previous file with comments | « net/disk_cache/entry_impl.h ('k') | net/disk_cache/sparse_control.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698