Home
last modified time | relevance | path

Searched refs:dataLen (Results 1 - 25 of 447) sorted by relevance

12345678910>>...18

/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/transport/
H A Ddh_transport_test.cpp81 uint32_t dataLen = 0; in HWTEST_F() local
82 dhTransportTest_->OnBytesReceived(sessionId, data, dataLen); in HWTEST_F()
84 dhTransportTest_->OnBytesReceived(g_socketid, data, dataLen); in HWTEST_F()
87 dhTransportTest_->OnBytesReceived(sessionId, dataMsg, dataLen); in HWTEST_F()
89 dhTransportTest_->OnBytesReceived(g_socketid, dataMsg, dataLen); in HWTEST_F()
91 dataLen = 1; in HWTEST_F()
92 dhTransportTest_->OnBytesReceived(g_socketid, data, dataLen); in HWTEST_F()
94 dhTransportTest_->OnBytesReceived(sessionId, data, dataLen); in HWTEST_F()
95 dhTransportTest_->OnBytesReceived(sessionId, dataMsg, dataLen); in HWTEST_F()
96 dataLen in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_trans.c40 static int32_t UnpackTransHeader(uint8_t *data, uint32_t dataLen, BleTransHeader *header) in UnpackTransHeader() argument
42 if (dataLen < BLE_TRANS_HEADER_SIZE) { in UnpackTransHeader()
50 if ((header->size != dataLen - BLE_TRANS_HEADER_SIZE) || (header->total > MAX_DATA_LEN) || in UnpackTransHeader()
53 "unpack ble trans header failed, dataLen=%{public}u, total=%{public}u, currentPacketSize=%{public}u", in UnpackTransHeader()
54 dataLen, header->total, header->size); in UnpackTransHeader()
79 uint32_t connectionId, uint8_t *data, uint32_t dataLen, ConnBleReadBuffer *buffer, uint32_t *outLen) in ConnGattTransRecv()
83 CONN_CHECK_AND_RETURN_RET_LOGW(dataLen != 0, NULL, CONN_BLE, in ConnGattTransRecv()
89 CONN_CHECK_AND_RETURN_RET_LOGW(UnpackTransHeader(data, dataLen, &header) == SOFTBUS_OK, NULL, CONN_BLE, in ConnGattTransRecv()
90 "unpack ble trans header failed, discard this packet, connectionId=%{public}u, dataLen=%{public}u", in ConnGattTransRecv()
91 connectionId, dataLen); in ConnGattTransRecv() local
78 ConnGattTransRecv( uint32_t connectionId, uint8_t *data, uint32_t dataLen, ConnBleReadBuffer *buffer, uint32_t *outLen) ConnGattTransRecv() argument
269 ConnGattTransSend(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module) ConnGattTransSend() argument
312 ConnBlePostBytesInner(uint32_t connectionId, uint8_t *data, uint32_t dataLen, int32_t pid, int32_t flag, int32_t module, int64_t seq, PostBytesFinishAction postBytesFinishAction) ConnBlePostBytesInner() argument
443 ConnBlePackCtrlMsgHeader(ConnPktHead *header, uint32_t dataLen) ConnBlePackCtrlMsgHeader() argument
460 uint32_t dataLen = 0; ConnBlePackCtlMessage() local
565 ConnCocTransSend(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module) ConnCocTransSend() argument
[all...]
/foundation/CastEngine/castengine_wifi_display/services/utils/
H A Ddata_buffer.cpp114 void DataBuffer::PushData(const char *data, int dataLen) in PushData() argument
120 if (dataLen + size_ <= capacity_) { in PushData()
121 auto ret = memcpy_s(data_ + size_, capacity_, data, dataLen); in PushData()
125 size_ += dataLen; in PushData()
127 capacity_ = size_ + dataLen; in PushData()
138 auto ret = memcpy_s(newBuffer + size_, capacity_, data, dataLen); in PushData()
148 void DataBuffer::ReplaceData(const char *data, int dataLen) in ReplaceData() argument
154 if (dataLen > capacity_) { in ReplaceData()
157 capacity_ = dataLen; in ReplaceData()
161 auto ret = memcpy_s(data_, capacity_, data, dataLen); in ReplaceData()
[all...]
H A Ddata_buffer.h83 void Append(const char *data, int32_t dataLen) in Append() argument
85 PushData(data, dataLen); in Append()
88 void Append(const uint8_t *data, int32_t dataLen) in Append() argument
90 PushData((const char *)data, dataLen); in Append()
98 void Assign(const char *data, int32_t dataLen) in Assign() argument
100 ReplaceData(data, dataLen); in Assign()
111 void PushData(const char *data, int32_t dataLen);
112 void ReplaceData(const char *data, int32_t dataLen);
/foundation/multimedia/av_session/services/session/server/softbus/
H A Dsoftbus_session_manager.cpp41 static void OnBytes(int socket, const void *data, unsigned int dataLen) in OnBytes() argument
43 SLOGI("OnBytesReceived sessionId[%{public}d], datalen[%{public}d]", socket, dataLen); in OnBytes()
44 std::string msg = std::string(static_cast<const char*>(data), dataLen); in OnBytes()
45 SoftbusSessionManager::GetInstance().OnBytes(socket, msg.c_str(), dataLen); in OnBytes()
48 static void OnMessage(int socket, const void *data, unsigned int dataLen) in OnMessage() argument
50 SLOGI("OnMessageReceived sessionId[%{public}d], datalen[%{public}d]", socket, dataLen); in OnMessage()
51 std::string msg = std::string(static_cast<const char*>(data), dataLen); in OnMessage()
52 SoftbusSessionManager::GetInstance().OnMessage(socket, msg.c_str(), dataLen); in OnMessage()
171 void SoftbusSessionManager::OnMessage(int32_t socket, const void *data, int32_t dataLen) in OnMessage() argument
179 listener->OnMessage(socket, data, dataLen); in OnMessage()
183 OnBytes(int32_t socket, const void *data, int32_t dataLen) OnBytes() argument
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/
H A Dstream_adaptor_test.cpp99 ssize_t dataLen = streamData.bufLen + adaptor->GetEncryptOverhead(); in HWTEST_F() local
100 std::unique_ptr<char[]> data = std::make_unique<char[]>(dataLen); in HWTEST_F()
101 int32_t ret = adaptor->Encrypt(streamData.buf, streamData.bufLen, data.get(), dataLen, adaptor->GetSessionKey()); in HWTEST_F()
103 ret = adaptor->Decrypt(data.get(), dataLen, streamData.buf, streamData.bufLen, adaptor->GetSessionKey()); in HWTEST_F()
123 ssize_t dataLen = streamData.bufLen + adaptor->GetEncryptOverhead(); in HWTEST_F() local
124 std::unique_ptr<char[]> data = std::make_unique<char[]>(dataLen); in HWTEST_F()
125 int32_t ret = adaptor->Encrypt(streamData.buf, streamData.bufLen, data.get(), dataLen, adaptor->GetSessionKey()); in HWTEST_F()
126 EXPECT_EQ(dataLen, ret); in HWTEST_F()
127 ret = adaptor->Decrypt(data.get(), dataLen + 1, streamData.buf, streamData.bufLen, adaptor->GetSessionKey()); in HWTEST_F()
/foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/
H A Dsession_callback_mock.cpp35 void InnerOnBytesReceived(int sessionId, const void *data, unsigned int dataLen) in InnerOnBytesReceived() argument
38 sessionImpl.BytesReceivedCallback(sessionId, data, dataLen); in InnerOnBytesReceived()
41 void InnerOnMessageReceived(int sessionId, const void *data, unsigned int dataLen) in InnerOnMessageReceived() argument
44 sessionImpl.MessageReceivedCallback(sessionId, data, dataLen); in InnerOnMessageReceived()
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dfile_transfer_manager.cpp55 uint32_t dataLen = msgHandler.GetDataSize(); in DownloadFileFromRemoteDevice() local
56 auto data = make_unique<uint8_t[]>(dataLen); in DownloadFileFromRemoteDevice()
57 msgHandler.PackData(data.get(), dataLen); in DownloadFileFromRemoteDevice()
58 LOGI("send data, dataLen:%{public}d, taskId: %{public}" PRIu64 "", dataLen, taskId); in DownloadFileFromRemoteDevice()
59 auto ret = sessionManager_->SendData(networkId, data.get(), dataLen); in DownloadFileFromRemoteDevice()
99 uint32_t dataLen = resp.GetDataSize(); in HandleDownloadFileRequest() local
100 auto data = make_unique<uint8_t[]>(dataLen); in HandleDownloadFileRequest()
101 resp.PackData(data.get(), dataLen); in HandleDownloadFileRequest()
102 auto ret = sessionManager_->SendData(receiverSessionId, data.get(), dataLen); in HandleDownloadFileRequest()
130 OnMessageHandle(const std::string &senderNetworkId, int receiverSessionId, const void *data, unsigned int dataLen) OnMessageHandle() argument
163 uint32_t dataLen = req.GetDataSize(); OnFileRecvHandle() local
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddistributed_mission_broadcast_listener.cpp27 void DistributedMissionBroadcastListener::OnDataRecv(std::string& senderNetworkId, uint8_t* payload, uint32_t dataLen) in OnDataRecv() argument
29 HILOGI("OnDataRecv, dataLen = %{public}u", dataLen); in OnDataRecv()
30 DMSContinueRecvMgr::GetInstance().NotifyDataRecv(senderNetworkId, payload, dataLen); in OnDataRecv()
/foundation/multimedia/av_session/services/session/server/test/fuzztest/softbussessionmanager_fuzzer/
H A Dsoftbussessionmanager_fuzzer.cpp41 void OnBytes(int32_t socket, const void *data, int32_t dataLen) override {};
42 void OnMessage(int32_t socket, const void *data, int32_t dataLen) override {};
65 unsigned int dataLen = 1; in SoftbusSessionManagerFuzzTest() local
66 manager_->OnBytes(socket, objectId, dataLen); in SoftbusSessionManagerFuzzTest()
67 manager_->OnBytes(socket, nullptr, dataLen); in SoftbusSessionManagerFuzzTest()
68 manager_->OnMessage(socket, objectId, dataLen); in SoftbusSessionManagerFuzzTest()
69 manager_->OnMessage(socket, nullptr, dataLen); in SoftbusSessionManagerFuzzTest()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/
H A Ddsched_softbus_session.cpp118 if (buffer->Size() != (headerPara.dataLen + BINARY_HEADER_FRAG_LEN) || headerPara.dataLen > headerPara.totalLen || in PackRecvData()
119 headerPara.dataLen > BINARY_DATA_MAX_LEN || headerPara.totalLen > BINARY_DATA_MAX_TOTAL_LEN) { in PackRecvData()
121 HILOGE("pack recv data failed, size: %" PRIu64", dataLen: %{public}d, totalLen: %{public}d session id:" in PackRecvData()
122 " %{public}d", bufferSize, headerPara.dataLen, headerPara.totalLen, sessionId_); in PackRecvData()
126 HILOGD("pack recv data Assemble, size: %" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
127 "%" PRId64" start", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
134 HILOGD("pack recv data Assemble, size: %" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
135 "%" PRId64" end", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
196 ret = memcpy_s(&headerPara.dataLen, sizeo in ReadTlvToHeader()
457 TlvItem dataLen = { TLV_TYPE_DATA_LEN, sizeof(uint32_t), headPara.dataLen }; MakeFragDataHeader() local
[all...]
/foundation/distributedhardware/distributed_camera/services/channel/src/
H A Ddcamera_softbus_session.cpp144 if (buffer->Size() != (headerPara.dataLen + BINARY_HEADER_FRAG_LEN) || headerPara.dataLen > headerPara.totalLen || in PackRecvData()
145 headerPara.dataLen > BINARY_DATA_MAX_LEN || headerPara.totalLen > BINARY_DATA_MAX_TOTAL_LEN) { in PackRecvData()
147 DHLOGE("pack recv data failed, size: %{public}" PRIu64", dataLen: %{public}d, totalLen: %{public}d sess: " in PackRecvData()
148 "%{public}s peerSess: %{public}s", bufferSize, headerPara.dataLen, headerPara.totalLen, in PackRecvData()
153 DHLOGD("pack recv data Assemble, size: %{public}" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
154 "%{public}" PRId64" start", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
161 DHLOGD("pack recv data Assemble, size: %{public}" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
162 "%{public}" PRId64" end", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
167 if (headerPara.dataLen ! in AssembleNoFrag()
[all...]
H A Ddcamera_softbus_adapter.cpp67 static void DCameraSourceOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnBytes() argument
69 DCameraSoftbusAdapter::GetInstance().SourceOnBytes(socket, data, dataLen); in DCameraSourceOnBytes()
73 static void DCameraSourceOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnMessage() argument
75 DCameraSoftbusAdapter::GetInstance().SourceOnMessage(socket, data, dataLen); in DCameraSourceOnMessage()
99 static void DCameraSinkOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSinkOnBytes() argument
101 DCameraSoftbusAdapter::GetInstance().SinkOnBytes(socket, data, dataLen); in DCameraSinkOnBytes()
105 static void DCameraSinkOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSinkOnMessage() argument
107 DCameraSoftbusAdapter::GetInstance().SinkOnMessage(socket, data, dataLen); in DCameraSinkOnMessage()
368 void DCameraSoftbusAdapter::SourceOnBytes(int32_t socket, const void *data, uint32_t dataLen) in SourceOnBytes() argument
370 if (dataLen in SourceOnBytes()
393 SourceOnMessage(int32_t socket, const void *data, uint32_t dataLen) SourceOnMessage() argument
409 int32_t dataLen = data->bufLen; SourceOnStream() local
583 SinkOnBytes(int32_t socket, const void *data, uint32_t dataLen) SinkOnBytes() argument
607 SinkOnMessage(int32_t socket, const void *data, uint32_t dataLen) SinkOnMessage() argument
619 int32_t dataLen = data->bufLen; SinkOnStream() local
[all...]
/foundation/communication/netstack/frameworks/js/napi/websocket/async_context/src/
H A Dsend_context.cpp41 size_t dataLen = LWS_SEND_BUFFER_PRE_PADDING + str.length() + LWS_SEND_BUFFER_POST_PADDING; in HandleParseString() local
42 if (dataLen == 0 || dataLen > MAX_LIMIT) { in HandleParseString()
46 data = malloc(dataLen); in HandleParseString()
72 size_t dataLen = LWS_SEND_BUFFER_PRE_PADDING + len + LWS_SEND_BUFFER_POST_PADDING; in HandleParseArrayBuffer() local
73 if (dataLen == 0 || dataLen > MAX_LIMIT) { in HandleParseArrayBuffer()
77 data = malloc(dataLen); in HandleParseArrayBuffer()
/foundation/ability/dmsfwk_lite/source/
H A Ddmslite_session.c46 static void OnBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen);
72 void OnBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen) in OnBytesReceived() argument
74 HILOGD("[OnBytesReceived dataLen = %u]", dataLen); in OnBytesReceived()
75 if (data == NULL || dataLen > MAX_DATA_SIZE) { in OnBytesReceived()
80 char *message = (char *)DMS_ALLOC(dataLen); in OnBytesReceived()
85 if (memcpy_s(message, dataLen, (char *)data, dataLen) != EOK) { in OnBytesReceived()
92 .len = dataLen, in OnBytesReceived()
104 void HandleBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen) in HandleBytesReceived() argument
[all...]
/foundation/communication/dsoftbus/core/bus_center/utils/src/
H A Dlnn_ipc_utils.c36 pubInfo->dataLen = *(int32_t *)info1; in ConvertVoidToPublishInfo()
38 if (pubInfo->dataLen > 0) { in ConvertVoidToPublishInfo()
40 info1 += pubInfo->dataLen + 1; in ConvertVoidToPublishInfo()
65 subInfo->dataLen = *(int32_t *)info1; in ConvertVoidToSubscribeInfo()
67 if (subInfo->dataLen > 0) { in ConvertVoidToSubscribeInfo()
H A Dlnn_common_utils.c55 if (in->dataLen >= UINT32_MAX - OVERHEAD_LEN) { in LnnEncryptAesGcm()
56 LNN_LOGE(LNN_STATE, "dataLen is invalid"); in LnnEncryptAesGcm()
59 uint32_t encDataLen = in->dataLen + OVERHEAD_LEN; in LnnEncryptAesGcm()
71 int32_t ret = SoftBusEncryptData(&cipherKey, in->data, in->dataLen, encData, &encDataLen); in LnnEncryptAesGcm()
88 if (in->dataLen <= OVERHEAD_LEN) { in LnnDecryptAesGcm()
89 LNN_LOGE(LNN_STATE, "dataLen is invalid"); in LnnDecryptAesGcm()
92 uint32_t decDataLen = in->dataLen - OVERHEAD_LEN; in LnnDecryptAesGcm()
104 int32_t ret = SoftBusDecryptData(&cipherKey, in->data, in->dataLen, decData, &decDataLen); in LnnDecryptAesGcm()
/foundation/communication/dsoftbus/core/discovery/ble/softbus_ble/src/
H A Ddisc_ble_utils.c218 uint32_t dataLen) in AssembleTLV()
220 uint32_t remainLen = BROADCAST_MAX_LEN - broadcastData->dataLen; in AssembleTLV()
223 broadcastData->data.data[broadcastData->dataLen] = (dataType << BYTE_SHIFT_4BIT) & MOST_SIGNIFICANT_4BIT_MASK; in AssembleTLV()
224 if (dataLen <= TLV_MAX_DATA_LEN) { in AssembleTLV()
225 broadcastData->data.data[broadcastData->dataLen] |= dataLen & LEAST_SIGNIFICANT_4BIT_MASK; in AssembleTLV()
227 broadcastData->dataLen += 1; in AssembleTLV()
230 uint32_t validLen = (dataLen > remainLen) ? remainLen : dataLen; in AssembleTLV()
231 errno_t retMem = memcpy_s(&(broadcastData->data.data[broadcastData->dataLen]), validLe in AssembleTLV()
217 AssembleTLV(BroadcastData *broadcastData, uint8_t dataType, const void *value, uint32_t dataLen) AssembleTLV() argument
341 ParseRecvTlvs(DeviceWrapper *device, const uint8_t *data, uint32_t dataLen) ParseRecvTlvs() argument
391 GetDeviceInfoFromDisAdvData(DeviceWrapper *device, const uint8_t *data, uint32_t dataLen) GetDeviceInfoFromDisAdvData() argument
[all...]
/foundation/communication/dsoftbus/adapter/common/net/bluetooth/include/
H A Dsoftbus_adapter_ble_conflict.h28 bool (*postBytes)(int32_t underlayerHandle, uint8_t *data, uint32_t dataLen);
37 void (*conflictNotifyDataReceive)(int32_t underlayerHandle, const uint8_t *data, uint32_t dataLen);
43 void SoftbusBleConflictNotifyDateReceive(int32_t underlayerHandle, const uint8_t *data, uint32_t dataLen);
48 bool LegacyConflictPostBytes(uint32_t connectionId, uint8_t *data, uint32_t dataLen);
/foundation/communication/dsoftbus/tests/sdk/bus_center/unittest/
H A Dbus_center_sdk_publish_test.cpp72 .dataLen = sizeof("capdata2"),
83 .dataLen = sizeof("capdata4"),
115 .dataLen = sizeof("capdata1"), in HWTEST_F()
138 testInfo.dataLen = MAX_CAPABILITYDATA_LEN + 1; in HWTEST_F()
161 .dataLen = sizeof("capdata1"), in HWTEST_F()
210 .dataLen = sizeof("capdata1"), in HWTEST_F()
266 .dataLen = sizeof("capdata1"), in HWTEST_F()
272 testInfo.dataLen = sizeof("capdata1"); in HWTEST_F()
278 testInfo.dataLen = sizeof("capdata1"); in HWTEST_F()
285 testInfo.dataLen in HWTEST_F()
[all...]
/foundation/multimedia/av_codec/test/moduletest/muxer/InnerAPI/
H A DInnerAVMuxerFuzzTest.cpp126 int dataLen = rand() % 65536; in HWTEST_F() local
127 vector<uint8_t> data(dataLen); in HWTEST_F()
137 cout << "OH_AV_KEY_BIT_RATE is: " << bitRate << ", OH_AV_KEY_CODEC_CONFIG len is: " << dataLen << endl; in HWTEST_F()
198 int dataLen = rand() % 65536; in HWTEST_F() local
199 uint8_t data[dataLen]; in HWTEST_F()
200 cout << "data len is:" << dataLen << endl; in HWTEST_F()
206 cout << "size is:" << dataLen << endl; in HWTEST_F()
209 std::shared_ptr<AVBuffer> avMemBuffer = AVBuffer::CreateAVBuffer(alloc, dataLen); in HWTEST_F()
210 avMemBuffer->memory_->Write(data, dataLen); in HWTEST_F()
264 int dataLen in HwTest_AddTrack() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_proxy_manager.c57 int32_t dataLen; member
88 data->dataLen = (int32_t)SoftBusHtoLl((uint32_t)data->dataLen); in ClientPackPacketHead()
96 data->dataLen = (int32_t)SoftBusLtoHl((uint32_t)data->dataLen); in ClientUnPackPacketHead()
378 int32_t ClientTransProxySessionDataLenCheck(uint32_t dataLen, SessionPktType type) in ClientTransProxySessionDataLenCheck() argument
383 if (dataLen > g_proxyMaxMessageBufSize) { in ClientTransProxySessionDataLenCheck()
389 if (dataLen > g_proxyMaxByteBufSize) { in ClientTransProxySessionDataLenCheck()
526 if (dataHead->dataLen <= OVERHEAD_LEN) { in ClientTransProxyProcessSessionData()
527 TRANS_LOGE(TRANS_SDK, "invalid data head dataLen in ClientTransProxyProcessSessionData()
846 uint32_t dataLen = len - sizeof(SliceHead); ClientTransProxySliceProc() local
987 uint32_t dataLen = (i == (sliceNum - 1U)) ? (dataInfo.outLen - i * SLICE_LEN) : SLICE_LEN; TransProxyPackAndSendData() local
[all...]
H A Dclient_trans_proxy_file_helper.c86 uint64_t dataLen = SoftBusLtoHll(*(uint64_t *)(data + FRAME_MAGIC_OFFSET)); in UnpackFileTransResultFrame() local
87 if (magic != FILE_MAGIC_NUMBER || dataLen != (FRAME_DATA_SEQ_OFFSET + sizeof(uint32_t) + sizeof(int32_t))) { in UnpackFileTransResultFrame()
89 TRANS_FILE, "recv ack response head fail. magic=%{public}u, dataLen=%{public}" PRIu64, magic, dataLen); in UnpackFileTransResultFrame()
130 uint64_t dataLen = SoftBusLtoHll((*(uint64_t *)(frame->data + FRAME_MAGIC_OFFSET))); in UnpackAckReqAndResData() local
131 if (frame->magic != FILE_MAGIC_NUMBER || dataLen < FRAME_DATA_SEQ_OFFSET + FRAME_DATA_SEQ_OFFSET) { in UnpackAckReqAndResData()
133 TRANS_FILE, "unpack ack head fail. magic=%{public}u, dataLen=%{public}" PRIu64, frame->magic, dataLen); in UnpackAckReqAndResData()
154 uint64_t dataLen = (uint64_t)len + FRAME_DATA_SEQ_OFFSET; in PackReadFileData() local
155 fileFrame->frameLength = FRAME_HEAD_LEN + dataLen in PackReadFileData()
195 uint64_t dataLen = (uint64_t)len + FRAME_DATA_SEQ_OFFSET; PackReadFileRetransData() local
228 uint64_t dataLen = SoftBusLtoHll((*(uint64_t *)(fileFrame->data + FRAME_MAGIC_OFFSET))); UnpackFileDataFrame() local
[all...]
/foundation/multimedia/av_codec/test/nativedemo/avdemuxer/capi_demo/
H A Davdemuxer_demo.cpp157 printf("OnDrmInfoChangedInApp print pssh length %d \n", drmInfo->psshInfo[i].dataLen); in OnDrmInfoChangedInApp()
158 if (drmInfo->psshInfo[i].dataLen > MAX_PSSH_DATA_LEN) { in OnDrmInfoChangedInApp()
162 for (uint32_t k = 0; k < drmInfo->psshInfo[i].dataLen; k++) { in OnDrmInfoChangedInApp()
184 printf("OnDrmInfoChangedWithObjInApp print pssh length %d \n", drmInfo->psshInfo[i].dataLen); in OnDrmInfoChangedWithObjInApp()
185 if (drmInfo->psshInfo[i].dataLen > MAX_PSSH_DATA_LEN) { in OnDrmInfoChangedWithObjInApp()
189 for (uint32_t k = 0; k < drmInfo->psshInfo[i].dataLen; k++) { in OnDrmInfoChangedWithObjInApp()
219 printf("GetMediaKeySystemInfo print pssh length %d \n", mediaKeySystemInfo.psshInfo[i].dataLen); in GetMediaKeySystemInfo()
220 for (uint32_t k = 0; k < mediaKeySystemInfo.psshInfo[i].dataLen; k++) { in GetMediaKeySystemInfo()
/foundation/distributedhardware/device_manager/services/implementation/src/dependency/softbus/
H A Dsoftbus_session.cpp38 static void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes() argument
41 SoftbusSession::OnBytesReceived(socket, data, dataLen); in OnBytes()
181 void SoftbusSession::OnBytesReceived(int sessionId, const void *data, unsigned int dataLen) in OnBytesReceived() argument
183 if (sessionId < 0 || data == nullptr || dataLen <= 0 || dataLen > MAX_DATA_LEN) { in OnBytesReceived()
184 LOGI("[SOFTBUS]fail to receive data from softbus with sessionId: %{public}d, dataLen: %{public}d.", sessionId, in OnBytesReceived()
185 dataLen); in OnBytesReceived()
188 LOGI("start, sessionId: %{public}d, dataLen: %{public}d.", sessionId, dataLen); in OnBytesReceived()
192 std::string message = std::string(reinterpret_cast<const char *>(data), dataLen); in OnBytesReceived()
[all...]

Completed in 12 milliseconds

12345678910>>...18