Home
last modified time | relevance | path

Searched refs:GetResponseSessionId (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Disync_target.h55 virtual uint32_t GetResponseSessionId() const = 0;
H A Dsync_target.h51 uint32_t GetResponseSessionId() const override;
H A Dsync_target.cpp82 uint32_t SyncTarget::GetResponseSessionId() const in GetResponseSessionId() function in DistributedDB::SyncTarget
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_target.h40 uint32_t GetResponseSessionId() const override;
H A Dsingle_ver_sync_target.cpp58 uint32_t SingleVerSyncTarget::GetResponseSessionId() const in GetResponseSessionId() function in DistributedDB::SingleVerSyncTarget
H A Dsingle_ver_sync_state_machine.cpp408 …bool ignoreInnerErr = (context_->GetResponseSessionId() != 0 && context_->GetRequestSessionId() !=… in DoInitiactiveDataSyncWithSlidingWindow()
419 } else if (context_->GetResponseSessionId() == 0 || in DoPassiveDataSyncWithSlidingWindow()
587 if (errCode != E_OK && inMsg->GetSessionId() == context_->GetResponseSessionId()) { in AbilitySyncRecv()
754 bool ignoreInnerErr = inMsg->GetSessionId() == context_->GetResponseSessionId() && in HandleDataAckRecv()
941 (inMsg->GetSessionId() != context_->GetResponseSessionId())) { in IsPacketValid()
961 context_->SetResponseSessionId(target.GetResponseSessionId()); in PreStartPullResponse()
998 …if (context_->GetResponseSessionId() == sessionId || context_->FindResponseSyncTarget(sessionId)) { in AddPullResponseTarget()
1069 if (inMsg->GetSessionId() == context_->GetResponseSessionId()) { in IsNeedResetWatchdog()
H A Dsingle_ver_sync_task_context.cpp189 uint32_t SingleVerSyncTaskContext::GetResponseSessionId() const in GetResponseSessionId() function in DistributedDB::SingleVerSyncTaskContext
201 responseSessionId_ = targetTmp->GetResponseSessionId(); in CopyTargetData()
379 return target->GetResponseSessionId() == responseSessionId; in FindResponseSyncTarget()
H A Dsingle_ver_sync_task_context.h71 uint32_t GetResponseSessionId() const;
H A Dsingle_ver_data_sync.cpp266 context->StartFeedDogForGetData(context->GetResponseSessionId()); in GetDataWithPerformanceRecord()
450 sessionId_ = context->GetResponseSessionId(); in ResetSyncStatus()
1106 context->GetSequenceId(), context->GetResponseSessionId()); in SendPullResponseDataPkt()
1226 if (((message->GetSessionId() == context->GetResponseSessionId()) || in AckRecv()
1378 context->GetSequenceId(), context->GetResponseSessionId()); in SendResetWatchDogPacket()