/base/startup/init/services/param/watcher/agent/ |
H A D | watcher_manager_kits.cpp | 111 WATCHER_LOGI("Add old watcher keyPrefix %s ", iter->first.c_str()); in ReAddWatcher() 117 WatcherManagerKits::ParamWatcher *WatcherManagerKits::GetParamWatcher(const std::string &keyPrefix) in GetParamWatcher() argument 120 auto iter = watchers_.find(keyPrefix); in GetParamWatcher() 142 int32_t WatcherManagerKits::AddWatcher(const std::string &keyPrefix, ParameterChangePtr callback, void *context) in AddWatcher() argument 155 if (watchers_.find(keyPrefix) == watchers_.end()) { in AddWatcher() 156 watcher = std::make_shared<ParamWatcher>(keyPrefix); in AddWatcher() 157 WATCHER_CHECK(watcher != nullptr, return -1, "Failed to create watcher for %s", keyPrefix.c_str()); in AddWatcher() 159 WATCHER_CHECK(ret == 0, return ret, "Failed to add callback for %s ", keyPrefix.c_str()); in AddWatcher() 160 ret = watcherManager->AddWatcher(keyPrefix, remoteWatcherId); in AddWatcher() 161 WATCHER_CHECK(ret == 0, return -1, "Failed to add watcher for %s", keyPrefix in AddWatcher() 176 DelWatcher(const std::string &keyPrefix, ParameterChangePtr callback, void *context) DelWatcher() argument 329 SystemWatchParameter(const char *keyPrefix, ParameterChangePtr callback, void *context) SystemWatchParameter() argument 350 RemoveParameterWatcher(const char *keyPrefix, ParameterChgPtr callback, void *context) RemoveParameterWatcher() argument [all...] |
H A D | watcher_manager_proxy.cpp | 51 int32_t WatcherManagerProxy::SendMsg(int op, const std::string &keyPrefix, uint32_t remoteWatcherId) in SendMsg() argument 55 data.WriteString(keyPrefix); in SendMsg() 64 int32_t WatcherManagerProxy::AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in AddWatcher() argument 66 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::ADD_WATCHER), keyPrefix, remoteWatcherId); in AddWatcher() 69 int32_t WatcherManagerProxy::DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in DelWatcher() argument 71 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::DEL_WATCHER), keyPrefix, remoteWatcherId); in DelWatcher() 74 int32_t WatcherManagerProxy::RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in RefreshWatcher() argument 76 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::REFRESH_WATCHER), keyPrefix, remoteWatcherId); in RefreshWatcher()
|
H A D | watcher_manager_proxy.h | 31 int32_t AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override; 32 int32_t DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override; 33 int32_t RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override; 35 int32_t SendMsg(int op, const std::string &keyPrefix, uint32_t remoteWatcherId);
|
H A D | watcher_manager_kits.h | 39 int32_t AddWatcher(const std::string &keyPrefix, ParameterChangePtr callback, void *context); 40 int32_t DelWatcher(const std::string &keyPrefix, ParameterChangePtr callback, void *context); 112 ParamWatcher *GetParamWatcher(const std::string &keyPrefix);
|
/base/startup/init/services/param/watcher/proxy/ |
H A D | watcher_manager.cpp | 90 int32_t WatcherManager::AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in AddWatcher() argument 94 WATCHER_CHECK(keyPrefix.size() < PARAM_NAME_LEN_MAX, return -1, "Failed to verify keyPrefix."); in AddWatcher() 99 auto group = AddWatcherGroup(keyPrefix); in AddWatcher() 100 WATCHER_CHECK(group != nullptr, return -1, "Failed to create group for %s", keyPrefix.c_str()); in AddWatcher() 110 SendLocalChange(keyPrefix, remoteWatcherId); in AddWatcher() 112 keyPrefix.c_str(), remoteWatcherId, group->GetGroupId()); in AddWatcher() 116 int32_t WatcherManager::DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in DelWatcher() argument 119 WATCHER_CHECK(keyPrefix.size() < PARAM_NAME_LEN_MAX, return -1, "Failed to verify keyPrefix in DelWatcher() 138 RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) RefreshWatcher() argument 195 FilterParam(const char *name, const std::string &keyPrefix) FilterParam() argument 227 SendLocalChange(const std::string &keyPrefix, uint32_t remoteWatcherId) SendLocalChange() argument 232 std::string keyPrefix; SendLocalChange() member 603 AddWatcherGroup(const std::string &keyPrefix) AddWatcherGroup() argument 635 GetWatcherGroup(const std::string &keyPrefix) GetWatcherGroup() argument [all...] |
H A D | watcher_manager.h | 78 int32_t AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override; 79 int32_t DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override; 80 int32_t RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override; 89 void SendLocalChange(const std::string &keyPrefix, uint32_t remoteWatcherId); 100 WatcherGroupPtr AddWatcherGroup(const std::string &keyPrefix); 101 WatcherGroupPtr GetWatcherGroup(const std::string &keyPrefix);
|
/base/startup/init/services/param/watcher/include/ |
H A D | iwatcher_manager.h | 33 virtual int32_t AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) = 0; 34 virtual int32_t DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) = 0; 35 virtual int32_t RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) = 0;
|
/base/startup/init/interfaces/kits/jskits/src/ |
H A D | native_parameters_watch.cpp | 46 char keyPrefix[BUF_LENGTH] = { 0 }; 230 watcher->keyPrefix, watcherId); 235 PARAM_JS_LOGV("JSApp watcher key %s delete callback %u", watcher->keyPrefix, next); 245 watcher->keyPrefix, id); 261 PARAM_JS_LOGV("JSApp watcher key %s callbackRef has been deleted %d.", watcher->keyPrefix, next); 316 WatchParameter(watcher->keyPrefix, nullptr, nullptr); 346 int ret = GetParamValue(env, argv[0], napi_string, watcher->keyPrefix, watcher->keyLen); 348 PARAM_JS_LOGV("JSApp watcher keyPrefix = %s ", watcher->keyPrefix); 349 ret = WatchParameter(watcher->keyPrefix, nullpt [all...] |
/base/startup/init/test/unittest/param/ |
H A D | watcher_proxy_unittest.cpp | 112 int TestAddWatcher(const std::string &keyPrefix, uint32_t watcherId) in TestAddWatcher() argument 121 data.WriteString(keyPrefix); in TestAddWatcher() 126 EXPECT_EQ(watcherManager->GetWatcherGroup(keyPrefix) != nullptr, 1); in TestAddWatcher() 130 int TestRefreshWatcher(const std::string &keyPrefix, uint32_t watcherId) in TestRefreshWatcher() argument 139 data.WriteString(keyPrefix); in TestRefreshWatcher() 144 EXPECT_EQ(watcherManager->GetWatcherGroup(keyPrefix) != nullptr, 1); in TestRefreshWatcher() 148 int TestDelWatcher(const std::string &keyPrefix, uint32_t watcherId) in TestDelWatcher() argument 156 data.WriteString(keyPrefix); in TestDelWatcher() 200 int TestWatchAgentDump(const std::string &keyPrefix) in TestWatchAgentDump() argument 211 args.push_back(Str8ToStr16(keyPrefix in TestWatchAgentDump() 229 TestInvalid(const std::string &keyPrefix) TestInvalid() argument [all...] |
/base/startup/init/interfaces/innerkits/include/syspara/ |
H A D | parameter.h | 97 * @param keyPrefix Indicates the key prefix for the parameter to be watched. 98 * If keyPrefix is not a full name, "A.B." for example, it means to watch for all parameter started with "A.B.". 107 int WatchParameter(const char *keyPrefix, ParameterChgPtr callback, void *context); 114 * @param keyPrefix Indicates the key prefix for the parameter to be watched. 115 * If keyPrefix is not a full name, "A.B." for example, it means to watch for all parameter started with "A.B.". 123 int RemoveParameterWatcher(const char *keyPrefix, ParameterChgPtr callback, void *context);
|
/base/hiviewdfx/hiview/plugins/unified_collector/test/unittest/common/mock/ |
H A D | mock_parameter_ex.cpp | 62 int WatchParamChange(const char *keyPrefix, ParameterChgPtr callback, void *context) in WatchParamChange() argument 64 return WatchParameter(keyPrefix, callback, context); in WatchParamChange() 67 int RemoveParamWatcher(const char *keyPrefix, ParameterChgPtr callback, void *context) in RemoveParamWatcher() argument 69 return RemoveParameterWatcher(keyPrefix, callback, context); in RemoveParamWatcher()
|
/base/hiviewdfx/hiview/base/utility/ |
H A D | parameter_ex.cpp | 58 int WatchParamChange(const char *keyPrefix, ParameterChgPtr callback, void *context) in WatchParamChange() argument 60 return WatchParameter(keyPrefix, callback, context); in WatchParamChange()
|
/base/hiviewdfx/hiview/base/utility/include/ |
H A D | parameter_ex.h | 37 int WatchParamChange(const char *keyPrefix, ParameterChgPtr callback, void *context);
|