/third_party/python/Lib/test/libregrtest/ |
H A D | utils.py | 123 for stream in (sys.stdout, sys.stderr, sys.__stdout__, sys.__stderr__): 124 if stream is not None: 125 stream.flush()
|
/third_party/skia/tools/ |
H A D | dump_record.cpp | 151 std::unique_ptr<SkStream> stream = SkStream::MakeFromFile(FLAGS_skps[i]); in main() local 152 if (!stream) { in main() 156 sk_sp<SkPicture> src(SkPicture::MakeFromStream(stream.get())); in main()
|
/third_party/skia/gm/ |
H A D | yuv420_odd_dim.cpp | 39 SkDynamicMemoryWStream stream; in make_image() local 43 if (!SkJpegEncoder::Encode(&stream, bmp.pixmap(), options)) { in make_image() 46 auto imageHelper = sk_gpu_test::LazyYUVImage::Make(stream.detachAsData()); in make_image()
|
/third_party/skia/dm/ |
H A D | DMJsonWriter.cpp | 43 SkFILEWStream stream(path.c_str()); in DumpJson() 44 SkJSONWriter writer(&stream, SkJSONWriter::Mode::kPretty); in DumpJson() 99 stream.flush(); in DumpJson()
|
/device/soc/rockchip/common/vendor/drivers/media/platform/rockchip/isp/ |
H A D | procfs.c | 575 struct rkisp_stream *stream = &dev->cap_dev.stream[val]; in isp_show() local 577 if (!stream->streaming) { in isp_show() 581 stream->vnode.vdev.name, stream->out_fmt.pixelformat, stream->out_fmt.pixelformat >> 0x08, in isp_show() 582 stream->out_fmt.pixelformat >> 0x10, stream->out_fmt.pixelformat >> 0x18, stream->out_fmt.width, in isp_show() 583 stream in isp_show() [all...] |
/device/soc/rockchip/rk3588/kernel/drivers/media/platform/rockchip/isp/ |
H A D | procfs.c | 733 struct rkisp_stream *stream = &dev->cap_dev.stream[val]; in isp_show() local 735 if (!stream->streaming) in isp_show() 739 stream->vnode.vdev.name, in isp_show() 740 stream->out_fmt.pixelformat, in isp_show() 741 stream->out_fmt.pixelformat >> 8, in isp_show() 742 stream->out_fmt.pixelformat >> 16, in isp_show() 743 stream->out_fmt.pixelformat >> 24, in isp_show() 744 stream->out_fmt.width, in isp_show() 745 stream in isp_show() [all...] |
/kernel/linux/linux-5.10/include/sound/ |
H A D | pcm.h | 450 int stream; /* stream (direction) */ member 491 int stream; /* stream (direction) */ member 545 int snd_pcm_new_stream(struct snd_pcm *pcm, int stream, int substream_count); 579 int snd_pcm_open_substream(struct snd_pcm *pcm, int stream, struct file *file, 582 int snd_pcm_attach_substream(struct snd_pcm *pcm, int stream, struct file *file, 621 * snd_pcm_stream_lock_irqsave - Lock the PCM stream 625 * This locks the PCM stream like snd_pcm_stream_lock() but with the local 649 #define for_each_pcm_streams(stream) \ 1384 int stream; /* PLAYBACK or CAPTURE */ global() member [all...] |
/kernel/linux/linux-6.6/include/sound/ |
H A D | pcm.h | 347 snd_pcm_state_t state; /* stream state */ 348 snd_pcm_state_t suspended_state; /* suspended stream state */ 453 int stream; /* stream (direction) */ member 494 int stream; /* stream (direction) */ member 548 int snd_pcm_new_stream(struct snd_pcm *pcm, int stream, int substream_count); 582 int snd_pcm_open_substream(struct snd_pcm *pcm, int stream, struct file *file, 585 int snd_pcm_attach_substream(struct snd_pcm *pcm, int stream, struct file *file, 625 * snd_pcm_stream_lock_irqsave - Lock the PCM stream 1488 int stream; /* PLAYBACK or CAPTURE */ global() member [all...] |
/kernel/linux/linux-6.6/tools/testing/kunit/ |
H A D | kunit_tool_test.py | 132 self.assertContains('# Subtest: string-stream-test', result) 137 self.assertContains('ok 3 - string-stream-test', result) 355 stream = line_stream_from_strs(['hello', 'world']) 357 self.assertTrue(stream, msg='Should be more input') 358 self.assertEqual(stream.line_number(), 1) 359 self.assertEqual(stream.peek(), 'hello') 360 self.assertEqual(stream.pop(), 'hello') 362 self.assertTrue(stream, msg='Should be more input') 363 self.assertEqual(stream.line_number(), 2) 364 self.assertEqual(stream [all...] |
/kernel/linux/linux-6.6/sound/pci/hda/ |
H A D | hda_controller.c | 38 /* assign a stream for the PCM */ 50 /* release the assigned stream */ 60 return &apcm->info->stream[substream->stream]; in to_hda_pcm_stream() 77 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in azx_adjust_codec_delay() 188 /* CA-IBG chips need the playback stream starting from 1 */ in azx_pcm_prepare() 295 int stream = substream->stream; in azx_get_position() local 298 if (chip->get_position[stream]) in azx_get_position() 299 pos = chip->get_position[stream](chi in azx_get_position() [all...] |
/third_party/node/deps/undici/src/lib/fetch/ |
H A D | index.js | 58 const { Readable, pipeline } = require('stream') 61 const { TransformStream } = require('stream/web') 341 if (request.body != null && isReadable(request.body?.stream)) { 342 request.body.stream.cancel(error).catch((err) => { 361 if (response.body != null && isReadable(response.body?.stream)) { 362 response.body.stream.cancel(error).catch((err) => { 439 assert(!request.body || request.body.stream) 974 response.body = { stream: response.body.stream.pipeThrough(transformStream) } 1745 for await (const bytes of request.body.stream) { [all...] |
/device/soc/rockchip/common/vendor/drivers/media/platform/rockchip/cif/ |
H A D | dev.c | 48 /* show the compact mode of each stream in stream index order,
56 ret = snprintf(buf, PAGE_SIZE, "%d %d %d %d\n", cif_dev->stream[0].is_compact ? 1 : 0,
in rkcif_show_compact_mode() 57 cif_dev->stream[1].is_compact ? 1 : 0, cif_dev->stream[NUMBER_2].is_compact ? 1 : 0,
in rkcif_show_compact_mode() 58 cif_dev->stream[NUMBER_3].is_compact ? 1 : 0);
in rkcif_show_compact_mode() 86 cif_dev->stream[i].is_compact = false;
in rkcif_store_compact_mode() 88 cif_dev->stream[i].is_compact = true;
in rkcif_store_compact_mode() 159 /* show the memory mode of each stream in stream inde [all...] |
/device/soc/rockchip/rk3588/kernel/drivers/media/platform/rockchip/cif/ |
H A D | dev.c | 43 /* show the compact mode of each stream in stream index order, 54 cif_dev->stream[0].is_compact ? 1 : 0, in rkcif_show_compact_mode() 55 cif_dev->stream[1].is_compact ? 1 : 0, in rkcif_show_compact_mode() 56 cif_dev->stream[2].is_compact ? 1 : 0, in rkcif_show_compact_mode() 57 cif_dev->stream[3].is_compact ? 1 : 0); in rkcif_show_compact_mode() 86 cif_dev->stream[i].is_compact = false; in rkcif_store_compact_mode() 88 cif_dev->stream[i].is_compact = true; in rkcif_store_compact_mode() 170 /* show the memory mode of each stream in stream inde [all...] |
/third_party/skia/src/pdf/ |
H A D | SkPDFDevice.cpp | 261 SkDynamicMemoryWStream* stream() { return fContentStream; } in stream() function in ScopedContentEntry 445 SkDynamicMemoryWStream* contentStream = content.stream(); in drawPoints() 536 SkPDFGraphicState::kLuminosity_SMaskMode, fDocument), content.stream()); in internalDrawPathWithFilter() 537 SkPDFUtils::AppendRectangle(SkRect::Make(dstMaskBounds), content.stream()); in internalDrawPathWithFilter() 538 SkPDFUtils::PaintPath(SkPaint::kFill_Style, path.getFillType(), content.stream()); in internalDrawPathWithFilter() 539 this->clearMaskOnGraphicState(content.stream()); in internalDrawPathWithFilter() 623 SkPDFUtils::EmitPath(*pathPtr, paint->getStyle(), consumeDegeratePathSegments, content.stream(), in internalDrawPath() 625 SkPDFUtils::PaintPath(paint->getStyle(), pathPtr->getFillType(), content.stream()); in internalDrawPath() 863 SkDynamicMemoryWStream* out = content.stream(); in internalDrawGlyphRun() 1129 fDocument), content.stream()); in drawFormXObjectWithMask() [all...] |
/kernel/linux/linux-5.10/net/sctp/ |
H A D | ulpevent.c | 355 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_ulpevent_notify_peer_addr_change() 450 skb_pull(skb, sctp_datachk_len(&asoc->stream)); in sctp_ulpevent_make_send_failed() 451 len -= sctp_datachk_len(&asoc->stream); in sctp_ulpevent_make_send_failed() 547 len -= sctp_datachk_len(&asoc->stream); in sctp_ulpevent_make_send_failed_event() 549 skb_pull(skb, sctp_datachk_len(&asoc->stream)); in sctp_ulpevent_make_send_failed_event() 747 event->stream = ntohs(chunk->subh.data_hdr->stream); in sctp_ulpevent_make_rcvmsg() 996 sinfo.sinfo_stream = event->stream; in sctp_ulpevent_read_sndrcvinfo() 1024 rinfo.rcv_sid = event->stream; in sctp_ulpevent_read_rcvinfo() 1047 nxtinfo.nxt_sid = event->stream; in __sctp_ulpevent_read_nxtinfo() [all...] |
/kernel/linux/linux-5.10/sound/usb/usx2y/ |
H A D | usx2yhwdeppcm.c | 352 if (SNDRV_PCM_STREAM_PLAYBACK == substream->stream) { in snd_usx2y_usbpcm_hw_free() 394 stream = subs->pcm_substream->stream; in usx2y_usbpcm_urbs_start() local 397 if (SNDRV_PCM_STREAM_CAPTURE == stream) { in usx2y_usbpcm_urbs_start() 402 for (p = 0; 3 >= (stream + p); p += 2) { in usx2y_usbpcm_urbs_start() 403 struct snd_usx2y_substream *subs = usx2y->subs[stream + p]; in usx2y_usbpcm_urbs_start() 420 for (p = 0; 3 >= (stream + p); p += 2) { in usx2y_usbpcm_urbs_start() 421 struct snd_usx2y_substream *subs = usx2y->subs[stream + p]; in usx2y_usbpcm_urbs_start() 555 snd_pcm_substream_chip(substream))[substream->stream]; in snd_usx2y_usbpcm_open() 561 runtime->hw = SNDRV_PCM_STREAM_PLAYBACK == substream->stream in snd_usx2y_usbpcm_open() [all...] |
/kernel/linux/linux-6.6/net/sctp/ |
H A D | ulpevent.c | 355 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_ulpevent_notify_peer_addr_change() 450 skb_pull(skb, sctp_datachk_len(&asoc->stream)); in sctp_ulpevent_make_send_failed() 451 len -= sctp_datachk_len(&asoc->stream); in sctp_ulpevent_make_send_failed() 547 len -= sctp_datachk_len(&asoc->stream); in sctp_ulpevent_make_send_failed_event() 549 skb_pull(skb, sctp_datachk_len(&asoc->stream)); in sctp_ulpevent_make_send_failed_event() 747 event->stream = ntohs(chunk->subh.data_hdr->stream); in sctp_ulpevent_make_rcvmsg() 996 sinfo.sinfo_stream = event->stream; in sctp_ulpevent_read_sndrcvinfo() 1024 rinfo.rcv_sid = event->stream; in sctp_ulpevent_read_rcvinfo() 1047 nxtinfo.nxt_sid = event->stream; in __sctp_ulpevent_read_nxtinfo() [all...] |
/kernel/linux/linux-6.6/sound/usb/usx2y/ |
H A D | usx2yhwdeppcm.c | 371 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in snd_usx2y_usbpcm_hw_free() 412 int p, u, err, stream = subs->pcm_substream->stream; in usx2y_usbpcm_urbs_start() local 417 if (stream == SNDRV_PCM_STREAM_CAPTURE) { in usx2y_usbpcm_urbs_start() 422 for (p = 0; 3 >= (stream + p); p += 2) { in usx2y_usbpcm_urbs_start() 423 struct snd_usx2y_substream *subs = usx2y->subs[stream + p]; in usx2y_usbpcm_urbs_start() 442 for (p = 0; 3 >= (stream + p); p += 2) { in usx2y_usbpcm_urbs_start() 443 struct snd_usx2y_substream *subs = usx2y->subs[stream + p]; in usx2y_usbpcm_urbs_start() 589 snd_pcm_substream_chip(substream))[substream->stream]; in snd_usx2y_usbpcm_open() 595 if (substream->stream in snd_usx2y_usbpcm_open() [all...] |
/third_party/curl/tests/server/ |
H A D | tftpd.c | 1010 FILE *stream; in parse_servercmd() local 1013 stream = test2fopen(req->testno, logdir); in parse_servercmd() 1014 if(!stream) { in parse_servercmd() 1027 error = getpart(&orgcmd, &cmdsize, "reply", "servercmd", stream); in parse_servercmd() 1028 fclose(stream); in parse_servercmd() 1099 FILE *stream; in validate_access() local 1124 stream = test2fopen(testno, logdir); in validate_access() 1129 if(!stream) { in validate_access() 1137 int error = getpart(&test->buffer, &count, "reply", partbuf, stream); in validate_access() 1138 fclose(stream); in validate_access() [all...] |
/third_party/ffmpeg/libavformat/ |
H A D | oggdec.c | 69 struct ogg_stream *stream = &ogg->streams[i]; in free_stream() local 71 av_freep(&stream->buf); in free_stream() 72 if (stream->codec && in free_stream() 73 stream->codec->cleanup) { in free_stream() 74 stream->codec->cleanup(s, i); in free_stream() 77 av_freep(&stream->private); in free_stream() 78 av_freep(&stream->new_metadata); in free_stream() 131 struct ogg_stream *stream = &ogg->streams[i]; in ogg_restore() local 132 av_freep(&stream->buf); in ogg_restore() 133 av_freep(&stream in ogg_restore() [all...] |
/third_party/ffmpeg/tests/fate/ |
H A D | matroska.mak | 110 # (Btw: The keyframe flags of the input video stream seem wrong.) 119 # stream side-data; not setting any track to default if the user requested it; 123 fate-matroska-spherical-mono-remux: CMD = transcode matroska $(TARGET_SAMPLES)/mkv/spherical.mkv matroska "-map 0 -map 0 -c copy -disposition:0 -default+forced -disposition:1 -default -default_mode passthrough -color_primaries:1 bt709 -color_trc:1 smpte170m -colorspace:1 bt2020c -color_range:1 pc" "-map 0 -c copy -t 0" "-show_entries stream_side_data_list:stream_disposition=default,forced:stream=color_range,color_space,color_primaries,color_transfer" 135 fate-matroska-mastering-display-metadata: CMD = transcode mxf $(TARGET_SAMPLES)/mxf/Meridian-Apple_ProResProxy-HDR10.mxf matroska "-map 0 -map 0:0 -c:v:0 copy -c:v:1 ffv1 -c:a:0 copy -bsf:a:0 noise=amount=3 -filter:a:1 aresample -c:a:1 pcm_s16be -bsf:a:1 noise=amount=-1:drop=-4" "-map 0 -c copy" "-show_entries stream_side_data_list:stream=index,codec_name" 151 fate-matroska-h264-remux: CMD = transcode mpegts $(TARGET_SAMPLES)/h264/h264_intra_first-small.ts matroska "-map 0:0 -map 0 -c:v copy -sar:0 3:4 -bsf:v:1 h264_metadata=aud=remove:delete_filler=1 -disposition:v +hearing_impaired -af aresample -c:a:0 pcm_s32le -c:a:1 pcm_s32be -disposition:a:0 original -metadata:s:a:0 title=swedish_silence -metadata:s:a:1 title=norwegian_silence -disposition:a:1 dub" "-map 0:v" "-show_entries stream=index,codec_name:stream_tags=title,language" 161 # The audio stream to be remuxed here has AV_DISPOSITION_VISUAL_IMPAIRED. 164 fate-matroska-mpegts-remux: CMD = transcode mpegts $(TARGET_SAMPLES)/mpegts/pmtchange.ts matroska "-map 0:2 -map 0:2 -c copy -disposition:a:1 -visual_impaired+hearing_impaired -default_mode infer" "-map 0 -c copy" "-show_entries stream_disposition:stream=index" 179 # Notice that the last packet of stream 0 before 20s is present, 180 # but has no duration (like stream 1). 193 fate-webm-webvtt-remux: CMD = transcode webvtt $(TARGET_SAMPLES)/sub/WebVTT_capability_tester.vtt webm "-map 0 -map 0 -map 0 -map 0 -c:s copy -disposition:0 original+descriptions+hearing_impaired -disposition:1 lyrics+default+metadata -disposition:2 comment+forced -disposition:3 karaoke+captions+dub" "-map 0:0 -map 0:1 -c copy" "-show_entries stream_disposition:stream [all...] |
/third_party/node/deps/v8/third_party/jinja2/ |
H A D | environment.py | 573 stream = self.lexer.tokenize(source, name, filename, state) 575 stream = ext.filter_stream(stream) 576 if not isinstance(stream, TokenStream): 577 stream = TokenStream(stream, name, filename) 578 return stream 671 if not parser.stream.eos: 673 "chunk after expression", parser.stream.current.lineno, None, None 971 >>> stream 1106 def stream(self, *args, **kwargs): global() member in Template [all...] |
/third_party/node/tools/inspector_protocol/jinja2/ |
H A D | environment.py | 529 stream = self.lexer.tokenize(source, name, filename, state) 531 stream = ext.filter_stream(stream) 532 if not isinstance(stream, TokenStream): 533 stream = TokenStream(stream, name, filename) 534 return stream 625 if not parser.stream.eos: 627 parser.stream.current.lineno, 910 >>> stream 1023 def stream(self, *args, **kwargs): global() member in Template [all...] |
/third_party/mesa3d/src/microsoft/compiler/ |
H A D | dxil_signature.c | 46 uint8_t stream; member 115 * The signatures are written into the stream in two pieces: 117 * to the stream in order of the registers and each contains an offset 118 * to the semantic name string. Then these strings are dumped into the stream. 146 info->stream = var->data.stream; in get_additional_semantic_info() 466 if (rec->elements[0].stream != 0) { in fill_SV_param_nodes() 468 SV_metadata[num_metadata_nodes++] = dxil_get_metadata_int32(mod, rec->elements[0].stream); in fill_SV_param_nodes() 496 elm->stream = semantic->stream; in fill_signature_element() [all...] |
/third_party/libphonenumber/metadata/src/main/java/com/google/i18n/phonenumbers/metadata/table/ |
H A D | RangeTable.java | 27 import static java.util.stream.Collectors.joining; 187 RangeTree allAssigned = columnRanges.values().stream() in getUnassignedRanges() 198 return columnRanges.entrySet().stream() in getColumns() 343 ImmutableMap<Column<?>, DisjointRangeMap<?>> columnMap = columnRanges.entrySet().stream() in build() 361 ImmutableSet<Column<?>> empty = columnRanges.entrySet().stream() in buildMinimal() 384 List<Assignment<?>> assignments = row.getValue().entrySet().stream() in from() 518 ImmutableMap<Column<?>, DisjointRangeMap<?>> columnMap = columns.stream() in subTable() 828 return table.rowMap().entrySet().stream() in toString() 834 return r.values().stream() in rowToString() 854 ImmutableList<Column<?>> reversedColumns = src.rowMap().entrySet().stream() in toRows() [all...] |