Home
last modified time | relevance | path

Searched refs:stream_ (Results 1 - 25 of 36) sorted by relevance

12

/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/
H A Drs_profiler_json.h29 stream_ << "{"; in PushObject()
35 stream_.seekg(-1, std::ios::end); in PopObject()
36 stream_ >> last; in PopObject()
38 stream_.seekp(-1, std::ios::end); in PopObject()
40 stream_ << "},"; in PopObject()
45 stream_ << "["; in PushArray()
51 stream_.seekg(-1, std::ios::end); in PopArray()
52 stream_ >> last; in PopArray()
54 stream_.seekp(-1, std::ios::end); in PopArray()
56 stream_ << "],"; in PopArray()
128 std::stringstream stream_; global() member in OHOS::Rosen::JsonWriter
[all...]
H A Drs_profiler_archive.h191 : Archive(Reader), stream_(const_cast<std::stringstream&>(stream)) in StringStreamArchive()
197 stream_.read(reinterpret_cast<char*>(data), size);
202 stream_.write(reinterpret_cast<const char*>(data), size);
206 std::stringstream& stream_; member in OHOS::Rosen::final
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/
H A Dext_wstream.cpp31 ExtWStream::ExtWStream(OutputDataStream *stream) : stream_(stream) in ExtWStream()
37 if (stream_ == nullptr) { in write()
41 return stream_->Write(static_cast<const uint8_t*>(buffer), size); in write()
46 if (stream_ == nullptr) { in flush()
50 stream_->Flush(); in flush()
55 if (stream_ == nullptr) { in bytesWritten()
60 stream_->GetCurrentSize(written); in bytesWritten()
67 if (stream_->Write(bytePtr, size) !=0) { in write()
75 return stream_->GetSize(); in bytesWritten()
80 return stream_ in GetAddr()
[all...]
H A Dext_stream.cpp36 ExtStream::ExtStream(InputDataStream *stream) : stream_(stream) in ExtStream()
63 if (stream_ == nullptr) { in read()
67 return Skip(stream_, size); in read()
73 if (stream_->GetStreamSize() != SIZE_ZERO && stream_->GetStreamSize() < desiredSize) { in read()
74 desiredSize = stream_->GetStreamSize(); in read()
76 if (!stream_->Read(desiredSize, buf.buf, buf.size, buf.resSize)) { in read()
85 if (stream_ == nullptr) { in peek()
94 if (!stream_->Peek(buf.size, buf.buf, buf.size, buf.resSize)) { in peek()
103 if (stream_ in isAtEnd()
[all...]
H A Dext_decoder.cpp370 stream_ = &sourceStream; in HeapMemAlloc()
379 stream_ = nullptr; in HeapMemAlloc()
783 if (stream_ == nullptr) { in HeapMemAlloc()
791 uint32_t jpegBufferSize = stream_->GetStreamSize(); in HeapMemAlloc()
805 stream_->Seek(streamOff_); in HeapMemAlloc()
935 if (stream_ == nullptr) { in HeapMemAlloc()
942 uint32_t savedPosition = stream_->Tell(); in HeapMemAlloc()
943 if (!stream_->Seek(0)) { in HeapMemAlloc()
948 bool result = stream_->Read(jpegBufferSize, jpegBuffer, jpegBufferSize, readSize); in HeapMemAlloc()
949 if (!stream_ in HeapMemAlloc()
[all...]
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/include/
H A Dext_wstream.h34 stream_ = nullptr;
40 ImagePlugin::OutputDataStream *stream_; member in OHOS::ImagePlugin::ExtWStream
45 MetadataWStream() {stream_ = new Media::BufferMetadataStream();}; in MetadataWStream()
48 delete stream_;
49 stream_ = nullptr;
56 Media::BufferMetadataStream *stream_; member in OHOS::ImagePlugin::MetadataWStream
H A Dext_stream.h33 stream_ = nullptr;
41 ImagePlugin::InputDataStream *stream_; member in OHOS::ImagePlugin::ExtStream
/foundation/ai/neural_network_runtime/example/deep_learning_framework/tflite/tools/
H A Dlog.h25 std::stringstream stream_; member in tflite::label_classify::Log
30 stream_ << severity << ": "; in Log()
34 return stream_; in Stream()
38 std::cerr << stream_.str() << std::endl; in ~Log()
/foundation/multimedia/audio_framework/services/audio_service/server/src/
H A Dcapturer_in_server.cpp61 stream_->GetSpanSizePerFrame(spanSizeInFrame_); in ConfigServerBuffer()
65 stream_->GetByteSizePerFrame(byteSizePerFrame_); in ConfigServerBuffer()
125 int32_t ret = IStreamManager::GetRecorderManager().CreateCapturer(processConfig_, stream_); in Init()
126 CHECK_AND_RETURN_RET_LOG(ret == SUCCESS && stream_ != nullptr, ERR_OPERATION_FAILED, in Init()
128 streamIndex_ = stream_->GetStreamIndex(); in Init()
131 stream_->RegisterStatusCallback(shared_from_this()); in Init()
132 stream_->RegisterReadCallback(shared_from_this()); in Init()
192 return stream_->DequeueBuffer(length); in DequeueBuffer()
205 BufferDesc dstBuffer = stream_->DequeueBuffer(length); in IsReadDataOverFlow()
206 stream_ in IsReadDataOverFlow()
[all...]
H A Drenderer_in_server.cpp81 stream_->GetSpanSizePerFrame(spanSizeInFrame_); in ConfigServerBuffer()
83 stream_->GetByteSizePerFrame(byteSizePerFrame_); in ConfigServerBuffer()
157 int32_t ret = IStreamManager::GetPlaybackManager(managerType_).CreateRender(processConfig_, stream_); in Init()
161 ret = IStreamManager::GetPlaybackManager(managerType_).CreateRender(processConfig_, stream_); in Init()
164 CHECK_AND_RETURN_RET_LOG(ret == SUCCESS && stream_ != nullptr, ERR_OPERATION_FAILED, in Init()
166 streamIndex_ = stream_->GetStreamIndex(); in Init()
173 stream_->RegisterStatusCallback(shared_from_this()); in Init()
174 stream_->RegisterWriteCallback(shared_from_this()); in Init()
318 stream_->Pause(true); in StandByCheck()
359 return stream_ in DequeueBuffer()
[all...]
H A Dnone_mix_engine.cpp48 stream_(nullptr), in NoneMixEngine()
250 if (stream_ == nullptr) { in MixStreams()
260 int32_t appUid = stream_->GetAudioProcessConfig().appInfo.appUid; in MixStreams()
262 int32_t result = stream_->Peek(&audioBuffer, index); in MixStreams()
266 stream_->ReturnIndex(index); in MixStreams()
281 stream_->BlockStream(); in MixStreams()
287 stream_->ReturnIndex(index); in MixStreams()
295 if (!stream_) { in AddRenderer()
299 stream_ = stream; in AddRenderer()
303 } else if (stream->GetStreamIndex() != stream_ in AddRenderer()
[all...]
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/test/unittest/plugin_test/
H A Dext_decoder_test.cpp81 extDecoder->stream_ = new MockInputDataStream; in HWTEST_F()
329 ASSERT_NE(extDecoder->stream_, nullptr); in HWTEST_F()
330 extDecoder->codec_ = SkCodec::MakeFromStream(std::make_unique<ExtStream>(extDecoder->stream_)); in HWTEST_F()
633 ASSERT_NE(extDecoder->stream_, nullptr); in HWTEST_F()
634 extDecoder->codec_ = SkCodec::MakeFromStream(std::make_unique<ExtStream>(extDecoder->stream_)); in HWTEST_F()
709 extWStream.stream_ = nullptr; in HWTEST_F()
711 ASSERT_EQ(extWStream.stream_, nullptr); in HWTEST_F()
713 extWStream.stream_ = new MockOutputDataStream; in HWTEST_F()
715 ASSERT_NE(extWStream.stream_, nullptr); in HWTEST_F()
717 delete extWStream.stream_; in HWTEST_F()
[all...]
/foundation/multimedia/image_framework/plugins/common/libs/image/libwebpplugin/src/
H A Dwebp_decoder.cpp56 stream_ = &sourceStream; in SetSource()
198 size_t stremSize = stream_->GetStreamSize(); in ReadIncrementalHead()
199 if (stremSize >= DECODE_VP8CHUNK_MIN_SIZE || stream_->IsStreamCompleted()) { in ReadIncrementalHead()
200 stream_->Seek(0); in ReadIncrementalHead()
201 if (!stream_->Read(stream_->GetStreamSize(), dataBuffer_)) { in ReadIncrementalHead()
235 size_t streamSize = stream_->GetStreamSize(); in IsDataEnough()
236 if (incrementSize_ < DECODE_VP8CHUNK_MIN_SIZE && !stream_->IsStreamCompleted()) { in IsDataEnough()
330 stream_->Seek(0); in DoIncrementalDecode()
331 if (!stream_ in DoIncrementalDecode()
[all...]
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/stream_source/
H A Dstream_source_plugin.cpp111 stream_ = source->GetDataConsumer(); in SetSource()
112 FALSE_RETURN_V(stream_ != nullptr, Status::ERROR_INVALID_PARAMETER); in SetSource()
120 auto deleter = [this](uint8_t* ptr) { FALSE_LOG(stream_->QueueEmptyBuffer(ptr)); }; in WrapDataBuffer()
136 FALSE_RETURN_V(stream_->GetDataBuffer(dataBuffer), Status::ERROR_TIMED_OUT); in Read()
H A Dstream_source_plugin.h52 std::shared_ptr<DataConsumer> stream_ {nullptr};
/foundation/multimedia/camera_framework/frameworks/native/camera/src/output/
H A Dcapture_output.cpp31 : outputType_(outputType), streamType_(streamType), stream_(stream), bufferProducer_(bufferProducer) in CaptureOutput()
102 return stream_ != nullptr; in IsStreamCreated()
108 return stream_; in GetStream()
115 stream_ = stream; in SetStream()
137 stream_ = nullptr; in Release()
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/source/
H A Dplayer_demux.cpp54 stream_.handle = nullptr; in PlayerDemuxer()
55 stream_.ReadData = nullptr; in PlayerDemuxer()
56 stream_.GetReadableSize = nullptr; in PlayerDemuxer()
104 source.stream = &stream_; in GetFormatDemuxer()
135 stream_ = stream; in SetSource()
/foundation/multimedia/media_lite/services/player_lite/server/src/
H A Dplayer_server.cpp296 stream_ = std::make_shared<ServerStreamSource>(); in SetStreamSource()
299 Source streamSource(stream_, formats); in SetStreamSource()
315 stream_->SetSurface(surface); in SetStreamSource()
322 ServerStreamSource* serverStream = reinterpret_cast<ServerStreamSource*>(stream_.get()); in SetStreamSource()
325 pthread_create(&g_streamThreadControl.process, &attr, streamProcess, stream_.get()); in SetStreamSource()
415 if (stream_.get() != nullptr) { in Stop()
416 ServerStreamSource* serverStream = reinterpret_cast<ServerStreamSource*>(stream_.get()); in Stop()
563 if (stream_ != nullptr) { in Release()
564 ServerStreamSource* serverStream = reinterpret_cast<ServerStreamSource*>(stream_.get()); in Release()
570 stream_ in Release()
[all...]
/foundation/multimedia/media_utils_lite/src/
H A Dsource.cpp34 stream_(stream) in Source()
62 return stream_; in GetSourceStream()
/foundation/multimedia/media_lite/services/player_lite/server/include/
H A Dplayer_server.h49 std::shared_ptr<StreamSource> stream_; member in OHOS::Media::PlayerServer
53 PlayerServer() : player_(nullptr), stream_(nullptr), sid_(nullptr) {} in PlayerServer()
/foundation/multimedia/av_codec/services/media_engine/modules/demuxer/
H A Ddemuxer_plugin_manager.cpp48 : stream_(stream), in DataSourceImpl()
55 if (stream_->seekable_ == Plugins::Seekable::SEEKABLE) { in IsOffsetValid()
56 return stream_->mediaDataSize_ == 0 || offset <= static_cast<int64_t>(stream_->mediaDataSize_); in IsOffsetValid()
82 return stream_->CallbackReadAt(streamID_, offset, buffer, expectedLen); in ReadAt()
87 size = stream_->mediaDataSize_; in GetSize()
93 return stream_->seekable_; in GetSeekable()
/foundation/multimedia/image_framework/plugins/common/libs/image/libbmpplugin/src/
H A Dbmp_decoder.cpp43 stream_ = &sourceStream; in SetSource()
49 if (stream_ != nullptr) { in Reset()
50 stream_->Seek(0); in Reset()
337 codec_ = SkCodec::MakeFromStream(make_unique<BmpStream>(stream_)); in DecodeHeader()
/foundation/multimedia/audio_framework/services/audio_service/server/include/
H A Dnone_mix_engine.h63 std::shared_ptr<IRendererStream> stream_; member in OHOS::AudioStandard::NoneMixEngine
/foundation/multimedia/image_framework/plugins/common/libs/image/libbmpplugin/include/
H A Dbmp_decoder.h63 InputDataStream *stream_ = nullptr; member in OHOS::ImagePlugin::BmpDecodingState::BmpDecoder
/foundation/multimedia/image_framework/plugins/common/libs/image/libwebpplugin/include/
H A Dwebp_decoder.h71 InputDataStream *stream_ = nullptr; member in OHOS::ImagePlugin::WebpDecodingState::WebpDecoder

Completed in 14 milliseconds

12