Home
last modified time | relevance | path

Searched refs:packetSize (Results 1 - 25 of 29) sorted by relevance

12

/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/a2dp_codec/sbccodecctrl/src/
H A Da2dp_decoder_sbc.cpp55 uint16_t packetSize = size; in DecodePacket() local
57 (void)memcpy_s(buf, CODEC_BUFFER_SIZE4K, data, packetSize); in DecodePacket()
66 if (pos >= packetSize) { in DecodePacket()
67 LOG_INFO("pos > packetSize"); in DecodePacket()
71 frameLen = sbcDecoder_->SBCDecode(g_sbcDecode, &buf[pos], packetSize - pos, in DecodePacket()
80 LOG_INFO("[DataAvailable][packetSize:%hu][count:%{public}d][len:%{public}zu][frameLen:%{public}d]", in DecodePacket()
81 packetSize, count, len, frameLen); in DecodePacket()
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/
H A Dclient_trans_proxy_file_manager_mock_test.cpp112 .packetSize = 1, in HWTEST_F()
127 info.packetSize = PROXY_BLE_MAX_PACKET_SIZE; in HWTEST_F()
147 uint32_t packetSize = TEST_PACKET_SIZE; in HWTEST_F() local
166 int32_t ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
174 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
H A Dclient_trans_proxy_file_manager_test.cpp696 info.packetSize = PROXY_BLE_MAX_PACKET_SIZE; in HWTEST_F()
967 info.packetSize = PROXY_BLE_MAX_PACKET_SIZE; in HWTEST_F()
985 uint32_t packetSize = TEST_PACKET_SIZE; in HWTEST_F() local
986 int32_t ret = UnpackFileTransStartInfo(nullptr, nullptr, nullptr, packetSize); in HWTEST_F()
999 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
1003 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
1008 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
1013 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
1017 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
1021 ret = UnpackFileTransStartInfo(&fileFrame, &info, &singleFileInfo, packetSize); in HWTEST_F()
1531 uint32_t packetSize = TEST_PACKET_SIZE; HWTEST_F() local
1840 uint32_t packetSize = TEST_PACKET_SIZE; HWTEST_F() local
1904 uint32_t packetSize; HWTEST_F() local
[all...]
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/src/
H A Drtp_codec_h264.cpp250 auto packetSize = GetMaxSize() - 2; // 2:fixed size in PackRtpFu() local
251 if (len <= packetSize + 1) { in PackRtpFu()
263 if (!fuFlags->startBit_ && len <= offset + packetSize) { in PackRtpFu()
265 packetSize = len - offset; in PackRtpFu()
269 auto rtp = MakeRtp(nullptr, packetSize + 2, fuFlags->endBit_ && isMark, pts); // 2:fixed size in PackRtpFu()
277 auto ret = memcpy_s(payload + 2, packetSize, (uint8_t *)data + offset, packetSize); // 2:fixed size in PackRtpFu()
282 offset += packetSize; in PackRtpFu()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Drelational_remote_query_continue_token.cpp38 int RelationalRemoteQueryContinueToken::GetData(int packetSize, RelationalRowDataSet &dataSet) in GetData() argument
52 if (dataSet.CalcLength() + data_.at(0)->CalcLength() > packetSize) { in GetData()
H A Drelational_remote_query_continue_token.h33 int GetData(int packetSize, RelationalRowDataSet &dataSet);
/foundation/communication/netmanager_base/services/netmanagernative/include/netsys/
H A Dclatd_packet_converter.h51 bool IsV4PacketValid(const iphdr *ipHeader, size_t packetSize);
52 bool IsV6PacketValid(const ip6_hdr *ip6Header, size_t packetSize);
72 bool IsTcpPacketValid(const tcphdr *packet, size_t packetSize);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.h155 size_t packetSize);
157 int GetData(SingleVerSyncTaskContext *context, size_t packetSize, std::vector<SendDataItem> &outData);
164 int GetUnsyncData(SingleVerSyncTaskContext *context, std::vector<SendDataItem> &outData, size_t packetSize);
168 int GetNextUnsyncData(SingleVerSyncTaskContext *context, std::vector<SendDataItem> &outData, size_t packetSize);
237 DataSizeSpecInfo GetDataSizeSpecInfo(size_t packetSize);
H A Dsingle_ver_data_sync.cpp259 std::vector<SendDataItem> &outData, size_t packetSize) in GetDataWithPerformanceRecord()
268 int errCode = GetData(context, packetSize, outData); in GetDataWithPerformanceRecord()
279 int SingleVerDataSync::GetData(SingleVerSyncTaskContext *context, size_t packetSize, std::vector<SendDataItem> &outData) in GetData() argument
286 errCode = GetUnsyncData(context, outData, packetSize); in GetData()
291 errCode = GetUnsyncData(context, outData, packetSize); in GetData()
295 errCode = GetNextUnsyncData(context, outData, packetSize); in GetData()
311 size_t packetSize = (version > SOFTWARE_VERSION_RELEASE_2_0) ? in GetMatchData() local
316 int errCode = GetDataWithPerformanceRecord(context, syncOutData.entries, packetSize); in GetMatchData()
340 size_t packetSize) in GetUnsyncData()
343 DataSizeSpecInfo syncDataSizeInfo = GetDataSizeSpecInfo(packetSize); in GetUnsyncData()
258 GetDataWithPerformanceRecord(SingleVerSyncTaskContext *context, std::vector<SendDataItem> &outData, size_t packetSize) GetDataWithPerformanceRecord() argument
339 GetUnsyncData(SingleVerSyncTaskContext *context, std::vector<SendDataItem> &outData, size_t packetSize) GetUnsyncData() argument
390 GetNextUnsyncData(SingleVerSyncTaskContext *context, std::vector<SendDataItem> &outData, size_t packetSize) GetNextUnsyncData() argument
1640 size_t packetSize = (version > SOFTWARE_VERSION_RELEASE_2_0) ? GetReSendData() local
1780 GetDataSizeSpecInfo(size_t packetSize) GetDataSizeSpecInfo() argument
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/
H A Dpan_network.cpp410 ssize_t packetSize; in ReadPanNetworkEvent() local
413 } while ((packetSize = read(fd_, &packet, sizeof(packet))) == -1 && errno == EINTR); in ReadPanNetworkEvent()
415 if (packetSize <= 0) { in ReadPanNetworkEvent()
419 if (packetSize > PAN_MAX_NETWORK_PACKET_SIZE) { in ReadPanNetworkEvent()
420 LOG_ERROR("[Pan Network]%{public}s():packet size is too large packetSize=%{public}zu", in ReadPanNetworkEvent()
421 __FUNCTION__, packetSize); in ReadPanNetworkEvent()
424 if (packetSize > sizeof(EthernetHeader)) { in ReadPanNetworkEvent()
437 PanService::GetService()->PanSendData(head, packet + sizeof(head), packetSize - sizeof(head)); in ReadPanNetworkEvent()
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/
H A Dclatd_packet_converter_test.cpp385 size_t packetSize; in HWTEST_F() local
388 packetSize = sizeof(ip6_hdr) - 1; in HWTEST_F()
389 EXPECT_FALSE(clatdPacketConverter->IsV6PacketValid(&ip6Header, packetSize)); in HWTEST_F()
390 packetSize = sizeof(ip6_hdr); in HWTEST_F()
394 EXPECT_FALSE(clatdPacketConverter->IsV6PacketValid(&ip6Header, packetSize)); in HWTEST_F()
398 EXPECT_FALSE(clatdPacketConverter->IsV6PacketValid(&ip6Header, packetSize)); in HWTEST_F()
404 EXPECT_FALSE(clatdPacketConverter->IsV6PacketValid(&ip6Header, packetSize)); in HWTEST_F()
581 size_t packetSize = 0; in HWTEST_F() local
582 EXPECT_FALSE(clatdPacketConverter->IsTcpPacketValid(&tcpHeader, packetSize)); in HWTEST_F()
583 packetSize in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_proxy_file_manager.c262 if (fileFrame->frameLength > info->packetSize) { in PackFileTransStartInfo()
270 SoftBusHtoLl(info->packetSize - FRAME_HEAD_LEN - FRAME_DATA_SEQ_OFFSET - FRAME_CRC_LEN); in PackFileTransStartInfo()
278 if (fileFrame->frameLength > info->packetSize) { in PackFileTransStartInfo()
290 FileFrame *fileFrame, const FileRecipientInfo *info, SingleFileInfo *file, uint32_t packetSize) in UnpackFileTransStartInfo()
314 if (file->oneFrameLen > packetSize) { in UnpackFileTransStartInfo()
352 const char *sourceFile, uint64_t *fileSize, uint64_t *frameNum, int32_t crc, uint32_t packetSize) in GetAndCheckFileSize()
369 uint64_t oneFrameSize = packetSize - FRAME_DATA_SEQ_OFFSET; in GetAndCheckFileSize()
615 fileFrame.data = (uint8_t *)SoftBusCalloc(sendInfo->packetSize); in FileToFrame()
621 uint64_t frameDataSize = sendInfo->packetSize - FRAME_DATA_SEQ_OFFSET; in FileToFrame()
648 (void)memset_s(fileFrame.data, sendInfo->packetSize, in FileToFrame()
289 UnpackFileTransStartInfo( FileFrame *fileFrame, const FileRecipientInfo *info, SingleFileInfo *file, uint32_t packetSize) UnpackFileTransStartInfo() argument
351 GetAndCheckFileSize( const char *sourceFile, uint64_t *fileSize, uint64_t *frameNum, int32_t crc, uint32_t packetSize) GetAndCheckFileSize() argument
1224 GetFileInfoByStartFrame( const FileFrame *fileFrame, const FileRecipientInfo *info, SingleFileInfo *file, uint32_t packetSize) GetFileInfoByStartFrame() argument
1349 CreateFileFromFrame( int32_t sessionId, int32_t channelId, const FileFrame *fileFrame, int32_t osType, uint32_t packetSize) CreateFileFromFrame() argument
1877 CheckFrameLength(int32_t channelId, uint32_t frameLength, int32_t osType, uint32_t *packetSize) CheckFrameLength() argument
1903 uint32_t packetSize; ProcessRecvFileFrameData() local
[all...]
H A Dclient_trans_proxy_file_helper.c156 if (fileFrame->frameLength > info->packetSize) { in PackReadFileData()
174 if (fileFrame->frameLength > info->packetSize) { in PackReadFileData()
197 if (fileFrame->frameLength > info->packetSize) { in PackReadFileRetransData()
268 fileFrame.data = (uint8_t *)SoftBusCalloc(info->packetSize); in RetransFileFrameBySeq()
275 uint64_t frameDataSize = info->packetSize - FRAME_HEAD_LEN - FRAME_DATA_SEQ_OFFSET - FRAME_CRC_LEN; in RetransFileFrameBySeq()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dclatd_packet_converter.cpp236 bool ClatdPacketConverter::IsV4PacketValid(const iphdr *ipHeader, size_t packetSize) in IsV4PacketValid() argument
238 if (packetSize < sizeof(iphdr)) { in IsV4PacketValid()
246 if (static_cast<size_t>(ipHeader->ihl * WORD_32BIT_IN_BYTE_UNIT) > packetSize) { in IsV4PacketValid()
257 bool ClatdPacketConverter::IsV6PacketValid(const ip6_hdr *ip6Header, size_t packetSize) in IsV6PacketValid() argument
259 if (packetSize < sizeof(ip6_hdr)) { in IsV6PacketValid()
617 bool ClatdPacketConverter::IsTcpPacketValid(const tcphdr *tcpHeader, size_t packetSize) in IsTcpPacketValid() argument
619 if (packetSize < sizeof(tcphdr)) { in IsTcpPacketValid()
631 if (static_cast<size_t>(tcpHeader->doff * WORD_32BIT_IN_BYTE_UNIT) > packetSize) { in IsTcpPacketValid()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Drelational_db_sync_interface.h49 virtual int ExecuteQuery(const PreparedStmt &prepStmt, size_t packetSize, RelationalRowDataSet &data,
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/
H A Da2dp_profile.cpp1131 uint16_t packetSize = PacketSize(pkt); in ProcessSinkStream() local
1132 if (packetSize == 0) { in ProcessSinkStream()
1135 auto frameData = (uint8_t *)malloc(packetSize); in ProcessSinkStream()
1137 (void)memset_s(frameData, packetSize, 0, packetSize); in ProcessSinkStream()
1138 PacketRead(pkt, frameData, 0, packetSize); in ProcessSinkStream()
1140 utility::Message msg(A2DP_FRAME_READY, packetSize, frameData); in ProcessSinkStream()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/include/
H A Dclient_trans_proxy_file_manager.h156 uint32_t packetSize; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_relational_ver_sync_db_interface.h111 int ExecuteQuery(const PreparedStmt &prepStmt, size_t packetSize, RelationalRowDataSet &data,
H A Dvirtual_single_ver_sync_db_Interface.cpp645 if (dataItems.size() >= dataSizeInfo.packetSize) { in GetDataInner()
646 LOGD("virtual device dataItem size reach to packetSize=%u", dataSizeInfo.packetSize); in GetDataInner()
H A Dvirtual_relational_ver_sync_db_interface.cpp332 int VirtualRelationalVerSyncDBInterface::ExecuteQuery(const PreparedStmt &prepStmt, size_t packetSize, in ExecuteQuery() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddb_types.h89 size_t packetSize = DBConstant::MAX_HPMODE_PACK_ITEM_SIZE; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dremote_executor.cpp908 int RemoteExecutor::GetPacketSize(const std::string &device, size_t &packetSize) const in GetPacketSize()
916 packetSize = communicator->GetCommunicatorMtuSize(device) * 9 / 10; // get the 9/10 of the size in GetPacketSize()
941 size_t packetSize = 0u; in ResponseRemoteQueryRequest() local
942 int errCode = GetPacketSize(device, packetSize); in ResponseRemoteQueryRequest()
960 errCode = storage->ExecuteQuery(stmt, packetSize, dataSet, token); in ResponseRemoteQueryRequest()
H A Dremote_executor.h138 int GetPacketSize(const std::string &device, size_t &packetSize) const;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h125 int ExecuteQuery(const PreparedStmt &prepStmt, size_t packetSize, RelationalRowDataSet &data,
262 int GetRemoteQueryData(const PreparedStmt &prepStmt, size_t packetSize,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp371 bool reachThreshold = (dataItems.size() >= dataSizeInfo.packetSize); in CanHoldDeletedData()
869 int RelationalSyncAbleStorage::GetRemoteQueryData(const PreparedStmt &prepStmt, size_t packetSize, in GetRemoteQueryData() argument
885 errCode = handle->ExecuteQueryBySqlStmt(prepStmt.GetSql(), prepStmt.GetBindArgs(), packetSize, colNames, data); in GetRemoteQueryData()
893 int RelationalSyncAbleStorage::ExecuteQuery(const PreparedStmt &prepStmt, size_t packetSize, in ExecuteQuery() argument
903 int errCode = GetRemoteQueryData(prepStmt, packetSize, colNames, data); in ExecuteQuery()
923 int errCode = remoteToken->GetData(packetSize, dataSet); in ExecuteQuery()

Completed in 28 milliseconds

12