Searched refs:rdbNotifyConfig (Results 1 – 8 of 8) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | delay_notify.cpp | 33 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in ~DelayNotify() local
34 rdbNotifyConfig.delay_ = 0; in ~DelayNotify()
35 rdbNotifyConfig.isFull_ = isFull_; in ~DelayNotify()
36 auto errCode = task_(changedData_, rdbNotifyConfig); in ~DelayNotify()
115 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in StartTimer() local
116 rdbNotifyConfig.delay_ = SERVICE_INTERVAL; in StartTimer()
117 rdbNotifyConfig.isFull_ = isFull; in StartTimer()
118 task_(changedData, rdbNotifyConfig); in StartTimer()
145 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in ExecuteTask() local
146 rdbNotifyConfig.delay_ = 0; in ExecuteTask()
[all …]
|
| H A D | rdb_service_proxy.cpp | 516 const RdbNotifyConfig &rdbNotifyConfig) in NotifyDataChange() argument
520 reply, param, rdbChangedData, rdbNotifyConfig); in NotifyDataChange()
|
| H A D | rdb_store_impl.cpp | 727 …st DistributedRdb::RdbChangedData& rdbChangedData, const RdbNotifyConfig& rdbNotifyConfig) -> int { in InitDelayNotifier() argument
736 return service->NotifyDataChange(param, rdbChangedData, rdbNotifyConfig); in InitDelayNotifier()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_stub.cpp | 288 RdbNotifyConfig rdbNotifyConfig; in OnRemoteNotifyDataChange() local
289 if (!ITypesUtil::Unmarshal(data, param, rdbChangedData, rdbNotifyConfig)) { in OnRemoteNotifyDataChange()
295 auto status = NotifyDataChange(param, rdbChangedData, rdbNotifyConfig); in OnRemoteNotifyDataChange()
|
| H A D | rdb_service_impl.h | 91 const RdbNotifyConfig &rdbNotifyConfig) override;
208 …bool IsPostImmediately(const int32_t callingPid, const RdbNotifyConfig &rdbNotifyConfig, StoreInfo…
|
| H A D | rdb_service_impl.cpp | 1062 const RdbNotifyConfig &rdbNotifyConfig) in NotifyDataChange() argument
1080 eventInfo.isFull = rdbNotifyConfig.isFull_; in NotifyDataChange()
1086 …if (IsPostImmediately(IPCSkeleton::GetCallingPid(), rdbNotifyConfig, storeInfo, eventInfo, param.s… in NotifyDataChange()
1094 …RdbServiceImpl::IsPostImmediately(const int32_t callingPid, const RdbNotifyConfig &rdbNotifyConfig, in IsPostImmediately() argument
1098 …heartbeatTaskIds_.Compute(callingPid, [this, &postImmediately, &rdbNotifyConfig, &storeInfo, &even… in IsPostImmediately()
1105 if (rdbNotifyConfig.delay_ == 0) { in IsPostImmediately()
1120 … taskId = executors_->Schedule(std::chrono::milliseconds(rdbNotifyConfig.delay_), task); in IsPostImmediately()
1122 … taskId = executors_->Reset(taskId, std::chrono::milliseconds(rdbNotifyConfig.delay_)); in IsPostImmediately()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
| H A D | rdb_service.h | 78 …cerParam ¶m, const RdbChangedData &rdbChangedData, const RdbNotifyConfig &rdbNotifyConfig) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | rdb_service_proxy.h | 75 const RdbNotifyConfig &rdbNotifyConfig) override;
|