Home
last modified time | relevance | path

Searched refs:streamData (Results 1 - 22 of 22) sorted by relevance

/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/
H A Dstream_adaptor_test.cpp93 StreamData streamData = { in HWTEST_F() local
99 ssize_t dataLen = streamData.bufLen + adaptor->GetEncryptOverhead(); 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()
117 StreamData streamData = { in HWTEST_F() local
123 ssize_t dataLen = streamData.bufLen + adaptor->GetEncryptOverhead(); in HWTEST_F()
125 int32_t ret = adaptor->Encrypt(streamData.buf, streamData in HWTEST_F()
[all...]
H A Dtrans_sdk_stream_test.cpp54 const StreamData streamData = {0}; in HWTEST_F() local
58 ret = SendStream(-1, &streamData, &ext, &param); in HWTEST_F()
64 ret = SendStream(sessionId, &streamData, NULL, &param); in HWTEST_F()
67 ret = SendStream(sessionId, &streamData, &ext, NULL); in HWTEST_F()
H A Dclient_trans_udp_stream_interface_test.cpp161 StreamData streamData = { in HWTEST_F() local
170 ret = SendVtpStream(channelId, &streamData, &extData, &frameInfo); in HWTEST_F()
183 StreamData streamData = { in HWTEST_F() local
190 ret = SendVtpStream(channelId, &streamData, NULL, &frameInfo); in HWTEST_F()
197 ret = SendVtpStream(channelId, &streamData, NULL, &frameInfo); in HWTEST_F()
204 ret = SendVtpStream(channelId, &streamData, NULL, &frameInfo); in HWTEST_F()
H A Dtrans_sdk_comm_stream_test.cpp53 const StreamData streamData = {0}; in HWTEST_F() local
57 int32_t ret = SendStream(-1, &streamData, &extData, &frameInfo); in HWTEST_F()
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/stream_common_data_test/
H A Dstream_common_data_test.cpp124 StreamData *streamData = (StreamData *)SoftBusCalloc(sizeof(StreamData)); in HWTEST_F() local
125 ASSERT_TRUE(streamData != nullptr); in HWTEST_F()
128 streamData->buffer = std::make_unique<char[]>(tmpLength); in HWTEST_F()
129 ASSERT_TRUE(std::move(streamData->buffer) != nullptr); in HWTEST_F()
131 ret = tmpStreamCommonData->InitStreamData(std::move(streamData->buffer), data->bufLen, nullptr, data->extLen); in HWTEST_F()
137 streamData->buffer = std::make_unique<char[]>(tmpLength); in HWTEST_F()
138 ASSERT_TRUE(std::move(streamData->buffer) != nullptr); in HWTEST_F()
140 ret = tmpStreamCommonData->InitStreamData(std::move(streamData->buffer), data->bufLen, std::move(data->buffer), in HWTEST_F()
147 SoftBusFree(streamData); in HWTEST_F()
/foundation/multimedia/image_framework/plugins/common/libs/image/libjpegplugin/src/
H A Djpeg_utils.cpp63 src->next_input_byte = src->streamData.inputStreamBuffer; in InitSrcStream()
86 if (!src->inputStream->Read(src->bufferSize, src->streamData)) { in FillInputBuffer()
90 if (!src->inputStream->IsStreamCompleted() && src->streamData.dataSize < JPEG_BUFFER_SIZE) { in FillInputBuffer()
92 src->inputStream->Seek(curr - src->streamData.dataSize); in FillInputBuffer()
94 curr - src->streamData.dataSize, src->streamData.dataSize); in FillInputBuffer()
97 src->next_input_byte = src->streamData.inputStreamBuffer; in FillInputBuffer()
98 src->bytes_in_buffer = src->streamData.dataSize; in FillInputBuffer()
128 src->next_input_byte = src->streamData.inputStreamBuffer; in SkipInputData()
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/sendstream_fuzzer/
H A Dsendstream_fuzzer.cpp28 StreamData streamData = {0}; in SendStreamTest() local
31 SendStream(size, &streamData, &ext, &param); in SendStreamTest()
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/distributed_stream/
H A Ddistributed_stream_test_agent.cpp41 void SetNumebrInStreamData(char *streamData, int32_t i) in SetNumebrInStreamData() argument
45 streamData[0] = len; in SetNumebrInStreamData()
46 (void)memcpy_s(streamData + 1, len, strI.c_str(), len); in SetNumebrInStreamData()
49 int32_t GetNumebrInStreamData(const char *streamData) in GetNumebrInStreamData() argument
51 char len = streamData[0]; in GetNumebrInStreamData()
52 string str(streamData + 1, len); in GetNumebrInStreamData()
H A Ddistributed_stream_test.cpp47 void SetNumebrInStreamData(char *streamData, int32_t i) in SetNumebrInStreamData() argument
51 streamData[0] = len; in SetNumebrInStreamData()
52 (void)memcpy_s(streamData + 1, len, strI.c_str(), len); in SetNumebrInStreamData()
55 int32_t GetNumebrInStreamData(const char *streamData) in GetNumebrInStreamData() argument
57 char len = streamData[0]; in GetNumebrInStreamData()
58 string str(streamData + 1, len); in GetNumebrInStreamData()
229 StreamData streamData = { in TestSendStream() local
244 int32_t ret = SendStream(session, &streamData, &extStreamData, &frame); in TestSendStream()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_control_center/test/fuzztest/onstreamreceived_fuzzer/
H A Donstreamreceived_fuzzer.cpp38 const StreamData streamData = { in OnStreamReceivedFuzzTest() local
51 SoftbusChannelAdapter::GetInstance().OnSoftbusStreamReceived(sessionId, &streamData, &extData, &frameInfo); in OnStreamReceivedFuzzTest()
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/monitor_permission_test/
H A Dcheckpermission_test.cpp130 const StreamData streamData = {0}; in HWTEST_F() local
134 int32_t ret = SendStream(g_sessionId, &streamData, &ext, &param); in HWTEST_F()
137 ret = SendStream(INVALID_SESSION_ID, &streamData, &ext, &param); in HWTEST_F()
/foundation/communication/dsoftbus/tests/sdk/transmission/demo/transport/
H A Dsendstream_demo.c87 const StreamData streamData = {0}; in main() local
91 ret = SendStream(sessionId, &streamData, &ext, &param); in main()
/foundation/distributedhardware/distributed_screen/services/softbusadapter/test/unittest/src/
H A Dsoftbus_adapter_test.cpp100 StreamData *streamData = nullptr; in HWTEST_F() local
104 softbusAdapter.OnStreamReceived(sessionId, streamData, ext, frameInfo); in HWTEST_F()
106 streamData = &sData; in HWTEST_F()
108 softbusAdapter.OnStreamReceived(sessionId, streamData, ext, frameInfo); in HWTEST_F()
112 softbusAdapter.OnStreamReceived(sessionId, streamData, ext, frameInfo); in HWTEST_F()
116 softbusAdapter.OnStreamReceived(sessionId, streamData, ext, frameInfo); in HWTEST_F()
/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screentranstestutils/src/
H A Dscreen_callback_test.cpp66 const StreamData *streamData = nullptr; in HWTEST_F() local
69 screenChannel->OnStreamReceived(sessionId, streamData, ext, param); in HWTEST_F()
158 const StreamData *streamData = nullptr; in HWTEST_F() local
161 screenChannel->OnStreamReceived(sessionId, streamData, ext, param); in HWTEST_F()
/foundation/multimedia/image_framework/plugins/common/libs/image/libjpegplugin/include/
H A Djpeg_utils.h54 ImagePlugin::DataStreamBuffer streamData; member
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/softbus/
H A Dsoftbus_wrapper.cpp141 StreamData streamData = { reinterpret_cast<char *>(const_cast<uint8_t *>(data)), len }; in SendSoftBusStream() local
143 return SendStream(softBusSessionId_, &streamData, &ext, &frameInfo); in SendSoftBusStream()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/softbus/
H A Dsoftbus_wrapper.cpp141 StreamData streamData = { reinterpret_cast<char *>(const_cast<uint8_t *>(data)), len }; in SendSoftBusStream() local
143 return SendStream(softBusSessionId_, &streamData, &ext, &frameInfo); in SendSoftBusStream()
/foundation/multimedia/audio_framework/services/audio_service/server/src/
H A Daudio_endpoint.cpp1532 AudioStreamData streamData; in GetAllReadyProcessData() local
1542 streamData.volumeStart = vol.isMute ? 0 : static_cast<int32_t>(curReadSpan->volumeStart * vol.volumeFloat); in GetAllReadyProcessData()
1544 streamData.volumeStart = curReadSpan->volumeStart; in GetAllReadyProcessData()
1546 streamData.volumeEnd = curReadSpan->volumeEnd; in GetAllReadyProcessData()
1547 streamData.streamInfo = processList_[i]->GetStreamInfo(); in GetAllReadyProcessData()
1548 streamData.isInnerCaped = processList_[i]->GetInnerCapState(); in GetAllReadyProcessData()
1551 processBufferList_[i]->GetReadbuffer(curRead, streamData.bufferDesc); // check return? in GetAllReadyProcessData()
1553 memset_s(static_cast<void *>(streamData.bufferDesc.buffer), streamData.bufferDesc.bufLength, in GetAllReadyProcessData()
1554 0, streamData in GetAllReadyProcessData()
[all...]
/foundation/multimedia/image_framework/plugins/common/libs/image/libpngplugin/src/
H A Dpng_decoder.cpp597 DataStreamBuffer streamData, size_t bufferSize, size_t totalSize) in ProcessData()
606 uint32_t ret = IncrementalRead(sourceStream, readSize, streamData); in ProcessData()
609 "dataSize:%{public}u, totalSize:%{public}zu.", readSize, bufferSize, streamData.dataSize, totalSize); in ProcessData()
612 png_process_data(pngStructPtr, infoStructPtr, const_cast<png_bytep>(streamData.inputStreamBuffer), in ProcessData()
613 streamData.dataSize); in ProcessData()
614 totalSize -= streamData.dataSize; in ProcessData()
596 ProcessData(png_structp pngStructPtr, png_infop infoStructPtr, InputDataStream *sourceStream, DataStreamBuffer streamData, size_t bufferSize, size_t totalSize) ProcessData() argument
/foundation/multimedia/image_framework/plugins/common/libs/image/libpngplugin/include/
H A Dpng_decoder.h88 DataStreamBuffer streamData, size_t bufferSize, size_t totalSize);
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/test/unittest/png_test/
H A Dpng_decoder_test.cpp696 DataStreamBuffer streamData; in HWTEST_F() local
697 uint32_t ret = pngDecoder->ProcessData(nullptr, infoStructPtr, mock.get(), streamData, 10, 20); in HWTEST_F()
717 DataStreamBuffer streamData; in HWTEST_F() local
718 streamData.dataSize = 4; in HWTEST_F()
719 const uint32_t ret = pngDecoder->ProcessData(pngStructPtr, infoStructPtr, mock.get(), streamData, 1, 20); in HWTEST_F()
/foundation/distributedhardware/distributed_camera/services/channel/src/
H A Ddcamera_softbus_adapter.cpp283 StreamData streamData = { reinterpret_cast<char *>(buffer->Data()), buffer->Size() }; in SendSofbusStream() local
315 int32_t ret = SendStream(socket, &streamData, &ext, &param); in SendSofbusStream()

Completed in 17 milliseconds