From 243f86a720537c56e0b148e4277cfe319310cbd3 Mon Sep 17 00:00:00 2001 From: "darin@google.com" Date: Sat, 9 Aug 2008 08:35:25 +0000 Subject: rollback r526 to fix performance regression git-svn-id: svn://svn.chromium.org/chrome/trunk/src@632 0039d316-1c4b-4281-b951-d872f2087c98 --- net/url_request/url_request_file_job.cc | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) (limited to 'net/url_request/url_request_file_job.cc') diff --git a/net/url_request/url_request_file_job.cc b/net/url_request/url_request_file_job.cc index 9f828d4..a738b3a 100644 --- a/net/url_request/url_request_file_job.cc +++ b/net/url_request/url_request_file_job.cc @@ -40,7 +40,7 @@ // attempts to read more from the file to fill its buffer. If reading from the // file does not complete synchronously, then the URLRequestFileJob waits for a // signal from the OS that the overlapped read has completed. It does so by -// leveraging the ObjectWatcher API. +// leveraging the MessageLoop::WatchObject API. #include #include @@ -57,7 +57,6 @@ #include "net/url_request/url_request.h" #include "net/url_request/url_request_file_dir_job.h" -// TODO(darin): The file job should not depend on WinInet!! using net::WinInetUtil; namespace { @@ -166,7 +165,7 @@ void URLRequestFileJob::Start() { void URLRequestFileJob::Kill() { // If we are killed while waiting for an overlapped result... if (is_waiting_) { - watcher_.StopWatching(); + MessageLoop::current()->WatchObject(overlapped_.hEvent, NULL); is_waiting_ = false; Release(); } @@ -204,7 +203,7 @@ bool URLRequestFileJob::ReadRawData(char* dest, int dest_size, DWORD err = GetLastError(); if (err == ERROR_IO_PENDING) { // OK, wait for the object to become signaled - watcher_.StartWatching(overlapped_.hEvent, this); + MessageLoop::current()->WatchObject(overlapped_.hEvent, this); is_waiting_ = true; SetStatus(URLRequestStatus(URLRequestStatus::IO_PENDING, 0)); AddRef(); @@ -285,7 +284,9 @@ void URLRequestFileJob::OnObjectSignaled(HANDLE object) { DCHECK(overlapped_.hEvent == object); DCHECK(is_waiting_); - // We'll resume watching this handle if need be when we do another IO. + // We'll resume watching this handle if need be when we do + // another IO. + MessageLoop::current()->WatchObject(object, NULL); is_waiting_ = false; DWORD bytes_read = 0; -- cgit v1.1