| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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/proxy/proxy_resolver_v8_tracing.h" | 5 #include "net/proxy/proxy_resolver_v8_tracing.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 107 void Alert(const base::string16& message) override { | 107 void Alert(const base::string16& message) override { |
| 108 DCHECK(thread_checker_.CalledOnValidThread()); | 108 DCHECK(thread_checker_.CalledOnValidThread()); |
| 109 bindings_->Alert(message); | 109 bindings_->Alert(message); |
| 110 } | 110 } |
| 111 | 111 |
| 112 void OnError(int line_number, const base::string16& error) override { | 112 void OnError(int line_number, const base::string16& error) override { |
| 113 DCHECK(thread_checker_.CalledOnValidThread()); | 113 DCHECK(thread_checker_.CalledOnValidThread()); |
| 114 bindings_->OnError(line_number, error); | 114 bindings_->OnError(line_number, error); |
| 115 } | 115 } |
| 116 | 116 |
| 117 BoundNetLog GetBoundNetLog() override { | 117 NetLogWithSource GetNetLogWithSource() override { |
| 118 DCHECK(thread_checker_.CalledOnValidThread()); | 118 DCHECK(thread_checker_.CalledOnValidThread()); |
| 119 return BoundNetLog(); | 119 return NetLogWithSource(); |
| 120 } | 120 } |
| 121 | 121 |
| 122 HostResolver* GetHostResolver() override { | 122 HostResolver* GetHostResolver() override { |
| 123 DCHECK(thread_checker_.CalledOnValidThread()); | 123 DCHECK(thread_checker_.CalledOnValidThread()); |
| 124 return bindings_->host_resolver(); | 124 return bindings_->host_resolver(); |
| 125 } | 125 } |
| 126 | 126 |
| 127 private: | 127 private: |
| 128 MockBindings* bindings_; | 128 MockBindings* bindings_; |
| 129 base::ThreadChecker thread_checker_; | 129 base::ThreadChecker thread_checker_; |
| (...skipping 549 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 679 class BlockableHostResolver : public HostResolver { | 679 class BlockableHostResolver : public HostResolver { |
| 680 public: | 680 public: |
| 681 BlockableHostResolver() | 681 BlockableHostResolver() |
| 682 : num_cancelled_requests_(0), waiting_for_resolve_(false) {} | 682 : num_cancelled_requests_(0), waiting_for_resolve_(false) {} |
| 683 | 683 |
| 684 int Resolve(const RequestInfo& info, | 684 int Resolve(const RequestInfo& info, |
| 685 RequestPriority priority, | 685 RequestPriority priority, |
| 686 AddressList* addresses, | 686 AddressList* addresses, |
| 687 const CompletionCallback& callback, | 687 const CompletionCallback& callback, |
| 688 std::unique_ptr<Request>* out_req, | 688 std::unique_ptr<Request>* out_req, |
| 689 const BoundNetLog& net_log) override { | 689 const NetLogWithSource& net_log) override { |
| 690 EXPECT_FALSE(callback.is_null()); | 690 EXPECT_FALSE(callback.is_null()); |
| 691 EXPECT_TRUE(out_req); | 691 EXPECT_TRUE(out_req); |
| 692 | 692 |
| 693 if (!action_.is_null()) | 693 if (!action_.is_null()) |
| 694 action_.Run(); | 694 action_.Run(); |
| 695 | 695 |
| 696 // Indicate to the caller that a request was received. | 696 // Indicate to the caller that a request was received. |
| 697 EXPECT_TRUE(waiting_for_resolve_); | 697 EXPECT_TRUE(waiting_for_resolve_); |
| 698 base::MessageLoop::current()->QuitWhenIdle(); | 698 base::MessageLoop::current()->QuitWhenIdle(); |
| 699 | 699 |
| 700 // This line is intentionally after action_.Run(), since one of the | 700 // This line is intentionally after action_.Run(), since one of the |
| 701 // tests does a cancellation inside of Resolve(), and it is more | 701 // tests does a cancellation inside of Resolve(), and it is more |
| 702 // interesting if *out_req hasn't been written yet at that point. | 702 // interesting if *out_req hasn't been written yet at that point. |
| 703 out_req->reset(new RequestImpl(this)); | 703 out_req->reset(new RequestImpl(this)); |
| 704 | 704 |
| 705 // Return ERR_IO_PENDING as this request will NEVER be completed. | 705 // Return ERR_IO_PENDING as this request will NEVER be completed. |
| 706 // Expectation is for the caller to later cancel the request. | 706 // Expectation is for the caller to later cancel the request. |
| 707 return ERR_IO_PENDING; | 707 return ERR_IO_PENDING; |
| 708 } | 708 } |
| 709 | 709 |
| 710 int ResolveFromCache(const RequestInfo& info, | 710 int ResolveFromCache(const RequestInfo& info, |
| 711 AddressList* addresses, | 711 AddressList* addresses, |
| 712 const BoundNetLog& net_log) override { | 712 const NetLogWithSource& net_log) override { |
| 713 NOTREACHED(); | 713 NOTREACHED(); |
| 714 return ERR_DNS_CACHE_MISS; | 714 return ERR_DNS_CACHE_MISS; |
| 715 } | 715 } |
| 716 | 716 |
| 717 void IncreaseNumOfCancelledRequests() { num_cancelled_requests_++; } | 717 void IncreaseNumOfCancelledRequests() { num_cancelled_requests_++; } |
| 718 | 718 |
| 719 void SetAction(const base::Callback<void(void)>& action) { | 719 void SetAction(const base::Callback<void(void)>& action) { |
| 720 action_ = action; | 720 action_ = action; |
| 721 } | 721 } |
| 722 | 722 |
| (...skipping 312 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1035 proxy_uri.substr(0, proxy_uri.find(':') + 1)); | 1035 proxy_uri.substr(0, proxy_uri.find(':') + 1)); |
| 1036 } else { | 1036 } else { |
| 1037 NOTREACHED(); | 1037 NOTREACHED(); |
| 1038 } | 1038 } |
| 1039 } | 1039 } |
| 1040 } | 1040 } |
| 1041 | 1041 |
| 1042 } // namespace | 1042 } // namespace |
| 1043 | 1043 |
| 1044 } // namespace net | 1044 } // namespace net |
| OLD | NEW |