Home
last modified time | relevance | path

Searched refs:outPacket (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp664 auto outPacket = outMsg.GetObject<DataRequestPacket>(); variable
665 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT);
666 EXPECT_EQ(outPacket->GetMode(), SyncModeType::QUERY_PUSH_PULL);
674 EXPECT_EQ(outPacket->GetQueryId(), syncQuery.GetIdentify());
676 EXPECT_EQ(outPacket->GetSendCode(), -E_NOT_SUPPORT);
677 EXPECT_EQ(outPacket->GetData()[0]->GetTimestamp(), 1u);
762 auto outPacket = outMsg.GetObject<DataAckPacket>(); variable
763 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT);
764 EXPECT_EQ(outPacket->GetData(), static_cast<uint64_t>(INT64_MAX));
766 EXPECT_EQ(outPacket->GetReserved(), reserved2);
[all …]
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp309 auto outPacket = outMsg.GetObject<SubscribeRequest>(); variable
310 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT);
311 EXPECT_EQ(outPacket->GetSendCode(), 100);
312 EXPECT_EQ(outPacket->GetcontrolCmdType(), SUBSCRIBE_QUERY_CMD);
313 EXPECT_EQ(outPacket->GetFlag(), 1u);
314 EXPECT_EQ(outPacket->GetQuery().GetIdentify(), syncQuery.GetIdentify());
364 auto outPacket = outMsg.GetObject<ControlAckPacket>(); variable
365 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT);
366 EXPECT_EQ(outPacket->GetRecvCode(), -E_NOT_SUPPORT);
367 EXPECT_EQ(outPacket->GetcontrolCmdType(), SUBSCRIBE_QUERY_CMD);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dprotocol_proto.cpp1017 …::FillFragmentPacketExtendHead(uint8_t *headBytesAddr, uint32_t headLen, FragmentPacket &outPacket) in FillFragmentPacketExtendHead() argument
1019 if (headLen > outPacket.leftLength) { in FillFragmentPacketExtendHead()
1023 errno_t retCode = memcpy_s(outPacket.ptrPacket, outPacket.leftLength, headBytesAddr, headLen); in FillFragmentPacketExtendHead()
1033 const uint8_t *fragBytes, uint32_t fragLen, FragmentPacket &outPacket) in FillFragmentPacket() argument
1035 if (outPacket.leftLength == 0) { in FillFragmentPacket()
1038 uint8_t *ptrPacket = outPacket.ptrPacket; in FillFragmentPacket()
1039 uint32_t leftLength = outPacket.leftLength; in FillFragmentPacket()
1064 int errCode = CalculateXorSum(outPacket.ptrPacket + LENGTH_BEFORE_SUM_RANGE, in FillFragmentPacket()
1065 outPacket.leftLength - LENGTH_BEFORE_SUM_RANGE, sumResult); in FillFragmentPacket()
1069 auto ptrPhyHeader = reinterpret_cast<CommPhyHeader *>(outPacket.ptrPacket); in FillFragmentPacket()
H A Dprotocol_proto.h129 const uint8_t *fragBytes, uint32_t fragLen, FragmentPacket &outPacket);
130 … FillFragmentPacketExtendHead(uint8_t *headBytesAddr, uint32_t headLen, FragmentPacket &outPacket);
/ohos5.0/drivers/hdf_core/framework/model/audio/usb/src/
H A Daudio_usb_endpoints.c388 struct AudioUsbPacketInfo *outPacket = NULL; in AudioUsbUpdataOutPacket() local
401 outPacket = endpoint->nextPacket + endpoint->nextPacketWritePos; in AudioUsbUpdataOutPacket()
403 outPacket->packets = inUrbCtx->packets; in AudioUsbUpdataOutPacket()
406 outPacket->packetSize[i] = urb->iso_frame_desc[i].actual_length / sender->stride; in AudioUsbUpdataOutPacket()
408 outPacket->packetSize[i] = 0; in AudioUsbUpdataOutPacket()