Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_message_schedule.cpp85 if (GetPacketId(inMsg, curPacketId) != E_OK) { in ScheduleInfoHandle()
151 if (GetPacketId(msg, packetId) != E_OK) { in GetMsgFromMap()
302 if (GetPacketId(msg, packetId) != E_OK) { in UpdateMsgMapIfNeed()
324 if ((GetPacketId(messageMap_[sequenceId], cachePacketId) == E_OK) && in UpdateMsgMapIfNeed()
340 int SingleVerDataMessageSchedule::GetPacketId(const Message *msg, uint64_t &packetId) in GetPacketId() function in DistributedDB::SingleVerDataMessageSchedule
346 packetId = packet->GetPacketId(); in GetPacketId()
H A Dsingle_ver_data_packet.h78 uint64_t GetPacketId() const;
175 uint64_t GetPacketId() const;
H A Dsingle_ver_data_message_schedule.h55 int GetPacketId(const Message *msg, uint64_t &packetId);
H A Dsingle_ver_data_packet.cpp139 uint64_t DataRequestPacket::GetPacketId() const in GetPacketId() function in DistributedDB::DataRequestPacket
396 uint64_t DataAckPacket::GetPacketId() const in GetPacketId() function in DistributedDB::DataAckPacket
H A Dsingle_ver_data_sync.cpp164 …uint64_t packetId = packet->GetPacketId(); // above 102 version data request reserve[0] store pack… in TryContinueSync()
645 reSendInfo.packetId = context->GetPacketId(); in UpdateSendInfo()
1166 …uint64_t packetId = packet->GetPacketId(); // above 102 version data request reserve[0] store pack… in AckPacketIdCheck()
1605 …packetId = packet->GetPacketId(); // above 102 version data request reserve[0] store packetId value in SetAckPacket()
H A Dsingle_ver_data_sync_utils.cpp271 std::vector<uint64_t> reserved {context->GetPacketId()}; in SetPacketId()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_msg_schedule_test.cpp264 EXPECT_EQ(packet->GetPacketId(), i + 3);
321 EXPECT_EQ(packet->GetPacketId(), i + 3);
387 EXPECT_EQ(packet->GetPacketId(), i);
431 EXPECT_EQ(packet->GetPacketId(), i + 3);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_task_context.h126 uint64_t GetPacketId() const;
H A Dsync_task_context.cpp403 uint64_t SyncTaskContext::GetPacketId() const in GetPacketId() function in DistributedDB::SyncTaskContext