| /third_party/ffmpeg/tests/ref/fate/ |
| D | ffprobe_flat | 509 streams.stream.0.index=0
510 streams.stream.0.codec_name="pcm_s16le"
511 streams.stream.0.profile="unknown"
512 streams.stream.0.codec_type="audio"
513 streams.stream.0.codec_time_base="1/44100"
514 streams.stream.0.codec_tag_string="PSD[16]"
515 streams.stream.0.codec_tag="0x10445350"
516 streams.stream.0.sample_fmt="s16"
517 streams.stream.0.sample_rate="44100"
518 streams.stream.0.channels=1
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | mix_neon.c | 33 static void pa_mix_ch2_s16ne_neon(pa_mix_info streams[], unsigned nstreams, uint8_t *data, unsigned… in pa_mix_ch2_s16ne_neon() argument
50 pa_mix_info *m = streams + i; in pa_mix_ch2_s16ne_neon()
80 fallback(streams, nstreams, 2, data, length & mask); in pa_mix_ch2_s16ne_neon()
84 static void pa_mix2_ch1_s16ne_neon(pa_mix_info streams[], int16_t *data, unsigned length) { in pa_mix2_ch1_s16ne_neon() argument
85 const int16_t *ptr0 = streams[0].ptr; in pa_mix2_ch1_s16ne_neon()
86 const int16_t *ptr1 = streams[1].ptr; in pa_mix2_ch1_s16ne_neon()
93 : [lin0] "r" (streams[0].linear[0]), [lin1] "r" (streams[1].linear[0]) in pa_mix2_ch1_s16ne_neon()
116 int32_t sum = pa_mult_s16_volume(*ptr0++, streams[0].linear[0].i); in pa_mix2_ch1_s16ne_neon()
117 sum += pa_mult_s16_volume(*ptr1++, streams[1].linear[0].i); in pa_mix2_ch1_s16ne_neon()
123 static void pa_mix2_ch2_s16ne_neon(pa_mix_info streams[], int16_t *data, unsigned length) { in pa_mix2_ch2_s16ne_neon() argument
[all …]
|
| D | mix.c | 68 static void calc_linear_integer_stream_volumes(pa_mix_info streams[], unsigned nstreams, const pa_c… in calc_linear_integer_stream_volumes() argument
72 pa_assert(streams); in calc_linear_integer_stream_volumes()
81 pa_mix_info *m = streams + k; in calc_linear_integer_stream_volumes()
87 static void calc_linear_float_stream_volumes(pa_mix_info streams[], unsigned nstreams, const pa_cvo… in calc_linear_float_stream_volumes() argument
91 pa_assert(streams); in calc_linear_float_stream_volumes()
100 pa_mix_info *m = streams + k; in calc_linear_float_stream_volumes()
106 typedef void (*pa_calc_stream_volumes_func_t) (pa_mix_info streams[], unsigned nstreams, const pa_c…
125 static void pa_mix2_ch1_s16ne(pa_mix_info streams[], int16_t *data, unsigned length) { in pa_mix2_ch1_s16ne() argument
126 const int16_t *ptr0 = streams[0].ptr; in pa_mix2_ch1_s16ne()
127 const int16_t *ptr1 = streams[1].ptr; in pa_mix2_ch1_s16ne()
[all …]
|
| /third_party/node/deps/npm/node_modules/readable-stream/lib/internal/streams/ |
| D | pipeline.js | 64 function popCallback(streams) { argument
65 if (!streams.length) return noop;
66 if (typeof streams[streams.length - 1] !== 'function') return noop;
67 return streams.pop();
71 for (var _len = arguments.length, streams = new Array(_len), _key = 0; _key < _len; _key++) {
72 streams[_key] = arguments[_key];
75 var callback = popCallback(streams);
76 if (Array.isArray(streams[0])) streams = streams[0];
78 if (streams.length < 2) {
83 var destroys = streams.map(function (stream, i) {
[all …]
|
| /third_party/glib/gio/tests/ |
| D | gdbus-non-socket.c | 131 GIOStream *streams[2]; in test_non_socket() local
142 ok = test_bidi_pipe (&streams[0], &streams[1], &error); in test_non_socket()
145 g_assert (G_IS_IO_STREAM (streams[0])); in test_non_socket()
146 g_assert (G_IS_INPUT_STREAM (g_io_stream_get_input_stream (streams[0]))); in test_non_socket()
147 g_assert (G_IS_OUTPUT_STREAM (g_io_stream_get_output_stream (streams[0]))); in test_non_socket()
148 g_assert (G_IS_IO_STREAM (streams[1])); in test_non_socket()
149 g_assert (G_IS_INPUT_STREAM (g_io_stream_get_input_stream (streams[1]))); in test_non_socket()
150 g_assert (G_IS_OUTPUT_STREAM (g_io_stream_get_output_stream (streams[1]))); in test_non_socket()
166 ok = g_io_stream_close (streams[1], NULL, &error); in test_non_socket()
169 g_object_unref (streams[1]); in test_non_socket()
[all …]
|
| /third_party/node/deps/npm/node_modules/pumpify/ |
| D | index.js | 12 var streams = toArray(arguments)
13 if (!(this instanceof Pumpify)) return new Pumpify(streams)
15 if (streams.length) this.setPipeline(streams)
21 var streams = toArray(arguments)
24 var w = streams[0]
25 var r = streams[streams.length-1]
31 streams[0].emit('error', new Error('stream was destroyed'))
39 pump(streams, function(err) {
|
| /third_party/ffmpeg/libavformat/ |
| D | webmdashenc.c | 43 int *streams; member
71 AVDictionaryEntry *duration = av_dict_get(s->streams[i]->metadata, in get_duration()
128 AVDictionaryEntry *gold = av_dict_get(s->streams[as->streams[0]]->metadata, in subsegment_alignment()
132 AVDictionaryEntry *ts = av_dict_get(s->streams[as->streams[i]]->metadata, in subsegment_alignment()
141 AVDictionaryEntry *gold_track_num = av_dict_get(s->streams[as->streams[0]]->metadata, in bitstream_switching()
143 AVCodecParameters *gold_par = s->streams[as->streams[0]]->codecpar; in bitstream_switching()
146 AVDictionaryEntry *track_num = av_dict_get(s->streams[as->streams[i]]->metadata, in bitstream_switching()
148 AVCodecParameters *par = s->streams[as->streams[i]]->codecpar; in bitstream_switching()
220 first_width = s->streams[as->streams[0]]->codecpar->width; in check_matching_width()
222 if (first_width != s->streams[as->streams[i]]->codecpar->width) in check_matching_width()
[all …]
|
| D | oggdec.c | 69 struct ogg_stream *stream = &ogg->streams[i]; in free_stream()
86 av_malloc(sizeof(*ost) + (ogg->nstreams - 1) * sizeof(*ogg->streams)); in ogg_save()
97 memcpy(ost->streams, ogg->streams, ogg->nstreams * sizeof(*ogg->streams)); in ogg_save()
100 struct ogg_stream *os = ogg->streams + i; in ogg_save()
103 memcpy(os->buf, ost->streams[i].buf, os->bufpos); in ogg_save()
131 struct ogg_stream *stream = &ogg->streams[i]; in ogg_restore()
135 if (i >= ost->nstreams || !ost->streams[i].private) { in ogg_restore()
144 if ((err = av_reallocp_array(&ogg->streams, ogg->nstreams, in ogg_restore()
145 sizeof(*ogg->streams))) < 0) { in ogg_restore()
149 memcpy(ogg->streams, ost->streams, in ogg_restore()
[all …]
|
| D | oggparsevp8.c | 33 struct ogg_stream *os = ogg->streams + idx; in vp8_header()
35 AVStream *st = s->streams[idx]; in vp8_header()
83 struct ogg_stream *os = ogg->streams + idx; in vp8_gptopts()
104 struct ogg_stream *os = ogg->streams + idx; in vp8_packet()
126 if(s->streams[idx]->start_time == AV_NOPTS_VALUE) { in vp8_packet()
127 s->streams[idx]->start_time = os->lastpts; in vp8_packet()
128 if (s->streams[idx]->duration && s->streams[idx]->duration != AV_NOPTS_VALUE) in vp8_packet()
129 s->streams[idx]->duration -= s->streams[idx]->start_time; in vp8_packet()
|
| D | smoothstreamingenc.c | 77 OutputStream *streams; member
144 AVCodecParameters *par = os->ctx->streams[0]->codecpar; in get_private_data()
169 if (!c->streams) in ism_free()
172 OutputStream *os = &c->streams[i]; in ism_free()
186 av_freep(&c->streams); in ism_free()
226 OutputStream *os = &c->streams[i]; in write_manifest()
231 if (s->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) { in write_manifest()
255 OutputStream *os = &c->streams[i]; in write_manifest()
256 if (s->streams[i]->codecpar->codec_type != AVMEDIA_TYPE_VIDEO) in write_manifest()
259 …vateData=\"%s\" />\n", index, s->streams[i]->codecpar->bit_rate, os->fourcc, s->streams[i]->codecp… in write_manifest()
[all …]
|
| D | hdsenc.c | 75 OutputStream *streams; member
139 if (!c->streams) in hds_free()
142 OutputStream *os = &c->streams[i]; in hds_free()
157 av_freep(&c->streams); in hds_free()
169 duration = c->streams[0].last_ts * av_q2d(s->streams[0]->time_base); in write_manifest()
187 OutputStream *os = &c->streams[i]; in write_manifest()
227 int index = s->streams[os->first_stream]->id; in write_abst()
329 c->streams = av_mallocz_array(s->nb_streams, sizeof(*c->streams)); in hds_write_header()
330 if (!c->streams) { in hds_write_header()
335 OutputStream *os = &c->streams[c->nb_streams]; in hds_write_header()
[all …]
|
| D | rtpenc_mpegts.c | 68 st->time_base = s->streams[i]->time_base; in rtp_mpegts_write_header()
69 st->sample_aspect_ratio = s->streams[i]->sample_aspect_ratio; in rtp_mpegts_write_header()
70 avcodec_parameters_copy(st->codecpar, s->streams[i]->codecpar); in rtp_mpegts_write_header()
77 s->streams[i]->time_base = mpegts_ctx->streams[i]->time_base; in rtp_mpegts_write_header()
139 s->streams[pkt->stream_index]->time_base, in rtp_mpegts_write_packet()
140 chain->rtp_ctx->streams[0]->time_base); in rtp_mpegts_write_packet()
143 s->streams[pkt->stream_index]->time_base, in rtp_mpegts_write_packet()
144 chain->rtp_ctx->streams[0]->time_base); in rtp_mpegts_write_packet()
|
| /third_party/node/deps/npm/node_modules/pump/ |
| D | index.js | 60 var streams = Array.prototype.slice.call(arguments)
61 var callback = isFn(streams[streams.length - 1] || noop) && streams.pop() || noop
63 if (Array.isArray(streams[0])) streams = streams[0]
64 if (streams.length < 2) throw new Error('pump requires two streams per minimum')
67 var destroys = streams.map(function (stream, i) {
68 var reading = i < streams.length - 1
79 return streams.reduce(pipe)
|
| /third_party/node/deps/npm/node_modules/pumpify/node_modules/pump/ |
| D | index.js | 60 var streams = Array.prototype.slice.call(arguments)
61 var callback = isFn(streams[streams.length - 1] || noop) && streams.pop() || noop
63 if (Array.isArray(streams[0])) streams = streams[0]
64 if (streams.length < 2) throw new Error('pump requires two streams per minimum')
67 var destroys = streams.map(function (stream, i) {
68 var reading = i < streams.length - 1
79 streams.reduce(pipe)
|
| /third_party/node/lib/internal/streams/ |
| D | pipeline.js | 77 function popCallback(streams) { argument
81 if (typeof streams[streams.length - 1] !== 'function')
82 throw new ERR_INVALID_CALLBACK(streams[streams.length - 1]);
83 return streams.pop();
128 function pipeline(...streams) { argument
129 const callback = once(popCallback(streams));
132 if (ArrayIsArray(streams[0]) && streams.length === 1) {
133 streams = streams[0];
136 if (streams.length < 2) {
167 for (let i = 0; i < streams.length; i++) {
[all …]
|
| /third_party/gstreamer/gstplugins_bad/ext/kate/ |
| D | README | 4 libkate, a codec for Kate streams, is required to build this plugin:
7 libtiger, a rendering library for Kate streams, is optional:
10 The Kate plugin contains various elements to manipulate Kate streams:
12 - katedec: decodes Kate streams to text and SPU images
13 - kateenc: encodes Kate streams from text and SPU images
14 - kateparse: parses Kate streams
15 - katetag: allows changing metadata in Kate streams
16 - tiger: decodes and renders Kate streams using libtiger (needs libtiger)
|
| /third_party/boost/tools/quickbook/src/ |
| D | collector.cpp | 40 streams.empty()); // assert there are no more pushes than pops!!! in ~collector()
45 streams.push(string_stream()); in push()
46 top = boost::ref(streams.top()); in push()
51 BOOST_ASSERT(!streams.empty()); in pop()
52 streams.pop(); in pop()
54 if (streams.empty()) in pop()
57 top = boost::ref(streams.top()); in pop()
|
| /third_party/pulseaudio/src/tests/ |
| D | connect-stress.c | 54 static pa_stream *streams[NSTREAMS]; variable
100 if (streams[i]) { in _disconnect()
101 pa_stream_disconnect(streams[i]); in _disconnect()
102 pa_stream_unref(streams[i]); in _disconnect()
103 streams[i] = NULL; in _disconnect()
175 streams[i] = pa_stream_new(c, name, &sample_spec, NULL); in context_state_callback()
176 fail_unless(streams[i] != NULL); in context_state_callback()
177 pa_stream_set_state_callback(streams[i], stream_state_callback, NULL); in context_state_callback()
178 pa_stream_set_write_callback(streams[i], stream_write_callback, NULL); in context_state_callback()
179 pa_stream_connect_playback(streams[i], NULL, &buffer_attr, 0, NULL, NULL); in context_state_callback()
[all …]
|
| D | extended-test.c | 40 static pa_stream *streams[NSTREAMS]; variable
136 streams[i] = pa_stream_new_extended(c, name, formats, 1, NULL); in context_state_callback()
137 fail_unless(streams[i] != NULL); in context_state_callback()
138 pa_stream_set_state_callback(streams[i], stream_state_callback, (void*) (long) i); in context_state_callback()
139 …pa_stream_connect_playback(streams[i], NULL, &buffer_attr, PA_STREAM_START_CORKED, NULL, i == 0 ? … in context_state_callback()
166 streams[i] = NULL; in START_TEST()
192 if (streams[i]) in START_TEST()
193 pa_stream_unref(streams[i]); in START_TEST()
|
| D | sync-playback.c | 40 static pa_stream *streams[NSTREAMS]; variable
135 streams[i] = pa_stream_new(c, name, &sample_spec, NULL); in context_state_callback()
136 fail_unless(streams[i] != NULL); in context_state_callback()
137 pa_stream_set_state_callback(streams[i], stream_state_callback, (void*) (long) i); in context_state_callback()
138 …pa_stream_connect_playback(streams[i], NULL, &buffer_attr, PA_STREAM_START_CORKED, NULL, i == 0 ? … in context_state_callback()
163 streams[i] = NULL; in START_TEST()
189 if (streams[i]) in START_TEST()
190 pa_stream_unref(streams[i]); in START_TEST()
|
| /third_party/grpc/src/python/grpcio_tests/tests/fork/ |
| D | _fork_interop_test.py | 73 streams = tuple(tempfile.TemporaryFile() for _ in range(2))
76 stdout=streams[0],
77 stderr=streams[1])
83 streams[0].seek(0)
84 s = streams[0].readline()
137 streams = tuple(tempfile.TemporaryFile() for _ in range(2))
139 stdout=streams[0],
140 stderr=streams[1])
146 for stream in streams:
|
| /third_party/ffmpeg/tools/ |
| D | uncoded_frame.c | 46 Stream *streams = NULL, *st; in main() local
107 if (!(streams = av_calloc(nb_streams, sizeof(*streams)))) { in main()
111 st = streams; in main()
121 av_assert0(st - streams == nb_streams); in main()
130 st = &streams[i]; in main()
152 streams[i].mux = streams[0].mux; in main()
156 st = &streams[i]; in main()
188 st = &streams[i]; in main()
198 st = &streams[i]; in main()
220 st = &streams[i]; in main()
[all …]
|
| /third_party/typescript/tests/baselines/reference/user/ |
| D | graceful-fs.log | 22 node_modules/graceful-fs/legacy-streams.js(14,17): error TS2345: Argument of type 'this' is not ass…
24 node_modules/graceful-fs/legacy-streams.js(36,14): error TS2339: Property 'encoding' does not exist…
25 node_modules/graceful-fs/legacy-streams.js(36,29): error TS2339: Property 'setEncoding' does not ex…
26 node_modules/graceful-fs/legacy-streams.js(36,46): error TS2339: Property 'encoding' does not exist…
27 node_modules/graceful-fs/legacy-streams.js(38,14): error TS2339: Property 'start' does not exist on…
28 node_modules/graceful-fs/legacy-streams.js(39,36): error TS2339: Property 'start' does not exist on…
29 node_modules/graceful-fs/legacy-streams.js(48,16): error TS2339: Property 'start' does not exist on…
30 node_modules/graceful-fs/legacy-streams.js(52,23): error TS2339: Property 'start' does not exist on…
31 node_modules/graceful-fs/legacy-streams.js(57,14): error TS2339: Property '_read' does not exist on…
32 node_modules/graceful-fs/legacy-streams.js(64,14): error TS2339: Property 'emit' does not exist on …
[all …]
|
| /third_party/glib/glib/ |
| D | gwin32.c | 852 streams[] = in g_console_win32_init() local
888 streams[1].redirect = TRUE; in g_console_win32_init()
890 streams[2].redirect = TRUE; in g_console_win32_init()
892 streams[0].redirect = TRUE; in g_console_win32_init()
899 for (i = 0; i < G_N_ELEMENTS (streams); i++) in g_console_win32_init()
908 if (!streams[i].redirect) in g_console_win32_init()
911 if (ferror (streams[i].stream) != 0) in g_console_win32_init()
913 g_warning ("Stream %s is in error state", streams[i].stream_name); in g_console_win32_init()
917 std_handle = GetStdHandle (streams[i].std_handle_type); in g_console_win32_init()
923 streams[i].stream_name, gle); in g_console_win32_init()
[all …]
|
| /third_party/node/deps/npm/node_modules/combined-stream/ |
| D | Readme.md | 3 A stream that emits multiple other streams one after another.
5 …rently `combined-stream` works with streams version 1 only. There is ongoing effort to switch this…
9 …//www.npmjs.com/package/multistream): A stream that emits multiple other streams one after another.
33 While the example above works great, it will pause all source streams until
48 However, what if you don't have all the source streams yet, or you don't want
81 Whether to apply back pressure to the underlaying streams. If set to `false`,
82 the underlaying streams will never be paused. If set to `true`, the
83 underlaying streams will be paused right after being appended, as well as when
88 The maximum amount of bytes (or characters) to buffer for all source streams.
100 `streams` can also be a function that takes one parameter called `next`. `next`
[all …]
|