1 // Copyright 2011 The Chromium Authors
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "net/proxy_resolution/network_delegate_error_observer.h"
6
7 #include "base/functional/bind.h"
8 #include "base/location.h"
9 #include "base/memory/raw_ptr.h"
10 #include "base/task/single_thread_task_runner.h"
11 #include "net/base/net_errors.h"
12 #include "net/base/network_delegate.h"
13
14 namespace net {
15
16 // NetworkDelegateErrorObserver::Core -----------------------------------------
17
18 class NetworkDelegateErrorObserver::Core
19 : public base::RefCountedThreadSafe<NetworkDelegateErrorObserver::Core> {
20 public:
21 Core(NetworkDelegate* network_delegate,
22 base::SingleThreadTaskRunner* origin_runner);
23
24 Core(const Core&) = delete;
25 Core& operator=(const Core&) = delete;
26
27 void NotifyPACScriptError(int line_number, const std::u16string& error);
28
29 void Shutdown();
30
31 private:
32 friend class base::RefCountedThreadSafe<NetworkDelegateErrorObserver::Core>;
33
34 virtual ~Core();
35
36 raw_ptr<NetworkDelegate> network_delegate_;
37 scoped_refptr<base::SingleThreadTaskRunner> origin_runner_;
38 };
39
Core(NetworkDelegate * network_delegate,base::SingleThreadTaskRunner * origin_runner)40 NetworkDelegateErrorObserver::Core::Core(
41 NetworkDelegate* network_delegate,
42 base::SingleThreadTaskRunner* origin_runner)
43 : network_delegate_(network_delegate), origin_runner_(origin_runner) {
44 DCHECK(origin_runner);
45 }
46
47 NetworkDelegateErrorObserver::Core::~Core() = default;
48
NotifyPACScriptError(int line_number,const std::u16string & error)49 void NetworkDelegateErrorObserver::Core::NotifyPACScriptError(
50 int line_number,
51 const std::u16string& error) {
52 if (!origin_runner_->BelongsToCurrentThread()) {
53 origin_runner_->PostTask(
54 FROM_HERE,
55 base::BindOnce(&Core::NotifyPACScriptError, this, line_number, error));
56 return;
57 }
58 if (network_delegate_)
59 network_delegate_->NotifyPACScriptError(line_number, error);
60 }
61
Shutdown()62 void NetworkDelegateErrorObserver::Core::Shutdown() {
63 CHECK(origin_runner_->BelongsToCurrentThread());
64 network_delegate_ = nullptr;
65 }
66
67 // NetworkDelegateErrorObserver -----------------------------------------------
68
NetworkDelegateErrorObserver(NetworkDelegate * network_delegate,base::SingleThreadTaskRunner * origin_runner)69 NetworkDelegateErrorObserver::NetworkDelegateErrorObserver(
70 NetworkDelegate* network_delegate,
71 base::SingleThreadTaskRunner* origin_runner)
72 : core_(base::MakeRefCounted<Core>(network_delegate, origin_runner)) {}
73
~NetworkDelegateErrorObserver()74 NetworkDelegateErrorObserver::~NetworkDelegateErrorObserver() {
75 core_->Shutdown();
76 }
77
78 // static
79 std::unique_ptr<ProxyResolverErrorObserver>
Create(NetworkDelegate * network_delegate,const scoped_refptr<base::SingleThreadTaskRunner> & origin_runner)80 NetworkDelegateErrorObserver::Create(
81 NetworkDelegate* network_delegate,
82 const scoped_refptr<base::SingleThreadTaskRunner>& origin_runner) {
83 return std::make_unique<NetworkDelegateErrorObserver>(network_delegate,
84 origin_runner.get());
85 }
86
OnPACScriptError(int line_number,const std::u16string & error)87 void NetworkDelegateErrorObserver::OnPACScriptError(
88 int line_number,
89 const std::u16string& error) {
90 core_->NotifyPACScriptError(line_number, error);
91 }
92
93 } // namespace net
94