Lines Matching refs:std
46 using ParamWatcherProcessor = std::function<void(ParamWatcherListPtr list, WatcherNodePtr node, uint32_t index)>;
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;
84 int Dump(int fd, const std::vector<std::u16string>& args) 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);
117 std::atomic<uint32_t> remoteWatcherId_ { 0 };
118 std::atomic<uint32_t> groupId_ { 0 };
119 std::mutex mutex_;
120 std::mutex watcherMutex_;
122 std::thread *pRecvThread_ { nullptr };
123 std::atomic<bool> stop_ { false };
124 std::map<std::string, WatcherGroupPtr> groupMap_ {};
236 void ProcessParameterChange(const std::string &prefix, const std::string &name, const std::string &value)
251 WatcherGroup(uint32_t groupId, const std::string &key)
255 void ProcessParameterChange(WatcherManager *mananger, const std::string &name, const std::string &value);
256 const std::string GetKeyPrefix() const
265 std::string keyPrefix_ { };