Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #ifndef CHROME_BROWSER_EXTENSIONS_API_DIAL_DIAL_API_H_ | 5 #ifndef CHROME_BROWSER_EXTENSIONS_API_DIAL_DIAL_API_H_ |
| 6 #define CHROME_BROWSER_EXTENSIONS_API_DIAL_DIAL_API_H_ | 6 #define CHROME_BROWSER_EXTENSIONS_API_DIAL_DIAL_API_H_ |
| 7 | 7 |
| 8 #include <memory> | 8 #include <memory> |
| 9 | 9 |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| 11 #include "chrome/browser/extensions/api/dial/dial_device_data.h" | 11 #include "chrome/browser/extensions/api/dial/dial_device_data.h" |
| 12 #include "chrome/browser/extensions/api/dial/dial_registry.h" | 12 #include "chrome/browser/extensions/api/dial/dial_registry.h" |
| 13 #include "chrome/common/extensions/api/dial.h" | |
| 13 #include "components/keyed_service/core/refcounted_keyed_service.h" | 14 #include "components/keyed_service/core/refcounted_keyed_service.h" |
| 14 #include "extensions/browser/api/async_api_function.h" | 15 #include "extensions/browser/api/async_api_function.h" |
| 15 #include "extensions/browser/event_router.h" | 16 #include "extensions/browser/event_router.h" |
| 16 | 17 |
| 17 namespace extensions { | 18 namespace extensions { |
| 18 | 19 |
| 19 namespace api { | 20 namespace api { |
| 20 namespace dial { | 21 namespace dial { |
| 21 class DialRegistry; | 22 class DeviceDescriptionFetcher; |
| 22 } // namespace dial | 23 } // namespace dial |
| 23 } // namespace api | 24 } // namespace api |
| 24 | 25 |
| 26 class DialFetchDeviceDescriptionFunction; | |
| 27 | |
| 25 // Dial API which is a ref-counted KeyedService that manages | 28 // Dial API which is a ref-counted KeyedService that manages |
| 26 // the DIAL registry. It takes care of creating the registry on the IO thread | 29 // the DIAL registry. It takes care of creating the registry on the IO thread |
| 27 // and is an observer of the registry. It makes sure devices events are sent out | 30 // and is an observer of the registry. It makes sure devices events are sent out |
| 28 // to extension listeners on the right thread. | 31 // to extension listeners on the right thread. |
| 29 // | 32 // |
| 30 // TODO(mfoltz): This should probably inherit from BrowserContextKeyedAPI | 33 // TODO(mfoltz): This should probably inherit from BrowserContextKeyedAPI |
| 31 // instead; ShutdownOnUIThread below is a no-op, which is the whole point of | 34 // instead; ShutdownOnUIThread below is a no-op, which is the whole point of |
| 32 // RefcountedKeyedService. | 35 // RefcountedKeyedService. |
| 36 // | |
| 37 // TODO(mfoltz): The threading model for this API needs to be rethought. At a | |
| 38 // minimum, DialRegistry should move to the UI thread to avoid extra thread hops | |
| 39 // here, allow a straightforward GetDeviceList implementation | |
| 40 // (crbug.com/576817), cleanup some long-tail crashes (crbug.com/640011) that | |
| 41 // are likely due to lifetime issues, and simplify unit tests | |
| 42 // (crbug.com/661457). | |
| 33 class DialAPI : public RefcountedKeyedService, | 43 class DialAPI : public RefcountedKeyedService, |
| 34 public EventRouter::Observer, | 44 public EventRouter::Observer, |
| 35 public api::dial::DialRegistry::Observer { | 45 public api::dial::DialRegistry::Observer { |
| 36 public: | 46 public: |
| 37 explicit DialAPI(Profile* profile); | 47 explicit DialAPI(Profile* profile); |
| 38 | 48 |
| 39 // The DialRegistry for the API. This must always be used only from the IO | 49 // The DialRegistry for the API. This must always be used only from the IO |
| 40 // thread. | 50 // thread. |
| 41 api::dial::DialRegistry* dial_registry(); | 51 api::dial::DialRegistry* dial_registry(); |
| 42 | 52 |
| 43 // Called by the DialRegistry on the IO thread so that the DialAPI dispatches | 53 // Called by the DialRegistry on the IO thread so that the DialAPI dispatches |
| 44 // the event to listeners on the UI thread. | 54 // the event to listeners on the UI thread. |
| 45 void SendEventOnUIThread(const api::dial::DialRegistry::DeviceList& devices); | 55 void SendEventOnUIThread(const api::dial::DialRegistry::DeviceList& devices); |
| 46 void SendErrorOnUIThread(const api::dial::DialRegistry::DialErrorCode type); | 56 void SendErrorOnUIThread(const api::dial::DialRegistry::DialErrorCode type); |
| 47 | 57 |
| 58 // Sets test device data. For tests only. | |
|
Wez
2017/01/05 22:29:24
nit: Suggest removing the "For tests only", since
mark a. foltz
2017/01/09 21:38:07
Done.
| |
| 59 void SetDeviceForTest( | |
| 60 const api::dial::DialDeviceData& device_data, | |
| 61 const api::dial::DialDeviceDescriptionData& device_description); | |
| 62 | |
| 48 private: | 63 private: |
| 49 ~DialAPI() override; | 64 ~DialAPI() override; |
| 50 | 65 |
| 66 friend class DialFetchDeviceDescriptionFunction; | |
| 67 | |
| 51 // RefcountedKeyedService: | 68 // RefcountedKeyedService: |
| 52 void ShutdownOnUIThread() override; | 69 void ShutdownOnUIThread() override; |
| 53 | 70 |
| 54 // EventRouter::Observer: | 71 // EventRouter::Observer: |
| 55 void OnListenerAdded(const EventListenerInfo& details) override; | 72 void OnListenerAdded(const EventListenerInfo& details) override; |
| 56 void OnListenerRemoved(const EventListenerInfo& details) override; | 73 void OnListenerRemoved(const EventListenerInfo& details) override; |
| 57 | 74 |
| 58 // DialRegistry::Observer: | 75 // DialRegistry::Observer: |
| 59 void OnDialDeviceEvent( | 76 void OnDialDeviceEvent( |
| 60 const api::dial::DialRegistry::DeviceList& devices) override; | 77 const api::dial::DialRegistry::DeviceList& devices) override; |
| 61 void OnDialError(api::dial::DialRegistry::DialErrorCode type) override; | 78 void OnDialError(api::dial::DialRegistry::DialErrorCode type) override; |
| 62 | 79 |
| 63 // Methods to notify the DialRegistry on the correct thread of new/removed | 80 // Methods to notify the DialRegistry on the correct thread of new/removed |
| 64 // listeners. | 81 // listeners. |
| 65 void NotifyListenerAddedOnIOThread(); | 82 void NotifyListenerAddedOnIOThread(); |
| 66 void NotifyListenerRemovedOnIOThread(); | 83 void NotifyListenerRemovedOnIOThread(); |
| 67 | 84 |
| 68 Profile* profile_; | 85 Profile* profile_; |
| 69 | 86 |
| 70 // Created lazily on first access on the IO thread. | 87 // Created lazily on first access on the IO thread. |
| 71 std::unique_ptr<api::dial::DialRegistry> dial_registry_; | 88 std::unique_ptr<api::dial::DialRegistry> dial_registry_; |
| 72 | 89 |
| 90 // Device data for testing. | |
| 91 std::unique_ptr<api::dial::DialDeviceData> test_device_data_; | |
| 92 std::unique_ptr<api::dial::DialDeviceDescriptionData> | |
| 93 test_device_description_; | |
|
Wez
2017/01/05 22:29:24
Rather than have these fields and having to friend
mark a. foltz
2017/01/09 21:38:07
I like that idea. I'd rather take it on as part o
Wez
2017/01/09 22:12:58
Acknowledged.
| |
| 94 | |
| 73 DISALLOW_COPY_AND_ASSIGN(DialAPI); | 95 DISALLOW_COPY_AND_ASSIGN(DialAPI); |
| 74 }; | 96 }; |
| 75 | 97 |
| 76 // DiscoverNow function. This function needs a round-trip from the IO thread | 98 // DiscoverNow function. This function needs a round-trip from the IO thread |
| 77 // because it needs to grab a pointer to the DIAL API in order to get a | 99 // because it needs to grab a pointer to the DIAL API in order to get a |
| 78 // reference to the DialRegistry while on the IO thread. Then, the result | 100 // reference to the DialRegistry while on the IO thread. Then, the result |
| 79 // must be returned on the UI thread. | 101 // must be returned on the UI thread. |
| 80 class DialDiscoverNowFunction : public AsyncApiFunction { | 102 class DialDiscoverNowFunction : public AsyncApiFunction { |
| 81 public: | 103 public: |
| 82 DialDiscoverNowFunction(); | 104 DialDiscoverNowFunction(); |
| (...skipping 13 matching lines...) Expand all Loading... | |
| 96 DialAPI* dial_; | 118 DialAPI* dial_; |
| 97 | 119 |
| 98 // Result of the discoverNow call to the DIAL registry. This result is | 120 // Result of the discoverNow call to the DIAL registry. This result is |
| 99 // retrieved on the IO thread but the function result is returned on the UI | 121 // retrieved on the IO thread but the function result is returned on the UI |
| 100 // thread. | 122 // thread. |
| 101 bool result_; | 123 bool result_; |
| 102 | 124 |
| 103 DISALLOW_COPY_AND_ASSIGN(DialDiscoverNowFunction); | 125 DISALLOW_COPY_AND_ASSIGN(DialDiscoverNowFunction); |
| 104 }; | 126 }; |
| 105 | 127 |
| 128 class DialFetchDeviceDescriptionFunction : public AsyncExtensionFunction { | |
| 129 public: | |
| 130 DialFetchDeviceDescriptionFunction(); | |
| 131 | |
| 132 protected: | |
| 133 ~DialFetchDeviceDescriptionFunction() override; | |
| 134 | |
| 135 // AsyncExtensionFunction: | |
| 136 bool RunAsync() override; | |
| 137 | |
| 138 private: | |
| 139 DECLARE_EXTENSION_FUNCTION("dial.fetchDeviceDescription", | |
| 140 DIAL_FETCHDEVICEDESCRIPTION) | |
| 141 | |
| 142 void GetDeviceDescriptionUrlOnIOThread(const std::string& label); | |
| 143 void MaybeStartFetch(const GURL& url); | |
| 144 void OnFetchComplete(const api::dial::DialDeviceDescriptionData& result); | |
| 145 void OnFetchError(const std::string& result); | |
| 146 | |
| 147 std::unique_ptr<api::dial::FetchDeviceDescription::Params> params_; | |
| 148 std::unique_ptr<api::dial::DeviceDescriptionFetcher> | |
| 149 device_description_fetcher_; | |
| 150 | |
| 151 DialAPI* dial_; | |
| 152 | |
| 153 DISALLOW_COPY_AND_ASSIGN(DialFetchDeviceDescriptionFunction); | |
| 154 }; | |
| 155 | |
| 106 } // namespace extensions | 156 } // namespace extensions |
| 107 | 157 |
| 108 #endif // CHROME_BROWSER_EXTENSIONS_API_DIAL_DIAL_API_H_ | 158 #endif // CHROME_BROWSER_EXTENSIONS_API_DIAL_DIAL_API_H_ |
| OLD | NEW |