Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2006-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 "net/base/host_resolver_impl.h" | 5 #include "net/base/host_resolver_impl.h" |
| 6 | 6 |
| 7 #if defined(OS_WIN) | 7 #if defined(OS_WIN) |
| 8 #include <ws2tcpip.h> | 8 #include <ws2tcpip.h> |
| 9 #include <wspiapi.h> // Needed for Win2k compat. | 9 #include <wspiapi.h> // Needed for Win2k compat. |
| 10 #elif defined(OS_POSIX) | 10 #elif defined(OS_POSIX) |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 66 job_(NULL), | 66 job_(NULL), |
| 67 callback_(callback), | 67 callback_(callback), |
| 68 addresses_(addresses) { | 68 addresses_(addresses) { |
| 69 } | 69 } |
| 70 | 70 |
| 71 // Mark the request as cancelled. | 71 // Mark the request as cancelled. |
| 72 void MarkAsCancelled() { | 72 void MarkAsCancelled() { |
| 73 job_ = NULL; | 73 job_ = NULL; |
| 74 callback_ = NULL; | 74 callback_ = NULL; |
| 75 addresses_ = NULL; | 75 addresses_ = NULL; |
| 76 // Clear the LoadLog to make sure it won't be released later on the | |
|
wtc
2009/09/21 18:14:12
Do you mean clearing the load log (i.e., emptying
| |
| 77 // worker thread. See http://crbug.com/22272 | |
| 78 load_log_ = NULL; | |
| 76 } | 79 } |
| 77 | 80 |
| 78 bool was_cancelled() const { | 81 bool was_cancelled() const { |
| 79 return callback_ == NULL; | 82 return callback_ == NULL; |
| 80 } | 83 } |
| 81 | 84 |
| 82 void set_job(Job* job) { | 85 void set_job(Job* job) { |
| 83 DCHECK(job != NULL); | 86 DCHECK(job != NULL); |
| 84 // Identify which job the request is waiting on. | 87 // Identify which job the request is waiting on. |
| 85 job_ = job; | 88 job_ = job; |
| (...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 180 HostResolver* resolver = resolver_; | 183 HostResolver* resolver = resolver_; |
| 181 resolver_ = NULL; | 184 resolver_ = NULL; |
| 182 | 185 |
| 183 // Mark the job as cancelled, so when worker thread completes it will | 186 // Mark the job as cancelled, so when worker thread completes it will |
| 184 // not try to post completion to origin loop. | 187 // not try to post completion to origin loop. |
| 185 { | 188 { |
| 186 AutoLock locked(origin_loop_lock_); | 189 AutoLock locked(origin_loop_lock_); |
| 187 origin_loop_ = NULL; | 190 origin_loop_ = NULL; |
| 188 } | 191 } |
| 189 | 192 |
| 190 // We don't have to do anything further to actually cancel the requests | 193 // We will call HostResolverImpl::CancelRequest(Request*) on each one |
| 191 // that were attached to this job (since they are unreachable now). | 194 // in order to notify any observers, and also clear the LoadLog. |
| 192 // But we will call HostResolverImpl::CancelRequest(Request*) on each one | |
| 193 // in order to notify any observers. | |
| 194 for (RequestsList::const_iterator it = requests_.begin(); | 195 for (RequestsList::const_iterator it = requests_.begin(); |
| 195 it != requests_.end(); ++it) { | 196 it != requests_.end(); ++it) { |
| 196 HostResolverImpl::Request* req = *it; | 197 HostResolverImpl::Request* req = *it; |
| 197 if (!req->was_cancelled()) | 198 if (!req->was_cancelled()) |
| 198 resolver->CancelRequest(req); | 199 resolver->CancelRequest(req); |
| 199 } | 200 } |
| 200 } | 201 } |
| 201 | 202 |
| 202 // Called from origin thread. | 203 // Called from origin thread. |
| 203 bool was_cancelled() const { | 204 bool was_cancelled() const { |
| (...skipping 184 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 388 // TODO(eroman): temp hack for: http://crbug.com/18373 | 389 // TODO(eroman): temp hack for: http://crbug.com/18373 |
| 389 // Because we destroy outstanding requests during Shutdown(), | 390 // Because we destroy outstanding requests during Shutdown(), |
| 390 // |req_handle| is already cancelled. | 391 // |req_handle| is already cancelled. |
| 391 LOG(ERROR) << "Called HostResolverImpl::CancelRequest() after Shutdown()."; | 392 LOG(ERROR) << "Called HostResolverImpl::CancelRequest() after Shutdown()."; |
| 392 StackTrace().PrintBacktrace(); | 393 StackTrace().PrintBacktrace(); |
| 393 return; | 394 return; |
| 394 } | 395 } |
| 395 Request* req = reinterpret_cast<Request*>(req_handle); | 396 Request* req = reinterpret_cast<Request*>(req_handle); |
| 396 DCHECK(req); | 397 DCHECK(req); |
| 397 DCHECK(req->job()); | 398 DCHECK(req->job()); |
| 399 // Hold a reference to the request's load log as we are about to clear it. | |
|
wtc
2009/09/21 18:14:12
Nit: it's not clear what "it" refers to here. Do
| |
| 400 scoped_refptr<LoadLog> load_log(req->load_log()); | |
| 398 // NULL out the fields of req, to mark it as cancelled. | 401 // NULL out the fields of req, to mark it as cancelled. |
| 399 req->MarkAsCancelled(); | 402 req->MarkAsCancelled(); |
| 400 OnCancelRequest(req->load_log(), req->id(), req->info()); | 403 OnCancelRequest(load_log, req->id(), req->info()); |
| 401 } | 404 } |
| 402 | 405 |
| 403 void HostResolverImpl::AddObserver(Observer* observer) { | 406 void HostResolverImpl::AddObserver(Observer* observer) { |
| 404 observers_.push_back(observer); | 407 observers_.push_back(observer); |
| 405 } | 408 } |
| 406 | 409 |
| 407 void HostResolverImpl::RemoveObserver(Observer* observer) { | 410 void HostResolverImpl::RemoveObserver(Observer* observer) { |
| 408 ObserversList::iterator it = | 411 ObserversList::iterator it = |
| 409 std::find(observers_.begin(), observers_.end(), observer); | 412 std::find(observers_.begin(), observers_.end(), observer); |
| 410 | 413 |
| (...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 541 } | 544 } |
| 542 | 545 |
| 543 LoadLog::EndEvent( | 546 LoadLog::EndEvent( |
| 544 load_log, LoadLog::TYPE_HOST_RESOLVER_IMPL_OBSERVER_ONCANCEL); | 547 load_log, LoadLog::TYPE_HOST_RESOLVER_IMPL_OBSERVER_ONCANCEL); |
| 545 } | 548 } |
| 546 | 549 |
| 547 LoadLog::EndEvent(load_log, LoadLog::TYPE_HOST_RESOLVER_IMPL); | 550 LoadLog::EndEvent(load_log, LoadLog::TYPE_HOST_RESOLVER_IMPL); |
| 548 } | 551 } |
| 549 | 552 |
| 550 } // namespace net | 553 } // namespace net |
| OLD | NEW |