Home
last modified time | relevance | path

Searched refs:SyncOperation (Results 1 – 25 of 38) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_operation.cpp23 SyncOperation::SyncOperation(uint32_t syncId, const std::vector<std::string> &devices, in SyncOperation() function in DistributedDB::SyncOperation
39 SyncOperation::~SyncOperation() in ~SyncOperation()
46 int SyncOperation::Initialize() in Initialize()
142 int SyncOperation::GetMode() const in GetMode()
161 void SyncOperation::Finished() in Finished()
205 void SyncOperation::WaitIfNeed() in WaitIfNeed()
213 void SyncOperation::NotifyIfNeed() in NotifyIfNeed()
221 bool SyncOperation::IsAutoSync() const in IsAutoSync()
226 bool SyncOperation::IsBlockSync() const in IsBlockSync()
254 void SyncOperation::Finalize() in Finalize()
[all …]
H A Dsync_operation.h34 class SyncOperation : public RefObject {
66 SyncOperation(uint32_t syncId, const std::vector<std::string> &devices, int mode,
69 DISABLE_COPY_ASSIGN_MOVE(SyncOperation);
135 virtual ~SyncOperation();
139 DECLARE_OBJECT_TAG(SyncOperation);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.cpp92 int SingleVerSyncTaskContext::AddSyncOperation(SyncOperation *operation) in AddSyncOperation()
109 SyncOperation *tmpOperation = nullptr; in AddSyncOperation()
117 operation->SetStatus(deviceId_, SyncOperation::OP_FINISHED_ALL); in AddSyncOperation()
218 SetOperationStatus(SyncOperation::OP_WAITING); in Clear()
234 if ((status >= SyncOperation::OP_FINISHED_ALL)) { in Abort()
259 SyncOperation *tmpInfOperation = nullptr; in ClearAllSyncTask()
274 SyncOperation *tmpOperation = nullptr; in ClearAllSyncTask()
491 SyncOperation *operation = GetAndIncSyncOperation(); in DEFINE_OBJECT_TAG_FACILITIES()
532 lastFullSyncTaskStatus_ = SyncOperation::OP_WAITING; in ResetLastPushTaskStatus()
545 if (lastFullSyncTaskStatus_ != SyncOperation::OP_FINISHED_ALL) { in IsCurrentSyncTaskCanBeSkippedInner()
[all …]
H A Dsingle_ver_sync_state_machine.cpp379 context_->SetOperationStatus(SyncOperation::OP_RECV_FINISHED); in DoInitiactiveDataSyncWithSlidingWindow()
384 context_->SetOperationStatus(SyncOperation::OP_SEND_FINISHED); in DoInitiactiveDataSyncWithSlidingWindow()
436 context_->SetOperationStatus(SyncOperation::OP_RECV_FINISHED); in DoInitiactiveControlSync()
462 if (context_->GetOperationStatus() == SyncOperation::OP_FINISHED_ALL) { in DoWaitForDataRecv()
557 context_->Abort(SyncOperation::OP_TIMEOUT); in DoTimeout()
573 context_->Abort(SyncOperation::OP_COMM_ABNORMAL); in DoInnerErr()
853 SyncOperation::Status status = SyncOperation::OP_WAITING;
864 { -E_TIMEOUT, SyncOperation::OP_TIMEOUT }, in GetSyncOperationStatus()
871 { -E_MAX_LIMITS, SyncOperation::OP_MAX_LIMITS }, in GetSyncOperationStatus()
1104 context_->SetOperationStatus(SyncOperation::OP_RECV_FINISHED); in PushPullDataRequestEvokeErrHandle()
[all …]
H A Dsingle_ver_sync_task_context.h47 int AddSyncOperation(SyncOperation *operation) override;
152 volatile int lastFullSyncTaskStatus_ = SyncOperation::Status::OP_WAITING;
154 …int GetCorrectedSendWaterMarkForCurrentTask(const SyncOperation *operation, uint64_t &waterMark) c…
156 bool IsCurrentSyncTaskCanBeSkippedInner(const SyncOperation *operation) const;
H A Dsingle_ver_data_sync_utils.cpp98 if (SyncOperation::GetSyncType(packet->GetMode()) != SyncType::QUERY_SYNC_TYPE) { in RequestQueryCheck()
194 if (SyncOperation::TransferSyncMode(mode) == SyncModeType::PUSH_AND_PULL && in TranslateErrCodeIfNeed()
203 int mode = SyncOperation::TransferSyncMode(packet->GetMode()); in RunPermissionCheck()
288 int mode = SyncOperation::TransferSyncMode(context->GetMode()); in PushAndPullKeyRevokHandle()
297 int curMode = SyncOperation::TransferSyncMode(mode); in GetReSendMode()
H A Dsingle_ver_sync_target.h30 void SetSyncOperation(SyncOperation *operation) override;
H A Dsingle_ver_data_sync.cpp78 int tmpMode = SyncOperation::TransferSyncMode(mode); in SyncStart()
116 int mode = SyncOperation::TransferSyncMode(mode_); in InnerSyncStart()
197 context->SetOperationStatus(SyncOperation::OP_SEND_FINISHED); in TryContinueSync()
446 int mode = SyncOperation::TransferSyncMode(inMode); in ResetSyncStatus()
995 SyncType curType = SyncOperation::GetSyncType(packet->GetMode()); in DataRequestRecv()
1275 int mode = SyncOperation::TransferSyncMode(packet->GetMode()); in GetPullEndWatermark()
1321 int mode = SyncOperation::TransferSyncMode(packet->GetMode()); in RunPermissionCheck()
1472 int mode = SyncOperation::TransferSyncMode(inMode); in CheckPermitSendData()
1575 int mode = SyncOperation::TransferSyncMode(inMode); in RemotePushFinished()
1589 SyncType curType = SyncOperation::GetSyncType(packet->GetMode()); in SetAckPacket()
[all …]
H A Dsingle_ver_sync_target.cpp34 void SingleVerSyncTarget::SetSyncOperation(SyncOperation *operation) in SetSyncOperation()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_task_context.cpp125 …if (status == SyncOperation::OP_SEND_FINISHED && operationStatus == SyncOperation::OP_RECV_FINISHE… in SetOperationStatus()
127 finalStatus = SyncOperation::OP_EKEYREVOKED_FAILURE; in SetOperationStatus()
129 finalStatus = SyncOperation::OP_FINISHED_ALL; in SetOperationStatus()
131 …} else if (status == SyncOperation::OP_RECV_FINISHED && operationStatus == SyncOperation::OP_SEND_… in SetOperationStatus()
135 finalStatus = SyncOperation::OP_FINISHED_ALL; in SetOperationStatus()
139 if (finalStatus >= SyncOperation::OP_FINISHED_ALL) { in SetOperationStatus()
162 status_ = SyncOperation::OP_WAITING; in Clear()
219 return SyncOperation::OP_FINISHED_ALL; in GetOperationStatus()
254 SyncOperation *tmpOperation = nullptr; in MoveToNextTarget()
577 status_ = SyncOperation::OP_SYNCING; in CopyTargetData()
[all …]
H A Dsync_target.h43 void SetSyncOperation(SyncOperation *operation) override;
46 void GetSyncOperation(SyncOperation *&operation) const override;
54 SyncOperation *operation_;
H A Disync_target.h47 virtual void SetSyncOperation(SyncOperation *operation) = 0;
50 virtual void GetSyncOperation(SyncOperation *&operation) const = 0;
H A Dgeneric_syncer.h131 virtual void AddSyncOperation(ISyncEngine *engine, SyncOperation *operation);
168 void TriggerSyncFinished(SyncOperation *operation);
185 void InitSyncOperation(SyncOperation *operation, const SyncParma &param);
227 std::map<int, SyncOperation *> syncOperationMap_;
H A Dsync_target.cpp56 void SyncTarget::SetSyncOperation(SyncOperation *operation) in SetSyncOperation()
66 void SyncTarget::GetSyncOperation(SyncOperation *&operation) const in GetSyncOperation()
H A Dgeneric_syncer.cpp201 … new (std::nothrow) SyncOperation(syncId, param.devices, param.mode, param.onComplete, param.wait); in PrepareSync()
236 SyncOperation *operation = nullptr; in RemoveSyncOperation()
346 void GenericSyncer::AddSyncOperation(ISyncEngine *engine, SyncOperation *operation) in AddSyncOperation()
360 syncOperationMap_.insert(std::pair<int, SyncOperation *>(operation->GetSyncId(), operation)); in AddSyncOperation()
502 std::vector<SyncOperation *> syncOperation; in ClearSyncOperations()
508 … int status = (!isClosedOperation) ? SyncOperation::OP_USER_CHANGED : SyncOperation::OP_FAILED; in ClearSyncOperations()
553 void GenericSyncer::TriggerSyncFinished(SyncOperation *operation) in TriggerSyncFinished()
657 int mode = SyncOperation::TransferSyncMode(inMode); in IsManualSync()
853 void GenericSyncer::InitSyncOperation(SyncOperation *operation, const SyncParma &param) in InitSyncOperation()
H A Dsync_engine.cpp158 int SyncEngine::AddSyncOperation(SyncOperation *operation) in AddSyncOperation()
171 SyncOperation::OP_BUSY_FAILURE : SyncOperation::OP_FAILED); in AddSyncOperation()
175 operation->SetStatus(deviceId, SyncOperation::OP_INVALID_ARGS); in AddSyncOperation()
178 operation->SetStatus(deviceId, SyncOperation::OP_WAITING); in AddSyncOperation()
180 operation->SetStatus(deviceId, SyncOperation::OP_FAILED); in AddSyncOperation()
322 int SyncEngine::AddSyncOperForContext(const std::string &deviceId, SyncOperation *operation) in AddSyncOperForContext()
678 context->SetOperationStatus(SyncOperation::OP_FINISHED_ALL); in ExecSyncTask()
688 context->SetOperationStatus(SyncOperation::OP_FAILED); in ExecSyncTask()
H A Dsync_task_context.h244 SyncOperation *GetAndIncSyncOperation() const;
255 SyncOperation *syncOperation_;
H A Dsync_engine.h47 int AddSyncOperation(SyncOperation *operation) override;
163 int AddSyncOperForContext(const std::string &deviceId, SyncOperation *operation);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dkv_virtual_device.cpp100 …auto operation = new (std::nothrow) SyncOperation(id, {remoteDeviceId_}, SUBSCRIBE_QUERY, nullptr,… in Subscribe()
121 const SyncOperation::UserCallback &callback) in UnSubscribe()
123 …auto operation = new (std::nothrow) SyncOperation(id, {remoteDeviceId_}, UNSUBSCRIBE_QUERY, callba… in UnSubscribe()
H A Dmock_sync_task_context.h78 void SetLastFullSyncTaskStatus(SyncOperation::Status lastFullSyncTaskStatus) in SetLastFullSyncTaskStatus()
96 void SetSyncOperation(SyncOperation *operation) in SetSyncOperation()
H A Dgeneric_virtual_device.cpp211 context_->SetOperationStatus(SyncOperation::OP_FAILED); in StartResponseTask()
223 auto operation = new (std::nothrow) SyncOperation(1, {remoteDeviceId_}, mode, nullptr, wait); in Sync()
243 const SyncOperation::UserCallback &callBack, bool wait) in Sync()
245 auto operation = new (std::nothrow) SyncOperation(1, {remoteDeviceId_}, mode, callBack, wait); in Sync()
H A Dkv_virtual_device.h42 …int UnSubscribe(const QuerySyncObject &query, bool wait, int id, const SyncOperation::UserCallback…
H A Dgeneric_virtual_device.h45 …virtual int Sync(SyncMode mode, const Query &query, const SyncOperation::UserCallback &callBack, b…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_task_context.cpp70 int MultiVerSyncTaskContext::AddSyncOperation(SyncOperation *operation) in AddSyncOperation()
78 operation->SetStatus(deviceId_, SyncOperation::OP_FINISHED_ALL); in AddSyncOperation()
H A Dmulti_ver_syncer.h55 void AddSyncOperation([[gnu::unused]] ISyncEngine *engine, SyncOperation *operation) override;

12