| // |
| // Copyright (C) 2014 The Android Open Source Project |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| // |
| |
| // Generic and provider-independent Variable subclasses. These variables can be |
| // used by any state provider to implement simple variables to avoid repeat the |
| // same common code on different state providers. |
| |
| #ifndef UPDATE_ENGINE_UPDATE_MANAGER_GENERIC_VARIABLES_H_ |
| #define UPDATE_ENGINE_UPDATE_MANAGER_GENERIC_VARIABLES_H_ |
| |
| #include <string> |
| |
| #include <base/callback.h> |
| |
| #include "update_engine/update_manager/variable.h" |
| |
| namespace chromeos_update_manager { |
| |
| // Variable class returning a copy of a given object using the copy constructor. |
| // This template class can be used to define variables that expose as a variable |
| // any fixed object, such as the a provider's private member. The variable will |
| // create copies of the provided object using the copy constructor of that |
| // class. |
| // |
| // For example, a state provider exposing a private member as a variable can |
| // implement this as follows: |
| // |
| // class SomethingProvider { |
| // public: |
| // SomethingProvider(...) { |
| // var_something_foo = new PollCopyVariable<MyType>(foo_); |
| // } |
| // ... |
| // private: |
| // MyType foo_; |
| // }; |
| template<typename T> |
| class PollCopyVariable : public Variable<T> { |
| public: |
| // Creates the variable returning copies of the passed |ref|. The reference to |
| // this object is kept and it should be available whenever the GetValue() |
| // method is called. If |is_set_p| is not null, then this flag will be |
| // consulted prior to returning the value, and an |errmsg| will be returned if |
| // it is not set. |
| PollCopyVariable(const std::string& name, const T& ref, const bool* is_set_p, |
| const std::string& errmsg) |
| : Variable<T>(name, kVariableModePoll), ref_(ref), is_set_p_(is_set_p), |
| errmsg_(errmsg) {} |
| PollCopyVariable(const std::string& name, const T& ref, const bool* is_set_p) |
| : PollCopyVariable(name, ref, is_set_p, std::string()) {} |
| PollCopyVariable(const std::string& name, const T& ref) |
| : PollCopyVariable(name, ref, nullptr) {} |
| |
| PollCopyVariable(const std::string& name, const base::TimeDelta poll_interval, |
| const T& ref, const bool* is_set_p, |
| const std::string& errmsg) |
| : Variable<T>(name, poll_interval), ref_(ref), is_set_p_(is_set_p), |
| errmsg_(errmsg) {} |
| PollCopyVariable(const std::string& name, const base::TimeDelta poll_interval, |
| const T& ref, const bool* is_set_p) |
| : PollCopyVariable(name, poll_interval, ref, is_set_p, std::string()) {} |
| PollCopyVariable(const std::string& name, const base::TimeDelta poll_interval, |
| const T& ref) |
| : PollCopyVariable(name, poll_interval, ref, nullptr) {} |
| |
| protected: |
| FRIEND_TEST(UmPollCopyVariableTest, SimpleTest); |
| FRIEND_TEST(UmPollCopyVariableTest, UseCopyConstructorTest); |
| |
| // Variable override. |
| inline const T* GetValue(base::TimeDelta /* timeout */, |
| std::string* errmsg) override { |
| if (is_set_p_ && !(*is_set_p_)) { |
| if (errmsg) { |
| if (errmsg_.empty()) |
| *errmsg = "No value set for " + this->GetName(); |
| else |
| *errmsg = errmsg_; |
| } |
| return nullptr; |
| } |
| return new T(ref_); |
| } |
| |
| private: |
| // Reference to the object to be copied by GetValue(). |
| const T& ref_; |
| |
| // A pointer to a flag indicating whether the value is set. If null, then the |
| // value is assumed to be set. |
| const bool* const is_set_p_; |
| |
| // An error message to be returned when attempting to get an unset value. |
| const std::string errmsg_; |
| }; |
| |
| // Variable class returning a constant value that is cached on the variable when |
| // it is created. |
| template<typename T> |
| class ConstCopyVariable : public Variable<T> { |
| public: |
| // Creates the variable returning copies of the passed |obj|. The value passed |
| // is copied in this variable, and new copies of it will be returned by |
| // GetValue(). |
| ConstCopyVariable(const std::string& name, const T& obj) |
| : Variable<T>(name, kVariableModeConst), obj_(obj) {} |
| |
| protected: |
| // Variable override. |
| const T* GetValue(base::TimeDelta /* timeout */, |
| std::string* /* errmsg */) override { |
| return new T(obj_); |
| } |
| |
| private: |
| // Value to be copied by GetValue(). |
| const T obj_; |
| }; |
| |
| // Variable class returning a copy of a value returned by a given function. The |
| // function is called every time the variable is being polled. |
| template<typename T> |
| class CallCopyVariable : public Variable<T> { |
| public: |
| CallCopyVariable(const std::string& name, base::Callback<T(void)> func) |
| : Variable<T>(name, kVariableModePoll), func_(func) {} |
| CallCopyVariable(const std::string& name, |
| const base::TimeDelta poll_interval, |
| base::Callback<T(void)> func) |
| : Variable<T>(name, poll_interval), func_(func) {} |
| |
| protected: |
| // Variable override. |
| const T* GetValue(base::TimeDelta /* timeout */, |
| std::string* /* errmsg */) override { |
| if (func_.is_null()) |
| return nullptr; |
| return new T(func_.Run()); |
| } |
| |
| private: |
| FRIEND_TEST(UmCallCopyVariableTest, SimpleTest); |
| |
| // The function to be called, stored as a base::Callback. |
| base::Callback<T(void)> func_; |
| |
| DISALLOW_COPY_AND_ASSIGN(CallCopyVariable); |
| }; |
| |
| |
| // A Variable class to implement simple Async variables. It provides two methods |
| // SetValue and UnsetValue to modify the current value of the variable and |
| // notify the registered observers whenever the value changed. |
| // |
| // The type T needs to be copy-constructible, default-constructible and have an |
| // operator== (to determine if the value changed), which makes this class |
| // suitable for basic types. |
| template<typename T> |
| class AsyncCopyVariable : public Variable<T> { |
| public: |
| explicit AsyncCopyVariable(const std::string& name) |
| : Variable<T>(name, kVariableModeAsync), has_value_(false) {} |
| |
| AsyncCopyVariable(const std::string& name, const T value) |
| : Variable<T>(name, kVariableModeAsync), |
| has_value_(true), value_(value) {} |
| |
| void SetValue(const T& new_value) { |
| bool should_notify = !(has_value_ && new_value == value_); |
| value_ = new_value; |
| has_value_ = true; |
| if (should_notify) |
| this->NotifyValueChanged(); |
| } |
| |
| void UnsetValue() { |
| if (has_value_) { |
| has_value_ = false; |
| this->NotifyValueChanged(); |
| } |
| } |
| |
| protected: |
| // Variable override. |
| const T* GetValue(base::TimeDelta /* timeout */, |
| std::string* errmsg) override { |
| if (!has_value_) { |
| if (errmsg) |
| *errmsg = "No value set for " + this->GetName(); |
| return nullptr; |
| } |
| return new T(value_); |
| } |
| |
| private: |
| // Whether the variable has a value set. |
| bool has_value_; |
| |
| // Copy of the object to be returned by GetValue(). |
| T value_; |
| }; |
| |
| } // namespace chromeos_update_manager |
| |
| #endif // UPDATE_ENGINE_UPDATE_MANAGER_GENERIC_VARIABLES_H_ |