| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_task_context.cpp | 40 SyncTaskContext::SyncTaskContext() in SyncTaskContext() function in DistributedDB::SyncTaskContext
65 SyncTaskContext::~SyncTaskContext() in ~SyncTaskContext()
152 void SyncTaskContext::Clear() in Clear()
229 int SyncTaskContext::GetMode() const in GetMode()
306 int SyncTaskContext::StartTimer() in StartTimer()
330 void SyncTaskContext::StopTimer() in StopTimer()
398 void SyncTaskContext::IncPacketId() in IncPacketId()
453 int SyncTaskContext::IncUsedCount() in IncUsedCount()
464 void SyncTaskContext::SafeExit() in SafeExit()
609 void SyncTaskContext::KillWait() in KillWait()
[all …]
|
| H A D | sync_task_context.h | 42 class SyncTaskContext : public ISyncTaskContext {
44 SyncTaskContext();
226 ~SyncTaskContext() override;
269 volatile int isNeedRetry_ = SyncTaskContext::NO_NEED_RETRY;
|
| H A D | sync_state_machine.cpp | 101 syncContext_->SetRetryStatus(SyncTaskContext::NEED_RETRY); in TimeoutCallback()
|
| H A D | sync_engine.cpp | 666 if ((status == SyncTaskContext::RUNNING) || context->IsKilled()) { in ExecSyncTask()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | mock_sync_task_context.h | 70 SyncTaskContext::CommErrHandlerFuncInner(errCode, sessionId); in CallCommErrHandlerFuncInner()
75 SyncTaskContext::SetTaskExecStatus(status); in CallSetTaskExecStatus()
|
| H A D | virtual_time_sync_communicator.h | 67 const std::string &deviceID, SyncTaskContext *syncTaskcontext);
80 SyncTaskContext *syncTaskcontext_;
|
| H A D | generic_virtual_device.cpp | 114 context_->SetRetryStatus(SyncTaskContext::NO_NEED_RETRY); in Initialize()
159 SyncTaskContext *context = context_; in MessageCallback()
195 if ((status == SyncTaskContext::RUNNING) || context_->IsKilled()) { in StartResponseTask()
|
| H A D | generic_virtual_device.h | 56 SyncTaskContext *context_;
|
| H A D | virtual_time_sync_communicator.cpp | 132 const std::string &deviceID, SyncTaskContext *syncTaskcontext) in SetTimeSync()
|
| H A D | distributeddb_mock_sync_module_test.cpp | 667 syncTaskContext.CallSetTaskExecStatus(SyncTaskContext::RUNNING);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 30 : SyncTaskContext(), in SingleVerSyncTaskContext()
197 SyncTaskContext::CopyTargetData(target, taskParam); in CopyTargetData()
214 SyncTaskContext::Clear(); in Clear()
293 if (GetTaskExecStatus() == SyncTaskContext::RUNNING) { in ClearAllSyncTask()
|
| H A D | single_ver_relational_sync_task_context.cpp | 97 SyncTaskContext::SchemaChange(); in SchemaChange()
|
| H A D | single_ver_sync_task_context.h | 36 class SingleVerSyncTaskContext : public SyncTaskContext {
|
| H A D | single_ver_data_sync.cpp | 282 if (context->GetRetryStatus() == SyncTaskContext::NEED_RETRY) { in GetData()
283 context->SetRetryStatus(SyncTaskContext::NO_NEED_RETRY); in GetData()
823 context->SetRetryStatus(SyncTaskContext::NO_NEED_RETRY); in PullRequestStart()
1067 SyncTaskContext::CommErrHandlerFunc(ret, context, sessionId, isDirectEnd); in SendDataPacket()
1305 context->SetRetryStatus(SyncTaskContext::NEED_RETRY); in DealWaterMarkException()
1459 SyncTaskContext::CommErrHandlerFunc(ret, context, sessionId, isDirectEnd); in SendReSendPacket()
1918 SyncTaskContext::CommErrHandlerFunc(ret, context, sessionId, isDirectEnd); in SendControlPacket()
|
| H A D | single_ver_sync_state_machine.cpp | 420 context_->GetRetryStatus() == static_cast<int>(SyncTaskContext::NO_NEED_RETRY)) { in DoPassiveDataSyncWithSlidingWindow()
482 SyncTaskContext::CommErrHandlerFunc(ret, context, requestSessionId, isDirectEnd); in DoTimeSync()
515 SyncTaskContext::CommErrHandlerFunc(ret, context, requestSessionId, isDirectEnd); in DoAbilitySync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_task_context.h | 24 class MultiVerSyncTaskContext final : public SyncTaskContext {
|
| H A D | multi_ver_sync_task_context.cpp | 236 SyncTaskContext::CopyTargetData(target, taskParam); in CopyTargetData()
|
| H A D | value_slice_sync.cpp | 509 if (context->GetRetryStatus() == SyncTaskContext::NEED_RETRY) { in GetValidValueSliceHashNode()
510 context->SetRetryStatus(SyncTaskContext::NO_NEED_RETRY); in GetValidValueSliceHashNode()
|
| H A D | multi_ver_data_sync.cpp | 548 if (context->GetRetryStatus() == SyncTaskContext::NEED_RETRY) { in GetValidCommit()
549 context->SetRetryStatus(SyncTaskContext::NO_NEED_RETRY); in GetValidCommit()
|