/foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/ |
H A D | pan_bnep.h | 231 void BnepRecvDataCallbackTask(uint16_t lcid, uint8_t *data, int dataLength); 235 int ProcessBnepControlData(uint8_t *data, int dataLength, bool isExtension); 236 int ProcessBnepExtensionData(uint8_t *data, int dataLength); 237 int ProcessBnepControlCommandNotUnderstood(uint8_t *data, int dataLength); 238 int ProcessBnepSetupConnectionRequest(uint8_t *data, int dataLength); 239 int ProcessBnepSetupConnectionResponse(uint8_t *data, int dataLength); 240 int ProcessBnepFilterNetTypeSet(uint8_t *data, int dataLength); 241 int ProcessBnepFilterNetTypeResponse(uint8_t *data, int dataLength); 242 int ProcessBnepFilterMultiAddrSet(uint8_t *data, int dataLength); 243 int ProcessBnepFilterMultiAddrResponse(uint8_t *data, int dataLength); [all...] |
H A D | pan_bnep.cpp | 596 int dataLength = static_cast<int>(PacketSize(pkt)); in BnepRecvDataCallback() local 597 if (dataLength > 0) { in BnepRecvDataCallback() 598 std::unique_ptr<uint8_t[]> buff = std::make_unique<uint8_t[]>(dataLength); in BnepRecvDataCallback() 599 PacketRead(pkt, buff.get(), 0, dataLength); in BnepRecvDataCallback() 602 event.dataLength_ = dataLength; in BnepRecvDataCallback() 812 void PanBnep::BnepRecvDataCallbackTask(uint16_t lcid, uint8_t *data, int dataLength) in BnepRecvDataCallbackTask() argument 814 if ((data == nullptr) || (dataLength < 1)) { in BnepRecvDataCallbackTask() 827 ret = ProcessBnepControlData(data + offset, dataLength - offset, false); in BnepRecvDataCallbackTask() 833 ret = ProcessBnepEthernetPacketHeader(type, ethernetHeader, data + offset, dataLength - offset); in BnepRecvDataCallbackTask() 846 ret = ProcessBnepExtensionData(data + offset, dataLength in BnepRecvDataCallbackTask() 858 SendBnepDataEvent(EthernetHeader ethernetHeader, int dataLength, int offset, uint8_t *data) SendBnepDataEvent() argument 889 ProcessBnepExtensionData(uint8_t *data, int dataLength) ProcessBnepExtensionData() argument 919 ProcessBnepControlData(uint8_t *data, int dataLength, bool isExtension) ProcessBnepControlData() argument 972 ProcessBnepControlCommandNotUnderstood(uint8_t *data, int dataLength) ProcessBnepControlCommandNotUnderstood() argument 985 ProcessBnepSetupConnectionRequest(uint8_t *data, int dataLength) ProcessBnepSetupConnectionRequest() argument 1028 ProcessBnepSetupConnectionResponse(uint8_t *data, int dataLength) ProcessBnepSetupConnectionResponse() argument 1042 ProcessBnepFilterNetTypeSet(uint8_t *data, int dataLength) ProcessBnepFilterNetTypeSet() argument 1090 ProcessBnepFilterNetTypeResponse(uint8_t *data, int dataLength) ProcessBnepFilterNetTypeResponse() argument 1104 ProcessBnepFilterMultiAddrSet(uint8_t *data, int dataLength) ProcessBnepFilterMultiAddrSet() argument 1156 ProcessBnepFilterMultiAddrResponse(uint8_t *data, int dataLength) ProcessBnepFilterMultiAddrResponse() argument 1276 ProcessBnepEthernetPacketHeader(uint8_t type, EthernetHeader ðernetHeader, uint8_t *data, int dataLength) ProcessBnepEthernetPacketHeader() argument [all...] |
H A D | pan_statemachine.cpp | 248 int dataLength = 0; in ProcessReciveData() local 251 dataLength = msg.dataLength_; in ProcessReciveData() 253 PanService::GetService()->WriteNetworkData(address_, msg.ethernetHeader_, data, dataLength); in ProcessReciveData() 259 int dataLength = 0; in ProcessSendData() local 262 dataLength = msg.dataLength_; in ProcessSendData() 264 panBnep_.SendData(msg.ethernetHeader_, data, dataLength); in ProcessSendData()
|
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/ |
H A D | tcp_connection.cpp | 206 uint32_t dataLength = GetReceivedDataLength(header); in HandleReceivedData() local 207 if (dataLength > ILLEGAL_LENGTH) { in HandleReceivedData() 212 uint8_t buf[dataLength]; in HandleReceivedData() 213 if (memset_s(buf, dataLength, 0, dataLength) != RET_OK) { in HandleReceivedData() 221 if (length != dataLength) { in HandleReceivedData() 227 HandleRemoteControlReceivedData(dataLength, header, buf); in HandleReceivedData() 230 CLOGD("TCP recvFrameLen done, dataLength = %{public}d", dataLength); in HandleReceivedData() 232 GetListener()->OnDataReceived(buf, dataLength, in HandleReceivedData() 240 uint32_t dataLength = Utils::ByteArrayToInt(header, PACKET_HEADER_LEN); GetReceivedDataLength() local 248 HandleRemoteControlReceivedData(uint32_t dataLength, uint8_t *header, uint8_t *buf) HandleRemoteControlReceivedData() argument [all...] |
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/ |
H A D | tcp_connection.cpp | 206 uint32_t dataLength = GetReceivedDataLength(header); in HandleReceivedData() local 207 if (dataLength > ILLEGAL_LENGTH) { in HandleReceivedData() 212 uint8_t buf[dataLength]; in HandleReceivedData() 213 if (memset_s(buf, dataLength, 0, dataLength) != RET_OK) { in HandleReceivedData() 221 if (length != dataLength) { in HandleReceivedData() 227 HandleRemoteControlReceivedData(dataLength, header, buf); in HandleReceivedData() 230 CLOGD("TCP recvFrameLen done, dataLength = %{public}d", dataLength); in HandleReceivedData() 232 GetListener()->OnDataReceived(buf, dataLength, in HandleReceivedData() 240 uint32_t dataLength = Utils::ByteArrayToInt(header, PACKET_HEADER_LEN); GetReceivedDataLength() local 248 HandleRemoteControlReceivedData(uint32_t dataLength, uint8_t *header, uint8_t *buf) HandleRemoteControlReceivedData() argument [all...] |
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/utils/ |
H A D | media_cached_buffer.cpp | 64 chunkInfo.dataLength = 0; in InitChunkInfo() 123 chunkInfo->dataLength = 0; in Init() 179 offset > (*chunkPos)->offset + (*chunkPos)->dataLength) { in ReadInner() 196 if (offsetChunk < chunkInfo->offset || diff > chunkInfo->dataLength) { in ReadInner() 200 uint64_t readDiff = chunkInfo->dataLength > diff ? chunkInfo->dataLength - diff : 0; in ReadInner() 231 return (inputOffset <= chunk->offset + chunk->dataLength); in WriteInPlace() 241 offset < chunkInfoTmp->offset + static_cast<uint64_t>(chunkInfoTmp->dataLength)) { in WriteInPlace() 243 size_t copyLen = static_cast<size_t>(chunkInfoTmp->dataLength - diff); in WriteInPlace() 259 auto copyLen = std::min(chunkInfoTmp->dataLength, (uint32_ in WriteInPlace() 292 uint64_t dataLength = static_cast<uint64_t>(chunkInfo->dataLength); WriteMergerPre() local 545 int64_t dataLength = static_cast<int64_t>(cacheChunk->dataLength); UpdateFragmentCacheForDelHead() local 569 auto dataLength = cacheChunk->dataLength; UpdateFragmentCacheForDelTail() local 1077 int64_t dataLength = 0; CheckInner() local [all...] |
H A D | media_cached_buffer.h | 39 uint32_t dataLength; member 49 int64_t dataLength; member 57 explicit FragmentCacheBuffer(uint64_t offset = 0) : offsetBegin(offset), dataLength(0), in FragmentCacheBuffer() 124 if (pred(offset, fragmentPos->offsetBegin, fragmentPos->offsetBegin + fragmentPos->dataLength)) { in GetOffsetFragmentCache() 131 if (pred(offset, fragment.offsetBegin, fragment.offsetBegin + fragment.dataLength)) { in GetOffsetFragmentCache() 145 if (pred(offset, fragment->offset, fragment->offset + fragment->dataLength)) { in GetOffsetChunkCache()
|
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
H A D | wifi_p2p_service_request_list.cpp | 118 unsigned short dataLength = length - PROTOCOL_SIZE - TRANSACTION_ID_SIZE; in ParseTlvs2ReqList() local 122 if (dataLength > leftLength - headLength || dataLength < 0) { in ParseTlvs2ReqList() 129 for (unsigned short i = 0; i < dataLength; ++i) { in ParseTlvs2ReqList() 132 pos += dataLength; in ParseTlvs2ReqList() 139 leftLength = leftLength - headLength - dataLength; in ParseTlvs2ReqList()
|
H A D | wifi_p2p_service_response_list.cpp | 157 unsigned short dataLength = length - PROTOCOL_SIZE - TRANSACTION_ID_SIZE - SERVICE_STATUS_SIZE; in ParseTlvs2RespList() local 162 if (dataLength > leftLength - headLength || dataLength < 0) { in ParseTlvs2RespList() 168 if (dataLength <= MAX_BUF_SIZE) { in ParseTlvs2RespList() 170 for (unsigned short i = 0; i < dataLength; ++i) { in ParseTlvs2RespList() 177 pos += dataLength; in ParseTlvs2RespList() 178 leftLength = leftLength - headLength - dataLength; in ParseTlvs2RespList()
|
/foundation/ability/dmsfwk_lite/source/ |
H A D | dmslite_famgr.c | 132 if (want->data != NULL && want->dataLength > 0) {
in MarshallDmsMessage() 133 RAWDATA_MARSHALL_HELPER(RawData, CALLER_PAYLOAD, want->data, want->dataLength);
in MarshallDmsMessage() 199 if (want->data != NULL && want->dataLength > 0) {
in FillRequestData() 200 void *data = DMS_ALLOC(want->dataLength);
in FillRequestData() 204 if (memcpy_s(data, want->dataLength, want->data, want->dataLength) != EOK) {
in FillRequestData() 209 wantData->dataLength = want->dataLength;
in FillRequestData()
|
/foundation/ai/neural_network_runtime/test/unittest/components/memory_manager/ |
H A D | memory_manager_test.cpp | 91 const size_t dataLength = 100; in HWTEST_F() local 92 data.resize(dataLength, '*'); in HWTEST_F() 146 const size_t dataLength = 100; in HWTEST_F() local 147 data.resize(dataLength, '/'); in HWTEST_F() 201 const size_t dataLength = 100; in HWTEST_F() local 202 data.resize(dataLength, '%'); in HWTEST_F()
|
/foundation/ability/ability_lite/frameworks/want_lite/src/ |
H A D | want.cpp | 157 void *newWantData = AdapterMalloc(tlv->totalLen + want->dataLength); 161 if (memcpy_s(newWantData, want->dataLength, want->data, want->dataLength) != 0 || 162 memcpy_s((unsigned char*)newWantData + want->dataLength, tlv->totalLen, tlv->entity, tlv->totalLen) != 0) { 166 SetWantData(want, newWantData, tlv->totalLen + want->dataLength); 266 bool SetWantData(Want *want, const void *data, uint16_t dataLength) 273 want->data = OHOS::Utils::Memdup(data, dataLength); 275 want->dataLength = 0; 279 want->dataLength = dataLength; [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/service/src/classic/ |
H A D | classic_data_structure.cpp | 26 ClassicDataStructure::ClassicDataStructure(uint8_t dataLength, int type, const std::vector<uint8_t> &value) in ClassicDataStructure() argument 27 : length_(dataLength), type_(type), data_(value) in ClassicDataStructure()
|
/foundation/graphic/graphic_2d/rosen/test/2d_graphics/fuzztest/text/fontmgr_fuzzer/ |
H A D | fontmgr_fuzzer.cpp | 102 size_t dataLength = GetObject<size_t>() % MAX_SIZE + 1; in FontMgrFuzzTest003() local 103 uint8_t* dataText = new uint8_t[dataLength]; in FontMgrFuzzTest003() 111 for (size_t i = 0; i < dataLength; i++) { in FontMgrFuzzTest003() 114 fontMgr->LoadDynamicFont(str, dataText, dataLength); in FontMgrFuzzTest003() 148 size_t dataLength = GetObject<size_t>() % MAX_SIZE + 1; in FontMgrFuzzTest004() local 149 uint8_t* dataText = new uint8_t[dataLength]; in FontMgrFuzzTest004() 157 for (size_t i = 0; i < dataLength; i++) { in FontMgrFuzzTest004() 160 fontMgr->LoadDynamicFont(str, dataText, dataLength); in FontMgrFuzzTest004() 208 size_t dataLength = GetObject<size_t>() % MAX_SIZE + 1; in FontMgrFuzzTest005() local 209 uint8_t* dataText = new uint8_t[dataLength]; in FontMgrFuzzTest005() [all...] |
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/text/ |
H A D | font_mgr.cpp | 37 Typeface* FontMgr::LoadDynamicFont(const std::string& familyName, const uint8_t* data, size_t dataLength) in LoadDynamicFont() argument 40 return fontMgrImpl_->LoadDynamicFont(familyName, data, dataLength); in LoadDynamicFont() 46 const uint8_t* data, size_t dataLength) in LoadThemeFont() 49 return fontMgrImpl_->LoadThemeFont(familyName, themeName, data, dataLength); in LoadThemeFont() 45 LoadThemeFont(const std::string& familyName, const std::string& themeName, const uint8_t* data, size_t dataLength) LoadThemeFont() argument
|
/foundation/arkui/ace_engine_lite/frameworks/src/core/modules/presets/ |
H A D | feature_ability_module.cpp | 370 int32_t FeatureAbilityModule::MessageFailCallback(const void *data, uint16_t dataLength, uint16_t errorCode) in MessageFailCallback() argument 380 if ((data != nullptr) && (dataLength > 0)) { in MessageFailCallback() 381 char *buffer = static_cast<char *>(ace_malloc(sizeof(char) * (dataLength + 1))); in MessageFailCallback() 382 if (buffer != nullptr && memcpy_s(buffer, dataLength, static_cast<const char *>(data), dataLength) == 0) { in MessageFailCallback() 383 buffer[dataLength] = '\0'; in MessageFailCallback() 384 params->dataLength = dataLength; in MessageFailCallback() 388 params->dataLength = 0; in MessageFailCallback() 447 if (params->data == nullptr || params->dataLength in AsyncFailCallback() [all...] |
H A D | feature_ability_module.h | 30 uint16_t dataLength; member 32 FailCallbackParams() : data(nullptr), dataLength(0), errorCode(0) {} in FailCallbackParams() 128 static int32_t MessageFailCallback(const void *data, uint16_t dataLength, uint16_t errorCode);
|
/foundation/ability/ability_lite/interfaces/kits/want_lite/ |
H A D | want.h | 77 uint16_t dataLength;
member 146 * @param dataLength Indicates the data length to set. The length must be the same as that of the data specified in
151 bool SetWantData(Want *want, const void *data, uint16_t dataLength);
|
/foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/slite/ |
H A D | abilityms_slite_client.cpp | 91 info->dataLength = 0;
in StartAbility() 99 SetWantData(info, want->data, want->dataLength);
in StartAbility() 213 want->dataLength = 0;
in ForceStop() 240 info->dataLength = 0;
in ForceStop() 243 SetWantData(info, want->data, want->dataLength);
in ForceStop()
|
/foundation/arkui/ace_engine_lite/interfaces/inner_api/builtin/async/ |
H A D | message_queue_utils.h | 90 uint16_t dataLength; member 91 AbilityInnerMsg() : msgId(UNKNOWN), token(0), bundleName(nullptr), path(nullptr), data(nullptr), dataLength(0) {} in AbilityInnerMsg()
|
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/impl_interface/ |
H A D | font_mgr_impl.h | 33 virtual Typeface* LoadDynamicFont(const std::string& familyName, const uint8_t* data, size_t dataLength) = 0; 35 const uint8_t* data, size_t dataLength) = 0;
|
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/drawing_ndk/src/ |
H A D | drawing_register_font.cpp | 62 OH_Drawing_FontCollection* fontCollection, const std::string& familyName, const uint8_t* data, size_t dataLength) in LoadFromFontCollection() 67 if ((data == nullptr) != (dataLength == 0)) { in LoadFromFontCollection() 71 auto face = fc->LoadFont(familyName, data, dataLength); in LoadFromFontCollection() 61 LoadFromFontCollection( OH_Drawing_FontCollection* fontCollection, const std::string& familyName, const uint8_t* data, size_t dataLength) LoadFromFontCollection() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
H A D | distributeddb_communicator_deep_test.cpp | 345 const uint32_t dataLength = 13 * 1024 * 1024; // 13 MB, 1024 is scale in HWTEST_F() local 346 Message *sendMsgForAB = BuildRegedGiantMessage(dataLength); in HWTEST_F() 359 Message *oriMsgForAB = BuildRegedGiantMessage(dataLength); in HWTEST_F() 406 uint32_t dataLength = 13 * 1024 * 1024; // 13 MB, 1024 is scale in HWTEST_F() local 407 Message *sendMsgForBC = BuildRegedGiantMessage(dataLength); in HWTEST_F() 424 dataLength = 17 * 1024 * 1024; // 17 MB, 1024 is scale in HWTEST_F() 425 Message *resendMsgForBC = BuildRegedGiantMessage(dataLength); in HWTEST_F() 434 EXPECT_EQ(dataLength, recvObjForCC->rawData_.size()); in HWTEST_F() 477 uint32_t dataLength = 23 * 1024 * 1024; // 23 MB, 1024 is scale in HWTEST_F() local 478 Message *sendMsgForAB = BuildRegedGiantMessage(dataLength); in HWTEST_F() 535 const uint32_t dataLength = 13 * 1024 * 1024; // 13 MB, 1024 is scale HWTEST_F() local [all...] |
/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/ |
H A D | ability_record_manager.cpp | 79 want->dataLength = 0; in StartLauncher() 104 want->dataLength = 0; in StartAbility() 112 want->dataLength = record->abilityData->wantDataSize; in StartAbility() 217 abilityRecord->SetWantData(want->data, want->dataLength); in StartAbility() 243 info->data = OHOS::Utils::Memdup(want->data, want->dataLength); in StartAbility() 244 info->dataLength = want->dataLength; in StartAbility() 266 record->SetWantData(info->data, info->dataLength); in UpdateRecord() 463 newTopRecord->SetWantData(want->data, want->dataLength); in TerminateAbility() 465 HILOG_INFO(HILOG_MODULE_AAFWK, "Terminate ability with want, dataLength i in TerminateAbility() [all...] |
/foundation/multimedia/audio_framework/services/audio_service/test/unittest/ |
H A D | volume_tools_unit_test.cpp | 46 size_t dataLength, uint8_t *metaBuffer, size_t metaLength); 197 desc.dataLength = (MIN_FRAME_SIZE - 1) * 3 * STEREO + 3; in HWTEST_F() 218 desc.dataLength = (MIN_FRAME_SIZE - 1) * 3 * STEREO + 1; in HWTEST_F() 242 desc.dataLength = (MIN_FRAME_SIZE - 1) * 3 * STEREO + 6; in HWTEST_F()
|