106f6ba60Sopenharmony_ci/* 206f6ba60Sopenharmony_ci * Copyright (c) Huawei Technologies Co., Ltd. 2021. All rights reserved. 306f6ba60Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License"); 406f6ba60Sopenharmony_ci * you may not use this file except in compliance with the License. 506f6ba60Sopenharmony_ci * You may obtain a copy of the License at 606f6ba60Sopenharmony_ci * 706f6ba60Sopenharmony_ci * http://www.apache.org/licenses/LICENSE-2.0 806f6ba60Sopenharmony_ci * 906f6ba60Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software 1006f6ba60Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS, 1106f6ba60Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1206f6ba60Sopenharmony_ci * See the License for the specific language governing permissions and 1306f6ba60Sopenharmony_ci * limitations under the License. 1406f6ba60Sopenharmony_ci */ 1506f6ba60Sopenharmony_ci 1606f6ba60Sopenharmony_ci#ifndef PLUGIN_WATCHER_H 1706f6ba60Sopenharmony_ci#define PLUGIN_WATCHER_H 1806f6ba60Sopenharmony_ci 1906f6ba60Sopenharmony_ci#include <logging.h> 2006f6ba60Sopenharmony_ci 2106f6ba60Sopenharmony_ci#include <map> 2206f6ba60Sopenharmony_ci#include <memory> 2306f6ba60Sopenharmony_ci#include <mutex> 2406f6ba60Sopenharmony_ci#include <string> 2506f6ba60Sopenharmony_ci#include <thread> 2606f6ba60Sopenharmony_ciclass PluginManager; 2706f6ba60Sopenharmony_ci 2806f6ba60Sopenharmony_ciusing PluginManagerPtr = STD_PTR(shared, PluginManager); 2906f6ba60Sopenharmony_ci 3006f6ba60Sopenharmony_ciclass PluginWatcher { 3106f6ba60Sopenharmony_cipublic: 3206f6ba60Sopenharmony_ci explicit PluginWatcher(const PluginManagerPtr& pluginManager); 3306f6ba60Sopenharmony_ci ~PluginWatcher(); 3406f6ba60Sopenharmony_ci bool ScanPlugins(const std::string& pluginDir); 3506f6ba60Sopenharmony_ci bool WatchPlugins(const std::string& pluginDir); 3606f6ba60Sopenharmony_ci 3706f6ba60Sopenharmony_ciprivate: 3806f6ba60Sopenharmony_ci int inotifyFd_; 3906f6ba60Sopenharmony_ci std::weak_ptr<PluginManager> pluginManager_; 4006f6ba60Sopenharmony_ci std::map<int, std::string> wdToDir_; 4106f6ba60Sopenharmony_ci std::thread monitorThread_; 4206f6ba60Sopenharmony_ci std::mutex mtx_; 4306f6ba60Sopenharmony_ci bool runMonitor_; 4406f6ba60Sopenharmony_ci virtual void OnPluginAdded(const std::string& pluginPath); 4506f6ba60Sopenharmony_ci virtual void OnPluginRemoved(const std::string& pluginPath); 4606f6ba60Sopenharmony_ci void Monitor(); 4706f6ba60Sopenharmony_ci bool MonitorIsSet(); 4806f6ba60Sopenharmony_ci}; 4906f6ba60Sopenharmony_ci 5006f6ba60Sopenharmony_ci#endif // !PLUGIN_WATCHER_H 51