OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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 SERVICES_PREFERENCES_PREF_STORE_MANAGER_IMPL_H_ | 5 #ifndef SERVICES_PREFERENCES_PREF_STORE_MANAGER_IMPL_H_ |
6 #define SERVICES_PREFERENCES_PREF_STORE_MANAGER_IMPL_H_ | 6 #define SERVICES_PREFERENCES_PREF_STORE_MANAGER_IMPL_H_ |
7 | 7 |
8 #include <memory> | 8 #include <memory> |
9 #include <set> | 9 #include <set> |
10 #include <unordered_map> | 10 #include <unordered_map> |
(...skipping 25 matching lines...) Expand all Loading... |
36 class PrefStoreManagerImpl | 36 class PrefStoreManagerImpl |
37 : public mojom::PrefStoreRegistry, | 37 : public mojom::PrefStoreRegistry, |
38 public mojom::PrefStoreConnector, | 38 public mojom::PrefStoreConnector, |
39 public service_manager::InterfaceFactory<mojom::PrefStoreConnector>, | 39 public service_manager::InterfaceFactory<mojom::PrefStoreConnector>, |
40 public service_manager::InterfaceFactory<mojom::PrefStoreRegistry>, | 40 public service_manager::InterfaceFactory<mojom::PrefStoreRegistry>, |
41 public mojom::PrefServiceControl, | 41 public mojom::PrefServiceControl, |
42 public service_manager::InterfaceFactory<mojom::PrefServiceControl>, | 42 public service_manager::InterfaceFactory<mojom::PrefServiceControl>, |
43 public service_manager::Service { | 43 public service_manager::Service { |
44 public: | 44 public: |
45 // Only replies to Connect calls when all |expected_pref_stores| have | 45 // Only replies to Connect calls when all |expected_pref_stores| have |
46 // registered. | 46 // registered. |expected_pref_stores| must contain |
| 47 // PrefValueStore::DEFAULT_STORE and PrefValueStore::USER_STORE for |
| 48 // consistency, as the service always registers these |
| 49 // internally. |worker_pool| is used for any I/O performed by the service. |
47 PrefStoreManagerImpl( | 50 PrefStoreManagerImpl( |
48 std::set<PrefValueStore::PrefStoreType> expected_pref_stores, | 51 std::set<PrefValueStore::PrefStoreType> expected_pref_stores, |
49 scoped_refptr<base::SequencedWorkerPool> worker_pool); | 52 scoped_refptr<base::SequencedWorkerPool> worker_pool); |
50 ~PrefStoreManagerImpl() override; | 53 ~PrefStoreManagerImpl() override; |
51 | 54 |
52 private: | 55 private: |
53 using PrefStorePtrs = | 56 struct PendingConnect; |
54 std::unordered_map<PrefValueStore::PrefStoreType, mojom::PrefStorePtr>; | |
55 | 57 |
56 // mojom::PrefStoreRegistry: | 58 // mojom::PrefStoreRegistry: |
57 void Register(PrefValueStore::PrefStoreType type, | 59 void Register(PrefValueStore::PrefStoreType type, |
58 mojom::PrefStorePtr pref_store_ptr) override; | 60 mojom::PrefStorePtr pref_store_ptr) override; |
59 | 61 |
60 // mojom::PrefStoreConnector: | 62 // mojom::PrefStoreConnector: |already_connected_types| must not include |
61 void Connect(mojom::PrefRegistryPtr pref_registry, | 63 // PrefValueStore::DEFAULT_STORE and PrefValueStore::USER_STORE as these must |
62 const ConnectCallback& callback) override; | 64 // always be accessed through the service. |
| 65 void Connect( |
| 66 mojom::PrefRegistryPtr pref_registry, |
| 67 const std::vector<PrefValueStore::PrefStoreType>& already_connected_types, |
| 68 const ConnectCallback& callback) override; |
63 | 69 |
64 // service_manager::InterfaceFactory<PrefStoreConnector>: | 70 // service_manager::InterfaceFactory<PrefStoreConnector>: |
65 void Create(const service_manager::Identity& remote_identity, | 71 void Create(const service_manager::Identity& remote_identity, |
66 prefs::mojom::PrefStoreConnectorRequest request) override; | 72 prefs::mojom::PrefStoreConnectorRequest request) override; |
67 | 73 |
68 // service_manager::InterfaceFactory<PrefStoreRegistry>: | 74 // service_manager::InterfaceFactory<PrefStoreRegistry>: |
69 void Create(const service_manager::Identity& remote_identity, | 75 void Create(const service_manager::Identity& remote_identity, |
70 prefs::mojom::PrefStoreRegistryRequest request) override; | 76 prefs::mojom::PrefStoreRegistryRequest request) override; |
71 | 77 |
72 // service_manager::InterfaceFactory<PrefServiceControl>: | 78 // service_manager::InterfaceFactory<PrefServiceControl>: |
73 void Create(const service_manager::Identity& remote_identity, | 79 void Create(const service_manager::Identity& remote_identity, |
74 prefs::mojom::PrefServiceControlRequest request) override; | 80 prefs::mojom::PrefServiceControlRequest request) override; |
75 | 81 |
76 // PrefServiceControl: | 82 // PrefServiceControl: |
77 void Init(mojom::PersistentPrefStoreConfigurationPtr configuration) override; | 83 void Init(mojom::PersistentPrefStoreConfigurationPtr configuration) override; |
78 | 84 |
79 // service_manager::Service: | 85 // service_manager::Service: |
80 void OnStart() override; | 86 void OnStart() override; |
81 bool OnConnect(const service_manager::ServiceInfo& remote_info, | 87 bool OnConnect(const service_manager::ServiceInfo& remote_info, |
82 service_manager::InterfaceRegistry* registry) override; | 88 service_manager::InterfaceRegistry* registry) override; |
83 | 89 |
84 // Called when a PrefStore previously registered using |Register| disconnects. | 90 // Called when a PrefStore previously registered using |Register| disconnects. |
85 void OnPrefStoreDisconnect(PrefValueStore::PrefStoreType type); | 91 void OnPrefStoreDisconnect(PrefValueStore::PrefStoreType type); |
86 | 92 |
87 // Have all the expected PrefStores connected? | 93 // Have all the expected PrefStores connected? |
88 bool AllConnected() const; | 94 bool AllConnected() const; |
89 | 95 |
90 void ProcessPendingConnects(); | 96 void ProcessPendingConnects(); |
91 | 97 |
92 void ConnectImpl(mojom::PrefRegistryPtr pref_registry, | 98 void ConnectImpl( |
93 const ConnectCallback& callback); | 99 mojom::PrefRegistryPtr pref_registry, |
| 100 const std::vector<PrefValueStore::PrefStoreType>& already_connected_types, |
| 101 const ConnectCallback& callback); |
94 | 102 |
95 void OnPersistentPrefStoreReady(); | 103 void OnPersistentPrefStoreReady(); |
96 | 104 |
97 // PrefStores that need to register before replying to any Connect calls. | 105 // PrefStores that need to register before replying to any Connect calls. This |
| 106 // does not include the PersistentPrefStore, which is handled separately. |
98 std::set<PrefValueStore::PrefStoreType> expected_pref_stores_; | 107 std::set<PrefValueStore::PrefStoreType> expected_pref_stores_; |
99 | 108 |
100 // Registered pref stores. | 109 // Registered pref stores. |
101 PrefStorePtrs pref_store_ptrs_; | 110 std::unordered_map<PrefValueStore::PrefStoreType, mojom::PrefStorePtr> |
| 111 pref_store_ptrs_; |
102 | 112 |
103 // We hold on to the connection request callbacks until all expected | 113 // We hold on to the connection request callbacks until all expected |
104 // PrefStores have registered. | 114 // PrefStores have registered. |
105 std::vector<std::pair<ConnectCallback, mojom::PrefRegistryPtr>> | 115 std::vector<PendingConnect> pending_connects_; |
106 pending_connects_; | |
107 | 116 |
108 mojo::BindingSet<mojom::PrefStoreConnector> connector_bindings_; | 117 mojo::BindingSet<mojom::PrefStoreConnector> connector_bindings_; |
109 mojo::BindingSet<mojom::PrefStoreRegistry> registry_bindings_; | 118 mojo::BindingSet<mojom::PrefStoreRegistry> registry_bindings_; |
110 std::unique_ptr<PersistentPrefStoreImpl> persistent_pref_store_; | 119 std::unique_ptr<PersistentPrefStoreImpl> persistent_pref_store_; |
111 mojo::Binding<mojom::PrefServiceControl> init_binding_; | 120 mojo::Binding<mojom::PrefServiceControl> init_binding_; |
112 | 121 |
113 const scoped_refptr<DefaultPrefStore> defaults_; | 122 const scoped_refptr<DefaultPrefStore> defaults_; |
114 const std::unique_ptr<PrefStoreImpl> defaults_wrapper_; | 123 const std::unique_ptr<PrefStoreImpl> defaults_wrapper_; |
115 | 124 |
116 const scoped_refptr<base::SequencedWorkerPool> worker_pool_; | 125 const scoped_refptr<base::SequencedWorkerPool> worker_pool_; |
117 | 126 |
118 DISALLOW_COPY_AND_ASSIGN(PrefStoreManagerImpl); | 127 DISALLOW_COPY_AND_ASSIGN(PrefStoreManagerImpl); |
119 }; | 128 }; |
120 | 129 |
121 } // namespace prefs | 130 } // namespace prefs |
122 | 131 |
123 #endif // SERVICES_PREFERENCES_PREF_STORE_MANAGER_IMPL_H_ | 132 #endif // SERVICES_PREFERENCES_PREF_STORE_MANAGER_IMPL_H_ |
OLD | NEW |