1fb299fa2Sopenharmony_ci/* 2fb299fa2Sopenharmony_ci * Copyright (c) 2023 Huawei Device Co., Ltd. 3fb299fa2Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License"); 4fb299fa2Sopenharmony_ci * you may not use this file except in compliance with the License. 5fb299fa2Sopenharmony_ci * You may obtain a copy of the License at 6fb299fa2Sopenharmony_ci * 7fb299fa2Sopenharmony_ci * http://www.apache.org/licenses/LICENSE-2.0 8fb299fa2Sopenharmony_ci * 9fb299fa2Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software 10fb299fa2Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS, 11fb299fa2Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12fb299fa2Sopenharmony_ci * See the License for the specific language governing permissions and 13fb299fa2Sopenharmony_ci * limitations under the License. 14fb299fa2Sopenharmony_ci */ 15fb299fa2Sopenharmony_ci#ifndef UPDATER_EVENT_H 16fb299fa2Sopenharmony_ci#define UPDATER_EVENT_H 17fb299fa2Sopenharmony_ci 18fb299fa2Sopenharmony_ci#include <functional> 19fb299fa2Sopenharmony_ci#include <string> 20fb299fa2Sopenharmony_ci#include <map> 21fb299fa2Sopenharmony_ci#include <mutex> 22fb299fa2Sopenharmony_ci#include <vector> 23fb299fa2Sopenharmony_ci 24fb299fa2Sopenharmony_ci#include "event_id.h" 25fb299fa2Sopenharmony_ci 26fb299fa2Sopenharmony_cinamespace Updater { 27fb299fa2Sopenharmony_ciclass UpdaterEvent { 28fb299fa2Sopenharmony_ci using EventHandler = std::function<void()>; 29fb299fa2Sopenharmony_cipublic: 30fb299fa2Sopenharmony_ci static void Subscribe(enum EventId id, EventHandler handler) 31fb299fa2Sopenharmony_ci { 32fb299fa2Sopenharmony_ci std::unique_lock<std::mutex> lock(mutex_); 33fb299fa2Sopenharmony_ci eventMap_[id].push_back(handler); 34fb299fa2Sopenharmony_ci } 35fb299fa2Sopenharmony_ci static void Invoke(enum EventId id) 36fb299fa2Sopenharmony_ci { 37fb299fa2Sopenharmony_ci std::unique_lock<std::mutex> lock(mutex_); 38fb299fa2Sopenharmony_ci for (const auto &handler : eventMap_[id]) { 39fb299fa2Sopenharmony_ci if (handler != nullptr) { 40fb299fa2Sopenharmony_ci handler(); 41fb299fa2Sopenharmony_ci } 42fb299fa2Sopenharmony_ci } 43fb299fa2Sopenharmony_ci } 44fb299fa2Sopenharmony_ciprivate: 45fb299fa2Sopenharmony_ci static inline std::mutex mutex_ {}; 46fb299fa2Sopenharmony_ci static inline std::map<enum EventId, std::vector<EventHandler>> eventMap_ {}; 47fb299fa2Sopenharmony_ci}; 48fb299fa2Sopenharmony_ci} // Updater 49fb299fa2Sopenharmony_ci#endif // UPDATER_EVENT_H