1 /* 2 * Copyright (c) 2023 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 DATA_PROXY_OBSERVER_STUB_H 17 #define DATA_PROXY_OBSERVER_STUB_H 18 19 #include "data_proxy_observer.h" 20 #include "dataproxy_handle_common.h" 21 #include "datashare_template.h" 22 #include "iremote_stub.h" 23 24 namespace OHOS { 25 namespace DataShare { 26 using RdbCallback = std::function<void(const RdbChangeNode &changeNode)>; 27 class RdbObserverStub : public IRemoteStub<IDataProxyRdbObserver> { 28 public: 29 RdbObserverStub(RdbCallback callback); 30 virtual ~RdbObserverStub(); 31 int OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override; 32 void OnChangeFromRdb(RdbChangeNode &changeNode); 33 void ClearCallback(); 34 private: 35 int RecoverRdbChangeNodeData(RdbChangeNode &changeNode); 36 int DeserializeDataFromAshmem(RdbChangeNode &changeNode); 37 int ReadAshmem(RdbChangeNode &changeNode, const void **data, int size, int &offset); 38 std::mutex mutex_; 39 RdbCallback callback_; 40 }; 41 42 using PublishedDataCallback = std::function<void(PublishedDataChangeNode &changeNode)>; 43 class PublishedDataObserverStub : public IRemoteStub<IDataProxyPublishedDataObserver> { 44 public: 45 virtual ~PublishedDataObserverStub(); 46 int OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override; PublishedDataObserverStub(PublishedDataCallback callback)47 explicit PublishedDataObserverStub(PublishedDataCallback callback) : callback_(callback){}; 48 void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode); 49 void ClearCallback(); 50 private: 51 std::mutex mutex_; 52 PublishedDataCallback callback_; 53 }; 54 55 using ProxyDataCallback = std::function<void(std::vector<DataProxyChangeInfo> &changeInfo)>; 56 class ProxyDataObserverStub : public IRemoteStub<IProxyDataObserver> { 57 public: 58 virtual ~ProxyDataObserverStub(); 59 int OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override; ProxyDataObserverStub(ProxyDataCallback callback)60 explicit ProxyDataObserverStub(ProxyDataCallback callback) : callback_(callback){}; 61 void OnChangeFromProxyData(std::vector<DataProxyChangeInfo> &changeInfo); 62 void ClearCallback(); 63 private: 64 std::mutex mutex_; 65 ProxyDataCallback callback_; 66 }; 67 } // namespace DataShare 68 } // namespace OHOS 69 #endif //DATA_PROXY_OBSERVER_STUB_H 70