Home
last modified time | relevance | path

Searched refs:SingleVerSyncTaskContext (Results 1 – 20 of 20) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.h68 int SyncStart(int mode, SingleVerSyncTaskContext *context);
74 int PushStart(SingleVerSyncTaskContext *context);
76 int PushPullStart(SingleVerSyncTaskContext *context);
78 int PullRequestStart(SingleVerSyncTaskContext *context);
80 int PullResponseStart(SingleVerSyncTaskContext *context);
102 int ControlCmdStart(SingleVerSyncTaskContext *context);
129 int InnerSyncStart(SingleVerSyncTaskContext *context);
133 int ReSendData(SingleVerSyncTaskContext *context);
144 int RequestStart(SingleVerSyncTaskContext *context, int mode);
239 int ControlCmdStartCheck(SingleVerSyncTaskContext *context);
[all …]
H A Dsingle_ver_sync_task_context.cpp29 SingleVerSyncTaskContext::SingleVerSyncTaskContext() in SingleVerSyncTaskContext() function in DistributedDB::SingleVerSyncTaskContext
36 SingleVerSyncTaskContext::~SingleVerSyncTaskContext() in ~SingleVerSyncTaskContext()
139 WaterMark SingleVerSyncTaskContext::GetEndMark() const in GetEndMark()
155 void SingleVerSyncTaskContext::ReleaseContinueToken() in ReleaseContinueToken()
210 void SingleVerSyncTaskContext::Clear() in Clear()
228 void SingleVerSyncTaskContext::Abort(int status) in Abort()
248 void SingleVerSyncTaskContext::ClearAllSyncTask() in ClearAllSyncTask()
404 bool SingleVerSyncTaskContext::IsQuerySync() const in IsQuerySync()
487 DEFINE_OBJECT_TAG_FACILITIES(SingleVerSyncTaskContext) in DEFINE_OBJECT_TAG_FACILITIES() argument
530 void SingleVerSyncTaskContext::ResetLastPushTaskStatus() in ResetLastPushTaskStatus()
[all …]
H A Dsingle_ver_data_sync_utils.h24 static int QuerySyncCheck(const SingleVerSyncTaskContext *context, bool &isCheckStatus);
26 static int AckMsgErrnoCheck(const SingleVerSyncTaskContext *context, const Message *message);
40 static void TransSendDataItemToLocal(const SingleVerSyncTaskContext *context,
45 …static int RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* stora…
48 …static int RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* stora…
54 …static void SetPacketId(DataRequestPacket *packet, SingleVerSyncTaskContext *context, uint32_t ver…
58 static void PushAndPullKeyRevokHandle(SingleVerSyncTaskContext *context);
62 …static void FillControlRequestPacket(ControlRequestPacket *packet, SingleVerSyncTaskContext *conte…
70 static void ControlAckErrorHandle(const SingleVerSyncTaskContext *context,
97 …static void RecordClientId(const SingleVerSyncTaskContext &context, const SyncGenericInterface &st…
[all …]
H A Dsingle_ver_data_sync.cpp66 int SingleVerDataSync::SyncStart(int mode, SingleVerSyncTaskContext *context) in SyncStart()
104 int SingleVerDataSync::InnerSyncStart(SingleVerSyncTaskContext *context) in InnerSyncStart()
210 int SingleVerDataSync::ReSendData(SingleVerSyncTaskContext *context) in ReSendData()
535 const SingleVerSyncTaskContext *context, WaterMark &waterMark) const in GetLocalWaterMark()
765 int SingleVerDataSync::PushStart(SingleVerSyncTaskContext *context) in PushStart()
775 int SingleVerDataSync::PushPullStart(SingleVerSyncTaskContext *context) in PushPullStart()
783 int SingleVerDataSync::PullRequestStart(SingleVerSyncTaskContext *context) in PullRequestStart()
1041 SingleVerSyncTaskContext *context) in SendDataPacket()
1079 SingleVerSyncTaskContext *context) in SendPullResponseDataPkt()
1781 int SingleVerDataSync::ControlCmdStart(SingleVerSyncTaskContext *context) in ControlCmdStart()
[all …]
H A Dsingle_ver_data_sync_utils.cpp47 int SingleVerDataSyncUtils::QuerySyncCheck(const SingleVerSyncTaskContext *context, bool &isCheckSt… in QuerySyncCheck()
81 int SingleVerDataSyncUtils::AckMsgErrnoCheck(const SingleVerSyncTaskContext *context, const Message… in AckMsgErrnoCheck()
165 void SingleVerDataSyncUtils::TransSendDataItemToLocal(const SingleVerSyncTaskContext *context, in TransSendDataItemToLocal()
200 int SingleVerDataSyncUtils::RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGeneric… in RunPermissionCheck()
213 bool SingleVerDataSyncUtils::CheckPermitReceiveData(const SingleVerSyncTaskContext *context, in CheckPermitReceiveData()
284 void SingleVerDataSyncUtils::PushAndPullKeyRevokHandle(SingleVerSyncTaskContext *context) in PushAndPullKeyRevokHandle()
368 void SingleVerDataSyncUtils::ControlAckErrorHandle(const SingleVerSyncTaskContext *context, in ControlAckErrorHandle()
489 int SingleVerDataSyncUtils::RunPermissionCheckInner(const SingleVerSyncTaskContext *context, in RunPermissionCheckInner()
522 void SingleVerDataSyncUtils::RecordClientId(const SingleVerSyncTaskContext &context, in RecordClientId()
539 void SingleVerDataSyncUtils::SetDataRequestCommonInfo(const SingleVerSyncTaskContext &context, in SetDataRequestCommonInfo()
[all …]
H A Dsingle_ver_sync_task_context.h36 class SingleVerSyncTaskContext : public SyncTaskContext {
38 explicit SingleVerSyncTaskContext();
40 DISABLE_COPY_ASSIGN_MOVE(SingleVerSyncTaskContext);
143 ~SingleVerSyncTaskContext() override;
158 DECLARE_OBJECT_TAG(SingleVerSyncTaskContext);
H A Dsingle_ver_data_message_schedule.h35 … Message *MoveNextMsg(SingleVerSyncTaskContext *context, bool &isNeedHandle, bool &isNeedContinue);
47 void StartTimer(SingleVerSyncTaskContext *context);
49 void ResetTimer(SingleVerSyncTaskContext *context);
H A Dsingle_ver_relational_sync_task_context.cpp22 : SingleVerSyncTaskContext() in SingleVerRelationalSyncTaskContext()
51 SingleVerSyncTaskContext::Clear(); in Clear()
56 SingleVerSyncTaskContext::CopyTargetData(target, taskParam); in CopyTargetData()
H A Dsingle_ver_sync_engine.cpp26 SingleVerSyncTaskContext *context = nullptr; in CreateSyncTaskContext()
56 auto context = static_cast<SingleVerSyncTaskContext *>(iter.second); in EnableClearRemoteStaleData()
H A Dsingle_ver_data_message_schedule.cpp51 Message *SingleVerDataMessageSchedule::MoveNextMsg(SingleVerSyncTaskContext *context, bool &isNeedH… in MoveNextMsg()
226 void SingleVerDataMessageSchedule::StartTimer(SingleVerSyncTaskContext *context) in StartTimer()
265 void SingleVerDataMessageSchedule::ResetTimer(SingleVerSyncTaskContext *context) in ResetTimer()
H A Dsingle_ver_kv_sync_task_context.h22 class SingleVerKvSyncTaskContext : public SingleVerSyncTaskContext {
H A Dsingle_ver_kv_sync_task_context.cpp20 : SingleVerSyncTaskContext(), syncStrategy_{} in SingleVerKvSyncTaskContext()
H A Dsingle_ver_relational_sync_task_context.h23 class SingleVerRelationalSyncTaskContext : public SingleVerSyncTaskContext {
H A Dsingle_ver_sync_state_machine.h228 SingleVerSyncTaskContext *context_;
H A Dsingle_ver_sync_state_machine.cpp156 context_ = static_cast<SingleVerSyncTaskContext *>(context); in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_single_ver_data_sync.h25 int CallRequestStart(SingleVerSyncTaskContext *context, int mode) in CallRequestStart()
30 int CallPullRequestStart(SingleVerSyncTaskContext *context) in CallPullRequestStart()
35 void CallUpdateSendInfo(SyncTimeRange dataTimeRange, SingleVerSyncTaskContext *context) in CallUpdateSendInfo()
40 int CallRemoveDeviceDataIfNeed(SingleVerSyncTaskContext *context) in CallRemoveDeviceDataIfNeed()
45 …int CallDoAbilitySyncIfNeed(SingleVerSyncTaskContext *context, const Message *message, bool isCont… in CallDoAbilitySyncIfNeed()
55 MOCK_METHOD1(RemoveDeviceDataIfNeed, int(SingleVerSyncTaskContext *));
H A Dgeneric_virtual_device.cpp98 static_cast<SingleVerSyncTaskContext *>(context_)->SetSubscribeManager(subManager_); in Initialize()
282 static_cast<SingleVerSyncTaskContext *>(context_)->EnableClearRemoteStaleData(isStaleData); in SetClearRemoteStaleData()
H A Ddistributeddb_ability_sync_test.cpp439 SingleVerSyncTaskContext *context = new (std::nothrow) SingleVerKvSyncTaskContext();
508 SingleVerSyncTaskContext *context = new (std::nothrow) SingleVerKvSyncTaskContext();
H A Ddistributeddb_time_sync_test.cpp42 SingleVerSyncTaskContext *g_syncTaskContext = nullptr;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dability_sync.cpp433 (static_cast<SingleVerSyncTaskContext *>(context))->SetTaskErrCode(-E_SCHEMA_MISMATCH); in AckRecv()
463 (static_cast<SingleVerSyncTaskContext *>(context))->SetTaskErrCode(-E_SCHEMA_MISMATCH); in RequestRecv()
568 (static_cast<SingleVerSyncTaskContext *>(context))->SetDbAbility(remoteDbAbility); in HandleVersionV3RequestParam()
569 …(static_cast<SingleVerSyncTaskContext *>(context))->SetRemoteSeccurityOption({remoteSecLabel, remo… in HandleVersionV3RequestParam()
570 (static_cast<SingleVerSyncTaskContext *>(context))->SetReceivcPermitCheck(false); in HandleVersionV3RequestParam()
581 (static_cast<SingleVerSyncTaskContext *>(context))->SetRemoteSeccurityOption(secOption); in HandleVersionV3AckSecOptionParam()
582 (static_cast<SingleVerSyncTaskContext *>(context))->SetSendPermitCheck(false); in HandleVersionV3AckSecOptionParam()
610 …auto remoteSecOption = (static_cast<const SingleVerSyncTaskContext *>(context))->GetRemoteSeccurit… in GetPacketSecOption()
1294 auto singleVerContext = static_cast<SingleVerSyncTaskContext *>(context); in HandleRelationAckSchemaParam()
1323 auto singleVerContext = static_cast<SingleVerSyncTaskContext *>(context); in AckRecvWithHighVersion()