Home
last modified time | relevance | path

Searched refs:GetRequestSessionId (Results 1 – 11 of 11) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp307 uint32_t requestSessionId = context_->GetRequestSessionId(); in CommErrAbort()
481 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoTimeSync()
485 int errCode = timeSync_->SyncStart(handler, context_->GetRequestSessionId()); in DoTimeSync()
514 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoAbilitySync()
519 errCode = abilitySync_->SyncStart(context_->GetRequestSessionId(), context_->GetSequenceId(), in DoAbilitySync()
755 context_->GetRequestSessionId() != 0; in HandleDataAckRecv()
895 int errCode = timeSync_->AckRecv(inMsg, context_->GetRequestSessionId()); in TimeMarkSyncRecv()
934 (inMsg->GetSessionId() != context_->GetRequestSessionId())) { in IsPacketValid()
940 (inMsg->GetSessionId() != context_->GetRequestSessionId()) && in IsPacketValid()
1090 if (sessionId == context_->GetRequestSessionId() || in IsNeedErrCodeHandle()
[all …]
H A Dsingle_ver_data_sync.cpp448 sessionId_ = context->GetRequestSessionId(); in ResetSyncStatus()
691 packet->SetSessionId(context->GetRequestSessionId()); in FillDataRequestPacket()
818 packet->SetSessionId(context->GetRequestSessionId()); in PullRequestStart()
961 message->GetSessionId() == context->GetRequestSessionId()) { in DataRequestRecvPre()
1025 context->GetRequestSessionId()); in DataRequestRecv()
1061 context->GetSequenceId(), context->GetRequestSessionId()); in SendDataPacket()
1227 (message->GetSessionId() == context->GetRequestSessionId())) && (token == nullptr)) { in AckRecv()
1916 context->GetSequenceId(), context->GetRequestSessionId()); in SendControlPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_sync_task_context.h64 MOCK_CONST_METHOD0(GetRequestSessionId, uint32_t(void));
H A Ddistributeddb_mock_sync_module_test.cpp506 EXPECT_CALL(syncTaskContext, GetRequestSessionId()).WillRepeatedly(Return(1u));
527 EXPECT_CALL(syncTaskContext, GetRequestSessionId()).WillRepeatedly(Return(0u));
668 EXPECT_CALL(syncTaskContext, GetRequestSessionId()).WillOnce(Return(1u));
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Disync_task_context.h122 virtual uint32_t GetRequestSessionId() const = 0;
H A Dsync_task_context.h117 uint32_t GetRequestSessionId() const override;
H A Dsync_task_context.cpp378 uint32_t SyncTaskContext::GetRequestSessionId() const in GetRequestSessionId() function in DistributedDB::SyncTaskContext
H A Dcommit_history_sync.cpp644 message->SetSessionId(context->GetRequestSessionId()); in SendRequestPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.cpp515 (inMsg->GetSessionId() != context_->GetRequestSessionId())) { in IsPacketValid()
518 inMsg->GetSessionId(), context_->GetRequestSessionId()); in IsPacketValid()
H A Dvalue_slice_sync.cpp330 message->SetSessionId(context->GetRequestSessionId()); in SendFinishedRequest()
566 message->SetSessionId(context->GetRequestSessionId()); in SendRequestPacket()
H A Dmulti_ver_data_sync.cpp347 message->SetSessionId(context->GetRequestSessionId()); in SendFinishedRequest()
615 message->SetSessionId(context->GetRequestSessionId()); in SendRequestPacket()