/third_party/skia/third_party/externals/oboe/samples/LiveEffect/src/main/cpp/ |
H A D | LiveEffectEngine.h | 65 void closeStream(std::shared_ptr<oboe::AudioStream> &stream); 73 void warnIfNotLowLatency(std::shared_ptr<oboe::AudioStream> &stream);
|
/third_party/skia/src/utils/win/ |
H A D | SkDWriteFontFileStream.h | 77 static HRESULT Create(SkStreamAsset* stream, 81 explicit SkDWriteFontFileStreamWrapper(SkStreamAsset* stream);
|
/third_party/skia/third_party/externals/freetype/src/cid/ |
H A D | cidparse.h | 44 * stream :: 45 * The current input stream. 71 FT_Stream stream; member 88 FT_Stream stream,
|
/third_party/skia/third_party/externals/dng_sdk/source/ |
H A D | dng_iptc.h | 156 void ParseString (dng_stream &stream, 160 void SpoolString (dng_stream &stream,
|
/third_party/python/Modules/cjkcodecs/ |
H A D | multibytecodec.h | 106 PyObject *stream; member 111 PyObject *stream; member
|
/foundation/multimedia/audio_framework/services/audio_service/server/src/ |
H A D | none_mix_engine.cpp | 292 int32_t NoneMixEngine::AddRenderer(const std::shared_ptr<IRendererStream> &stream) in AddRenderer() argument 296 AudioProcessConfig config = stream->GetAudioProcessConfig(); in AddRenderer() 299 stream_ = stream; in AddRenderer() 303 } else if (stream->GetStreamIndex() != stream_->GetStreamIndex()) { in AddRenderer() 309 void NoneMixEngine::RemoveRenderer(const std::shared_ptr<IRendererStream> &stream) in RemoveRenderer() argument 313 AUDIO_INFO_LOG("stream already removed."); in RemoveRenderer() 316 if (stream->GetStreamIndex() == stream_->GetStreamIndex()) { in RemoveRenderer()
|
/foundation/multimedia/camera_framework/services/camera_service/binder/client/src/ |
H A D | hcapture_session_proxy.cpp | 91 int32_t HCaptureSessionProxy::AddOutput(StreamType streamType, sptr<IStreamCommon> stream) in AddOutput() argument 97 if (stream == nullptr) { in AddOutput() 98 MEDIA_ERR_LOG("HCaptureSessionProxy AddOutput stream is null"); in AddOutput() 104 data.WriteRemoteObject(stream->AsObject()); in AddOutput() 138 int32_t HCaptureSessionProxy::RemoveOutput(StreamType streamType, sptr<IStreamCommon> stream) in RemoveOutput() argument 144 if (stream == nullptr) { in RemoveOutput() 145 MEDIA_ERR_LOG("HCaptureSessionProxy RemoveOutput stream is null"); in RemoveOutput() 151 data.WriteRemoteObject(stream->AsObject()); in RemoveOutput()
|
/foundation/multimedia/camera_framework/services/camera_service/include/ |
H A D | hcapture_session.h | 111 bool AddStream(sptr<HStreamCommon> stream); 112 bool RemoveStream(sptr<HStreamCommon> stream); 220 int32_t AddOutput(StreamType streamType, sptr<IStreamCommon> stream) override; 223 int32_t RemoveOutput(StreamType streamType, sptr<IStreamCommon> stream) override; 290 int32_t AddOutputStream(sptr<HStreamCommon> stream); 291 int32_t RemoveOutputStream(sptr<HStreamCommon> stream);
|
/kernel/linux/linux-5.10/sound/firewire/oxfw/ |
H A D | oxfw-pcm.c | 114 struct amdtp_stream *stream; in init_hw_params() local 117 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) { in init_hw_params() 119 stream = &oxfw->tx_stream; in init_hw_params() 123 stream = &oxfw->rx_stream; in init_hw_params() 141 err = amdtp_am824_add_pcm_hw_constraints(stream, runtime); in init_hw_params() 153 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in limit_to_current_params() 186 // When source of clock is not internal or any stream is reserved for in pcm_open()
|
/kernel/linux/linux-5.10/sound/soc/sof/intel/ |
H A D | hda.h | 175 * Timeout in us, for setting the stream RUN bit, during 176 * start/stop the stream. The timeout expires if new RUN bit 469 struct sof_intel_stream stream; member 546 struct hdac_ext_stream *stream, 549 int hda_dsp_iccmax_stream_hw_params(struct snd_sof_dev *sdev, struct hdac_ext_stream *stream, 553 struct hdac_ext_stream *stream, int cmd); 557 struct hdac_stream *stream); 565 struct hdac_ext_stream *stream,
|
/kernel/linux/linux-6.6/tools/net/ynl/lib/ |
H A D | nlspec.py | 369 with open(spec_path, "r") as stream: 371 first = stream.readline().strip() 376 stream.seek(0) 377 spec = yaml.safe_load(stream) 393 with open(schema_path, "r") as stream: 394 schema = yaml.safe_load(stream)
|
/kernel/linux/linux-6.6/sound/firewire/oxfw/ |
H A D | oxfw-pcm.c | 114 struct amdtp_stream *stream; in init_hw_params() local 117 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) { in init_hw_params() 119 stream = &oxfw->tx_stream; in init_hw_params() 123 stream = &oxfw->rx_stream; in init_hw_params() 141 err = amdtp_am824_add_pcm_hw_constraints(stream, runtime); in init_hw_params() 153 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in limit_to_current_params() 186 // When source of clock is not internal or any stream is reserved for in pcm_open()
|
/third_party/ffmpeg/libavformat/ |
H A D | rpl.c | 268 "Video stream will be broken!\n", av_fourcc2str(vst->codecpar->codec_tag)); in rpl_read_header() 318 AVStream* stream; in rpl_read_packet() local 328 stream = s->streams[rpl->chunk_part]; in rpl_read_packet() 329 sti = ffstream(stream); in rpl_read_packet() 341 if (stream->codecpar->codec_type == AVMEDIA_TYPE_VIDEO && in rpl_read_packet() 342 stream->codecpar->codec_tag == 124) { in rpl_read_packet() 374 if (stream->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) { in rpl_read_packet()
|
H A D | avformat.h | 97 * single elementary stream. In the lavf API this process is represented by the 169 * pts/dts, 0 for duration) if the stream does not provide them. The timing 199 * - Unless the format is of the AVFMT_NOSTREAMS type, at least one stream must 201 * the @ref AVStream.codecpar "stream codec parameters" information, such as the 204 * etc.) as known. The @ref AVStream.time_base "stream timebase" should 205 * be set to the timebase that the caller desires to use for this stream (note 213 * AVFormatContext.metadata "global" or @ref AVStream.metadata "per-stream" 373 * changes on a stream, you need to loop through all streams in the AVFormatContext 406 variant_bitrate -- the total bitrate of the bitrate variant that the current stream is part of 479 #define AVFMT_SHOW_IDS 0x0008 /**< Show format stream ID [all...] |
/third_party/mbedtls/scripts/mbedtls_dev/ |
H A D | c_wrapper_generator.py | 362 self.stream = 'stdout' 364 def set_stream(self, stream: str) -> None: 365 """Set the stdio stream to log to. 369 self.stream = stream 456 if ({stream}) {{ 457 mbedtls_fprintf({stream}, "{formats}\\n", 462 .format(stream=self.stream,
|
/third_party/node/src/ |
H A D | heap_utils.cc | 367 FileOutputStream stream(fd, &req); in WriteSnapshot() 368 TakeSnapshot(env, &stream); in WriteSnapshot() 369 if ((err = stream.status()) < 0) { in WriteSnapshot() 418 BaseObjectPtr<AsyncWrap> stream = in CreateHeapSnapshotStream() local 420 if (stream) in CreateHeapSnapshotStream() 421 args.GetReturnValue().Set(stream->object()); in CreateHeapSnapshotStream()
|
/third_party/lzma/C/ |
H A D | 7zTypes.h | 348 /* try to read as much as avail in stream and limited by (*processedSize) */
349 SRes SeqInStream_ReadMax(ISeqInStreamPtr stream, void *buf, size_t *processedSize);
351 // SRes SeqInStream_Read(ISeqInStreamPtr stream, void *buf, size_t size);
352 // SRes SeqInStream_Read2(ISeqInStreamPtr stream, void *buf, size_t size, SRes errorType);
353 SRes SeqInStream_ReadByte(ISeqInStreamPtr stream, Byte *buf);
400 SRes LookInStream_LookRead(ILookInStreamPtr stream, void *buf, size_t *size);
401 SRes LookInStream_SeekTo(ILookInStreamPtr stream, UInt64 offset);
404 SRes LookInStream_Read2(ILookInStreamPtr stream, void *buf, size_t size, SRes errorType);
405 SRes LookInStream_Read(ILookInStreamPtr stream, void *buf, size_t size);
|
/third_party/node/deps/v8/src/builtins/ |
H A D | builtins-string.cc | 265 StringCharacterStream stream(string); in ConvertCaseHelper() 268 base::uc32 current = stream.GetNext(); in ConvertCaseHelper() 271 bool has_next = stream.HasMore(); in ConvertCaseHelper() 272 base::uc32 next = has_next ? stream.GetNext() : 0; in ConvertCaseHelper() 304 while (stream.HasMore()) { in ConvertCaseHelper() 305 current = stream.GetNext(); in ConvertCaseHelper()
|
/third_party/mesa3d/src/gallium/tools/trace/ |
H A D | pytracediff.py | 111 def __init__(self, stream, options, state): 112 TraceParser.__init__(self, stream, options, state) 237 stream = io.TextIOWrapper(GzipFile(filename, "rb")) 240 stream = io.TextIOWrapper(BZ2File(filename, "rb")) 242 stream = open(filename, "rt") 247 parser = PKKTraceParser(stream, options, state)
|
H A D | parse.py | 431 stream = io.TextIOWrapper(GzipFile(fname, 'rb')) 434 stream = io.TextIOWrapper(BZ2File(fname, 'rb')) 436 stream = open(fname, 'rt') 441 self.process_arg(stream, options) 481 def process_arg(self, stream, options): 487 dump = TraceDumper(stream, options, formatter, TraceStateData())
|
/third_party/libphonenumber/migrator/src/test/java/com/google/phonenumbers/migrator/ |
H A D | MigrationJobTest.java | 38 import java.util.stream.Collectors; 163 assertThat(migratedNums.getValidMigrations().stream().map(MigrationResult::getMigratedNumber) in customRecipe_multipleMigration_expectMigration() 175 assertThat(report.getUntouchedEntries().stream().map(MigrationEntry::getOriginalNumber)) in standardMigration_invalidNumberNoRecipe_expectNoMigration() 187 assertThat(report.getValidUntouchedEntries().stream().map(MigrationEntry::getOriginalNumber)) in standardMigration_numberAlreadyValid_expectNoMigration() 198 assertThat(report.getValidMigrations().stream().map(res -> res.getMigrationEntry().getOriginalNumber())) in standardMigration_migratableNumber_expectMigration() 210 assertThat(report.getInvalidMigrations().stream() in standardMigration_invalidMigration_expectInvalidMigration()
|
/third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/jsonrpc2/ |
H A D | jsonrpc2.go | 33 stream Stream 71 // NewConn creates a new connection object around the supplied stream. 76 stream: s, 130 n, err := c.stream.Write(ctx, data) 176 n, err := c.stream.Write(ctx, data) 277 n, err := r.conn.stream.Write(ctx, data) 283 // TODO(iancottrell): if a stream write fails, we really need to shut down 284 // the whole stream 317 // It returns only when the reader is closed or there is an error in the stream. 326 data, n, err := c.stream [all...] |
/third_party/skia/src/codec/ |
H A D | SkBmpRLECodec.cpp | 21 std::unique_ptr<SkStream> stream, in SkBmpRLECodec() 25 : INHERITED(std::move(info), std::move(stream), bitsPerPixel, rowOrder) in SkBmpRLECodec() 79 // Read the color table from the stream in createColorTable() 82 if (stream()->read(cBuffer.get(), colorBytes) != colorBytes) { in createColorTable() 120 if (stream()->skip(fOffset - colorBytes) != fOffset - colorBytes) { in createColorTable() 130 fBytesBuffered = this->stream()->read(fStreamBuffer, kBufferSize); in initializeStreamBuffer() 140 * @return the number of bytes remaining in the stream buffer after 141 * attempting to read more bytes from the stream 156 // Try to read additional bytes from the stream. There are fCurrRLEByte in checkForMoreData() 159 size_t additionalBytes = this->stream() in checkForMoreData() 20 SkBmpRLECodec(SkEncodedInfo&& info, std::unique_ptr<SkStream> stream, uint16_t bitsPerPixel, uint32_t numColors, uint32_t bytesPerColor, uint32_t offset, SkCodec::SkScanlineOrder rowOrder) SkBmpRLECodec() argument [all...] |
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/ |
H A D | jsonrpc2.go | 33 stream Stream 71 // NewConn creates a new connection object around the supplied stream. 76 stream: s, 130 n, err := c.stream.Write(ctx, data) 176 n, err := c.stream.Write(ctx, data) 277 n, err := r.conn.stream.Write(ctx, data) 283 // TODO(iancottrell): if a stream write fails, we really need to shut down 284 // the whole stream 317 // It returns only when the reader is closed or there is an error in the stream. 326 data, n, err := c.stream [all...] |
/third_party/skia/tests/ |
H A D | MultiPictureDocumentTest.cpp | 85 // Create the stream we will serialize into. in DEF_TEST() 86 SkDynamicMemoryWStream stream; in DEF_TEST() local 95 sk_sp<SkDocument> multipic = SkMakeMultiPictureDocument(&stream, &procs); in DEF_TEST() 129 std::unique_ptr<SkStreamAsset> writtenStream = stream.detachAsStream(); in DEF_TEST() 319 // Create the stream we will serialize into. in DEF_GPUTEST_FOR_RENDERING_CONTEXTS() 320 SkDynamicMemoryWStream stream; in DEF_GPUTEST_FOR_RENDERING_CONTEXTS() local 330 sk_sp<SkDocument> multipic = SkMakeMultiPictureDocument(&stream, &procs, in DEF_GPUTEST_FOR_RENDERING_CONTEXTS() 364 std::unique_ptr<SkStreamAsset> writtenStream = stream.detachAsStream(); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
|