| /ohos5.0/foundation/multimedia/audio_framework/services/audio_policy/server/src/service/effect/ |
| H A D | audio_effect_manager.cpp | 135 if (pp.stream == stream) { in UpdateAvailableStreamPre()
144 Stream stream; in UpdateAvailableStreamPre() local
146 stream.scene = pp.stream; in UpdateAvailableStreamPre()
151 preProcessNew.stream.push_back(stream); in UpdateAvailableStreamPre()
163 if (ess.stream == stream) { in UpdateAvailableStreamPost()
174 stream.scene = ess.stream; in UpdateAvailableStreamPost()
179 postProcessNew.stream.push_back(stream); in UpdateAvailableStreamPost()
290 for (auto &stream: processNew.stream) { in UpdateDuplicateBypassMode() local
314 for (auto &stream: processNew.stream) { in UpdateDuplicateMode() local
356 for (auto &stream: processNew.stream) { in UpdateDuplicateDevice() local
[all …]
|
| /ohos5.0/foundation/multimedia/image_framework/frameworks/innerkitsimpl/test/unittest/image_source_test/ |
| H A D | metadata_stream_test.cpp | 315 stream.Flush();
463 stream.Flush();
982 EXPECT_EQ(stream.Seek(0, SeekPos::END), stream.GetSize());
1167 delete stream;
1170 delete stream;
1184 stream->GetAddr();
1186 delete stream;
1329 stream.Open();
1399 stream.Read(buf, 13);
1464 stream.Close();
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | tcp_test.rs | 36 while stream.is_err() { in sdv_tcp_ipv6_connect()
39 let mut stream = stream.unwrap(); in sdv_tcp_ipv6_connect() localVariable
87 while stream.is_err() { in sdv_tcp_stream_try()
90 let stream = stream.unwrap(); in sdv_tcp_stream_try() localVariable
122 while stream.is_err() { in sdv_tcp_stream_basic()
125 let stream = stream.unwrap(); in sdv_tcp_stream_basic() localVariable
137 stream in sdv_tcp_stream_basic()
172 let stream = stream.unwrap(); in sdv_tcp_stream_peek() localVariable
300 let mut stream = stream.unwrap(); in sdv_tcp_split_borrow_half() localVariable
370 let stream = stream.unwrap(); in sdv_tcp_split_owned_half() localVariable
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 98 Self::connect_inner(stream).await in connect()
102 let stream = TcpStream::new(stream)?; in connect_inner() localVariable
103 stream in connect_inner()
115 Ok(stream) in connect_inner()
690 while stream.is_err() { in ut_tcp_stream_basic()
693 let stream = stream.unwrap(); in ut_tcp_stream_basic() localVariable
699 stream.set_ttl(101).unwrap(); in ut_tcp_stream_basic()
730 while stream.is_err() { in ut_tcp_stream_peek()
733 let stream = stream.unwrap(); in ut_tcp_stream_peek() localVariable
763 while stream.is_err() { in ut_tcp_stream_try()
[all …]
|
| H A D | split.rs | 140 while stream.is_err() { in ut_test_borrow_half()
141 stream = TcpStream::connect(addr).await; in ut_test_borrow_half()
143 let mut stream = stream.unwrap(); in ut_test_borrow_half() localVariable
186 while stream.is_err() { in ut_test_owned_half()
187 stream = TcpStream::connect(addr).await; in ut_test_owned_half()
189 let stream = stream.unwrap(); in ut_test_owned_half() localVariable
233 while stream.is_err() { in ut_test_borrow_half_vector()
234 stream = TcpStream::connect(addr).await; in ut_test_borrow_half_vector()
236 let mut stream = stream.unwrap(); in ut_test_borrow_half_vector() localVariable
283 while stream.is_err() { in ut_test_owned_half_vector()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | streams.rs | 298 self.stream_map.get(&id).map(|stream| stream.state) in stream_state()
410 Some(stream) => match stream.state { in headers()
429 Some(stream) => match stream.state { in poll_read_body()
459 let stream = if let Some(stream) = self.stream_map.get_mut(&id) { in poll_sized_data() localVariable
460 stream in poll_sized_data()
547 Some(stream) => match stream.state { in send_local_reset()
572 Some(stream) => match &stream.state { in send_headers_frame()
615 Some(stream) => match &stream.state { in send_data_frame()
644 Some(stream) => match stream.state { in recv_remote_reset()
664 Some(stream) => match &stream.state { in recv_headers()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 33 let (mut stream, _) = loop { in sdv_tcp_server()
34 let stream = server.accept(); in sdv_tcp_server() localVariable
35 match stream { in sdv_tcp_server()
36 Ok(stream) => break stream, in sdv_tcp_server()
41 let mut ret = stream.write(b"hello"); in sdv_tcp_server()
76 Ok(stream) => break stream, in sdv_tcp_server()
103 let (mut stream, _) = loop { in sdv_tcp_server_vectored()
104 let stream = server.accept(); in sdv_tcp_server_vectored() localVariable
105 match stream { in sdv_tcp_server_vectored()
106 Ok(stream) => break stream, in sdv_tcp_server_vectored()
[all …]
|
| /ohos5.0/base/startup/init/services/param/linux/ |
| H A D | param_msgadp.c | 56 return LE_CreateStreamServer(LE_GetDefaultLoop(), stream, &info); in ParamServerCreate()
59 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server, in ParamStreamCreate() argument
81 void *ParamGetTaskUserData(const ParamTaskPtr stream) in ParamGetTaskUserData() argument
83 PARAM_CHECK(stream != NULL, return NULL, "Invalid stream"); in ParamGetTaskUserData()
84 return LE_GetUserData(stream); in ParamGetTaskUserData()
87 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg) in ParamTaskSendMsg() argument
90 PARAM_CHECK(stream != NULL, free((void *)msg); in ParamTaskSendMsg()
111 PARAM_CHECK(stream != NULL, return -1, "Invalid stream"); in ParamEventSend()
116 int ParamTaskClose(const ParamTaskPtr stream) in ParamTaskClose() argument
118 PARAM_CHECK(stream != NULL, return -1, "Invalid param"); in ParamTaskClose()
[all …]
|
| /ohos5.0/foundation/multimedia/image_framework/frameworks/innerkitsimpl/accessor/src/ |
| H A D | metadata_accessor_factory.cpp | 78 return Create(stream, error); in Create()
84 if (!stream->Open(OpenMode::ReadWrite)) { in Create()
88 return Create(stream, error); in Create()
95 if (!stream->Open(OpenMode::ReadWrite)) { in Create()
99 return Create(stream, error); in Create()
105 EncodedFormat type = GetImageType(stream, error); in Create()
111 return std::make_shared<PngExifMetadataAccessor>(stream); in Create()
127 stream->Seek(0, SeekPos::BEGIN); in GetImageType()
128 auto ret = stream->Read(buff, IMAGE_HEADER_SIZE * byteSize); in GetImageType()
129 stream->Seek(0, SeekPos::BEGIN); in GetImageType()
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/ |
| H A D | a2dp_state_machine.cpp | 55 avdtp.GetAllCapabilityReq(msgData.stream.addr, msgData.stream.acpSeid, label); in Dispatch()
58 avdtp.GetCapabilityReq(msgData.stream.addr, msgData.stream.acpSeid, label); in Dispatch()
73 ProcessDisconnectInd(msgData.stream.addr, msgData.stream.handle, role); in Dispatch()
76 ProcessDisconnectCfm(msgData.stream.addr, msgData.stream.handle, role); in Dispatch()
283 ProcessOpenReq(msgData.stream.addr, msgData.stream.handle, role); in Dispatch()
295 ProcessDisconnectInd(msgData.stream.addr, msgData.stream.handle, role); in Dispatch()
472 ProcessDisconnectInd(msgData.stream.addr, msgData.stream.handle, role); in Dispatch()
590 ProcessDisconnectInd(msgData.stream.addr, msgData.stream.handle, role); in Dispatch()
608 ProcessReconfigCfm(msgData.stream.addr, role, msgData.stream.handle); in Dispatch()
661 avdtp.CloseRsp(msgData.stream.handle, msgData.stream.label, 0); in ProcessCloseInd()
[all …]
|
| /ohos5.0/foundation/filemanagement/file_api/interfaces/kits/ts/streamrw/src/ |
| H A D | streamrw.ts | 17 const stream = requireNapi('util.stream');
30 class ReadStream extends stream.Readable {
37 private stream?: fileIo.Stream;
60 this.offset = this.stream?.seek(offset);
62 this.offset = this.stream?.seek(offset, whence);
68 this.stream?.close();
103 class WriteStream extends stream.Writable {
110 private stream?: fileIo.Stream;
133 this.offset = this.stream?.seek(offset);
141 this.stream?.close();
[all …]
|
| /ohos5.0/base/update/updater/test/fuzztest/fuzz_src_data/ |
| H A D | TestDecompressGzip.new.gz | ... = pkgStreams_.end()) {
67 PkgStreamPtr stream = (*iter1).second;
68 delete ... |
| /ohos5.0/base/update/updater/test/unittest/test_data/applypatch/ |
| H A D | TestDecompressGzip.new.gz | ... = pkgStreams_.end()) {
67 PkgStreamPtr stream = (*iter1).second;
68 delete ... |
| /ohos5.0/docs/en/application-dev/media/audio/ |
| H A D | using-right-streamusage-and-sourcetype.md | 7 …stream types and their use cases](#typical-audio-stream-types-and-use-cases) and [their effects on…
63 …igation stream starts playing, the Music stream that is playing will be ducked. After the Navigati…
65 - When a Movie stream starts playing, the Music stream that is playing will be stopped. When the Mo…
67 … When a VoiceCommunication stream starts, the Music stream that is playing will be paused. When th…
69 - The Music stream and Game stream can be mixed and played concurrently without affecting each othe…
71 - When a VoiceMessage stream starts, the Music stream that is playing will be paused. When the Voic…
75 The system selects an input/output device based on the audio stream type.
79 - For a MUSIC stream, the default output device is a speaker.
83 - For an Alarm stream, the default output device is a speaker. If a Bluetooth headset is connected …
91 Common methods for setting the audio playback stream type are as follows:
[all …]
|
| /ohos5.0/base/update/updater/services/package/pkg_manager/ |
| H A D | pkg_managerImpl.cpp | 94 delete stream; in ClearPkgFile()
95 stream = nullptr; in ClearPkgFile()
183 ClosePkgStream(stream); in CreatePackage()
254 if (stream == nullptr) { in ParsePackage()
514 stream = pkgStream; in CreatePkgStream()
527 stream = pkgStream; in CreatePkgStream()
552 stream = mapStream; in DoCreatePkgStream()
573 stream = nullptr; in DoCreatePkgStream()
617 if (stream == nullptr) { in DoCreatePkgStream()
641 stream = nullptr; in DoCreatePkgStream()
[all …]
|
| /ohos5.0/foundation/multimedia/av_codec/test/unittest/dash_test/ |
| H A D | dash_media_downloader_unit_test.cpp | 135 for (auto stream : streams) { variable
136 if (stream.type != VIDEO) {
166 for (auto stream : streams) { variable
167 if (stream.type != AUDIO) {
191 for (auto stream : streams) { variable
192 if (stream.type != VIDEO) {
234 for (auto stream : streams) { variable
235 if (stream.type != SUBTITLE) {
284 for (auto stream : streams) { variable
285 if (stream.type == AUDIO) {
[all …]
|
| /ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/test/unittest/common/distributedcameramgr/ |
| H A D | dcamera_provider_callback_impl_test.cpp | 377 DCStreamInfo stream; variable
378 stream.streamId_ = 1;
381 stream.stride_ = 1;
382 stream.format_ = 1;
391 stream.streamId_ = 1;
392 stream.height_ = -1;
395 stream.streamId_ = 1;
397 stream.width_ = -1;
406 stream.stride_ = -1;
409 stream.stride_ = 1;
[all …]
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/buffer_manager/src/ |
| H A D | buffer_loop_tracking.cpp | 286 if (stream != nullptr) { in AddTrackingStreamBegin()
293 if (stream == nullptr) { in AddTrackingStreamBegin()
320 if (stream == nullptr) { in AddTrackingStreamEnd()
323 stream->NodeAddComplete(); in AddTrackingStreamEnd()
348 if (stream == nullptr) { in AddTrackingNode()
403 if (stream == nullptr) { in HandleMessage()
408 if (!stream->IsNodeComplete()) { in HandleMessage()
452 if (stream == nullptr) { in IsEmpty()
463 if (stream == nullptr) { in IsEmpty()
485 if (stream == nullptr) { in DumpTrace()
[all …]
|
| /ohos5.0/foundation/multimedia/image_framework/frameworks/innerkitsimpl/test/fuzztest/imageaccessor_fuzzer/src/ |
| H A D | image_accessor_fuzzer.cpp | 53 std::shared_ptr<MetadataStream> stream = std::make_shared<FileMetadataStream>(fd); in JpegAccessorTest() local
54 if (!stream->Open(OpenMode::ReadWrite)) { in JpegAccessorTest()
59 if (EncodedFormat::JPEG != MetadataAccessorFactory::GetImageType(stream, errorCode)) { in JpegAccessorTest()
83 std::shared_ptr<MetadataStream> stream = std::make_shared<FileMetadataStream>(fd); in PngAccessorTest() local
84 if (!stream->Open(OpenMode::ReadWrite)) { in PngAccessorTest()
108 std::shared_ptr<MetadataStream> stream = std::make_shared<FileMetadataStream>(fd); in WebpAccessorTest() local
109 if (!stream->Open(OpenMode::ReadWrite)) { in WebpAccessorTest()
139 std::shared_ptr<MetadataStream> stream = std::make_shared<FileMetadataStream>(fd); in HeifAccessorTest() local
140 if (!stream->Open(OpenMode::ReadWrite)) { in HeifAccessorTest()
164 std::shared_ptr<MetadataStream> stream = std::make_shared<FileMetadataStream>(fd); in DngAccessorTest() local
[all …]
|
| /ohos5.0/foundation/multimedia/audio_framework/ |
| H A D | hisysevent.yaml | 19 STREAMID: {type: INT32, desc: stream id}
20 STREAMTYPE: {type: INT32, desc: stream type}
29 STREAMID: {type: INT32, desc: stream id}
32 STREAMTYPE: {type: INT32, desc: stream type}
35 VOLUMEFACTOR: {type: FLOAT, desc: stream volume factor}
41 STREAMID: {type: INT32, desc: stream id}
45 STREAMTYPE: {type: INT32, desc: stream type}
52 STREAMID: {type: INT32, desc: stream id}
105 DURATION: {type: UINT32, desc: duration of this stream}
113 SAMPLE_RATE: {type: UINT32, desc: sample rate of this stream}
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | listener.rs | 67 let (stream, addr) = self in accept()
72 let stream = UnixStream::new(stream)?; in accept() localVariable
73 Ok((stream, addr)) in accept()
183 let mut stream = UnixStream::connect(PATH).await; in ut_uds_listener_read_write_test() localVariable
184 while stream.is_err() { in ut_uds_listener_read_write_test()
185 stream = UnixStream::connect(PATH).await; in ut_uds_listener_read_write_test()
187 let mut stream = stream.unwrap(); in ut_uds_listener_read_write_test() localVariable
189 stream.read_exact(&mut read_buf).await.unwrap(); in ut_uds_listener_read_write_test()
197 let (mut stream, _) = listener.accept().await.unwrap(); in ut_uds_listener_read_write_test()
198 stream.write_all(client_msg.as_bytes()).await.unwrap(); in ut_uds_listener_read_write_test()
[all …]
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/ |
| H A D | capture_request.cpp | 42 auto stream = owner.lock(); in AddOwner() local
43 CHECK_IF_PTR_NULL_RETURN_VALUE(stream, RC_ERROR); in AddOwner()
46 owners_[stream->GetStreamId()] = stream; in AddOwner()
54 auto stream = owners_[id].lock(); in Process() local
55 CHECK_IF_PTR_NULL_RETURN_VALUE(stream, RC_ERROR); in Process()
58 return stream->Capture(shared_from_this()); in Process()
63 auto stream = owners_[id].lock(); in OnResult() local
67 return stream->OnFrame(shared_from_this()); in OnResult()
89 auto stream = it.second.lock(); in Cancel() local
90 if (stream == nullptr) { in Cancel()
[all …]
|
| /ohos5.0/docs/en/application-dev/media/avcodec/ |
| H A D | avcodec-support-formats.md | 78 … |<!--RP4-->Video stream: AVC (H.264); audio stream: AAC and MPEG (MP3); su…
79 | Audio/Video | fmp4 |<!--RP5-->Video stream: AVC (H.264); audio stream: A…
80 | Audio/Video | mkv |<!--RP6-->Video stream: AVC (H.264); audio stream: A…
81 | Audio/Video | mpeg-ts |<!--RP7-->Video stream: AVC (H.264); audio stream: A…
82 | Audio/Video | flv |<!--RP8-->Video stream: AVC (H.264); audio stream: A…
84 | Audio | aac |Audio stream: AAC|
85 | Audio | mp3 |Audio stream: MPEG (MP3)|
86 | Audio | ogg |Audio stream: OGG|
87 | Audio | flac |Audio stream: FLAC|
90 | Audio | ape |Audio stream: APE|
[all …]
|
| /ohos5.0/foundation/multimedia/drm_framework/services/utils/ |
| H A D | drm_api_operation.cpp | 128 while (std::getline(stream, line)) { in ParseReportConfig()
150 while (std::getline(stream, line)) { in ParseEvent()
166 … {"\"event1\": {", [&](std::istringstream &stream) { ParseEvent(stream, eventConfig.event1); }}, in ParseEventConfig()
167 … {"\"event2\": {", [&](std::istringstream &stream) { ParseEvent(stream, eventConfig.event2); }}, in ParseEventConfig()
168 … {"\"event3\": {", [&](std::istringstream &stream) { ParseEvent(stream, eventConfig.event3); }} in ParseEventConfig()
172 while (std::getline(stream, line)) { in ParseEventConfig()
179 it->second(stream); in ParseEventConfig()
188 …{"\"report_config\": {", [&](std::istringstream &stream) { ParseReportConfig(stream, reportConfig)… in ParseApiOperationManagement()
189 …{"\"event_config\": {", [&](std::istringstream &stream) { ParseEventConfig(stream, eventConfig); }} in ParseApiOperationManagement()
193 while (std::getline(stream, line)) { in ParseApiOperationManagement()
[all …]
|
| /ohos5.0/drivers/hdf_core/framework/model/camera/device_impl/src/ |
| H A D | camera_stream.c | 434 …ret = deviceDriver->stream[num]->streamOps->streamGetAbility(&capability, deviceDriver->stream[num… in CameraStreamGetAbility()
473 … isFailed |= !HdfSbufWriteString(rspData, rootConfig->deviceConfig[camId].stream.stream[num].name); in CameraStreamEnumDevice()
474 isFailed |= !HdfSbufWriteUint8(rspData, rootConfig->deviceConfig[camId].stream.stream[num].id); in CameraStreamEnumDevice()
475 …isFailed |= !HdfSbufWriteUint32(rspData, rootConfig->deviceConfig[camId].stream.stream[num].height… in CameraStreamEnumDevice()
476 …isFailed |= !HdfSbufWriteUint32(rspData, rootConfig->deviceConfig[camId].stream.stream[num].widthM… in CameraStreamEnumDevice()
477 …isFailed |= !HdfSbufWriteUint32(rspData, rootConfig->deviceConfig[camId].stream.stream[num].frameR… in CameraStreamEnumDevice()
478 …isFailed |= !HdfSbufWriteUint32(rspData, rootConfig->deviceConfig[camId].stream.stream[num].buffer… in CameraStreamEnumDevice()
479 …isFailed |= !HdfSbufWriteUint8(rspData, rootConfig->deviceConfig[camId].stream.stream[num].bufferC… in CameraStreamEnumDevice()
480 for (i = 0; i <= rootConfig->deviceConfig[camId].stream.stream[num].bufferTypeNum; i++) { in CameraStreamEnumDevice()
481 …isFailed |= !HdfSbufWriteUint32(rspData, rootConfig->deviceConfig[camId].stream.stream[num].buffer… in CameraStreamEnumDevice()
[all …]
|