1 /* 2 * Copyright (c) 2025 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16 #ifndef OHOS_DISTRIBUTED_DATA_SWITCH_OBSERVER_BRIDGE_H 17 #define OHOS_DISTRIBUTED_DATA_SWITCH_OBSERVER_BRIDGE_H 18 19 #include "concurrent_map.h" 20 #include "executor_pool.h" 21 #include "kvstore_death_recipient.h" 22 #include "kvstore_observer.h" 23 24 namespace OHOS::DistributedKv { 25 class SwitchObserverBridge : public KvStoreDeathRecipient { 26 public: 27 SwitchObserverBridge(const AppId &appId); 28 virtual ~SwitchObserverBridge() = default; 29 30 void AddSwitchCallback(std::shared_ptr<KvStoreObserver> observer); 31 void DeleteSwitchCallback(std::shared_ptr<KvStoreObserver> observer); 32 void OnRemoteDied() override; 33 34 private: 35 void RegisterSwitchObserver(); 36 void RestartRegisterTimer(); 37 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID; 38 AppId switchAppId_; 39 std::mutex switchMutex_; 40 ConcurrentMap<uintptr_t, std::shared_ptr<KvStoreObserver>> switchObservers_; 41 std::atomic<uint32_t> registerRetryCount_ = 0; 42 }; 43 } // namespace OHOS::DistributedKv 44 #endif // OHOS_DISTRIBUTED_DATA_SWITCH_OBSERVER_BRIDGE_H