Home
last modified time | relevance | path

Searched refs:stream (Results 251 - 275 of 2425) sorted by relevance

1...<<11121314151617181920>>...97

/third_party/pulseaudio/src/tests/
H A Dinterpol-test.c42 static pa_stream *stream = NULL; variable
125 stream = pa_stream_new(c, "interpol-test", &ss, NULL); in context_state_callback()
126 fail_unless(stream != NULL); in context_state_callback()
129 pa_assert_se(pa_stream_connect_playback(stream, NULL, &attr, flags, NULL, NULL) == 0); in context_state_callback()
130 pa_stream_set_write_callback(stream, stream_write_cb, NULL); in context_state_callback()
132 pa_assert_se(pa_stream_connect_record(stream, NULL, &attr, flags) == 0); in context_state_callback()
133 pa_stream_set_read_callback(stream, stream_read_cb, NULL); in context_state_callback()
136 pa_stream_set_latency_update_callback(stream, stream_latency_cb, NULL); in context_state_callback()
189 if (stream) { in START_TEST()
192 if (pa_stream_get_time(stream, in START_TEST()
[all...]
/third_party/skia/third_party/externals/freetype/builds/amiga/src/base/
H A Dftsystem.c241 /* system-specific stream handle from a given FreeType stream object */
242 #define STREAM_FILE( stream ) ( (struct SysFile *)stream->descriptor.pointer )
251 /* The function to close a stream. */
254 /* stream :: A pointer to the stream object. */
257 ft_amiga_stream_close( FT_Stream stream ) in ft_amiga_stream_close()
261 sysfile = STREAM_FILE( stream ); in ft_amiga_stream_close()
265 stream in ft_amiga_stream_close()
292 ft_amiga_stream_io( FT_Stream stream, unsigned long offset, unsigned char* buffer, unsigned long count ) ft_amiga_stream_io() argument
[all...]
/third_party/skia/third_party/externals/dng_sdk/source/
H A Ddng_ifd.cpp261 bool dng_ifd::ParseTag (dng_stream &stream, in ParseTag() argument
285 fNewSubFileType = stream.TagValue_uint32 (tagType); in ParseTag()
312 fImageWidth = stream.TagValue_uint32 (tagType); in ParseTag()
334 fImageLength = stream.TagValue_uint32 (tagType); in ParseTag()
370 uint32 x = stream.TagValue_uint32 (tagType); in ParseTag()
434 fCompression = stream.TagValue_uint32 (tagType); in ParseTag()
484 fPhotometricInterpretation = stream.TagValue_uint32 (tagType); in ParseTag()
509 fFillOrder = stream.TagValue_uint32 (tagType); in ParseTag()
541 fTileOffset [j] = stream.TagValue_uint32 (tagType); in ParseTag()
552 stream in ParseTag()
4249 ReadImage(dng_host &host, dng_stream &stream, dng_image &image, dng_jpeg_image *jpegImage, dng_fingerprint *jpegDigest) const ReadImage() argument
[all...]
/third_party/googletest/googletest/src/
H A Dgtest.cc367 "This flag specifies the host name and the port number on which to stream "
1386 // stream.
1388 // adds. It also adds the hunk header before printint into the stream.
2042 ::std::stringstream stream;
2056 stream << CodePointToUtf8(unicode_code_point);
2058 return StringStreamToString(&stream);
3297 // We need to flush the stream buffers into the console before each
3893 static void PrintXmlTestsList(std::ostream* stream,
3930 static void OutputXmlAttribute(std::ostream* stream,
3936 static void OutputXmlCDataSection(::std::ostream* stream, cons
[all...]
/third_party/node/deps/googletest/src/
H A Dgtest.cc375 "This flag specifies the host name and the port number on which to stream "
1403 // stream.
1405 // adds. It also adds the hunk header before printint into the stream.
2059 ::std::stringstream stream;
2073 stream << CodePointToUtf8(unicode_code_point);
2075 return StringStreamToString(&stream);
3310 // We need to flush the stream buffers into the console before each
3906 static void PrintXmlTestsList(std::ostream* stream,
3943 static void OutputXmlAttribute(std::ostream* stream,
3949 static void OutputXmlCDataSection(::std::ostream* stream, cons
[all...]
/third_party/node/lib/internal/http2/
H A Dcore.js52 const { Duplex } = require('stream');
202 function debugStreamObj(stream, message, ...args) {
203 const session = stream[kSession];
205 debugStream(stream[kID], type, message, ...new SafeArrayIterator(args));
334 // stream. The stream may or may not be new. If the stream is new,
335 // create the associated Http2Stream instance and emit the 'stream'
336 // event. If the stream is not new, emit the 'headers' event to pass
349 let stream
[all...]
/device/soc/rockchip/common/vendor/drivers/gpu/arm/bifrost/tl/
H A Dmali_kbase_tlstream.h33 /* The number of packets used by one timeline stream. */
44 * struct kbase_tlstream - timeline stream structure
49 * @numbered: If non-zero stream's packets are sequentially numbered
50 * @autoflush_counter: Counter tracking stream's autoflush state
56 * timeline stream.
59 * greater than the previous message in the same stream. For this reason
62 * Each stream contains a set of buffers. Each buffer will hold one MIPE
65 * stream has a sequence number embedded, this value must increment
72 * is no activity on the buffer for two consecutive timer expiries, the stream
107 * kbase_tlstream_init - initialize timeline stream
[all...]
H A Dmali_kbase_timeline_io.c29 /* The timeline stream file operations functions. */
34 /* The timeline stream file operations structure. */
45 * @ready_stream: Pointer to variable where stream will be placed
51 * values pointing to right stream and buffer.
64 struct kbase_tlstream *stream = &timeline->streams[i]; in kbasep_timeline_io_packet_pending() local
65 *rb_idx_raw = atomic_read(&stream->rbi); in kbasep_timeline_io_packet_pending()
71 if (atomic_read(&stream->wbi) != *rb_idx_raw) { in kbasep_timeline_io_packet_pending()
72 *ready_stream = stream; in kbasep_timeline_io_packet_pending()
98 * copy_stream_header() - copy timeline stream header.
104 * @hdr: Pointer to the stream heade
201 struct kbase_tlstream *stream = NULL; kbasep_timeline_io_read() local
282 struct kbase_tlstream *stream; kbasep_timeline_io_poll() local
[all...]
/device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/tl/
H A Dmali_kbase_tlstream.h32 /* The number of packets used by one timeline stream. */
43 * struct kbase_tlstream - timeline stream structure
50 * @numbered: If non-zero stream's packets are sequentially numbered
51 * @autoflush_counter: Counter tracking stream's autoflush state
57 * timeline stream.
60 * greater than the previous message in the same stream. For this reason
63 * Each stream contains a set of buffers. Each buffer will hold one MIPE
66 * stream has a sequence number embedded, this value must increment
73 * is no activity on the buffer for two consecutive timer expiries, the stream
108 * kbase_tlstream_init - initialize timeline stream
[all...]
H A Dmali_kbase_timeline_io.c30 /* The timeline stream file operations functions. */
39 /* The timeline stream file operations structure. */
53 * @ready_stream: Pointer to variable where stream will be placed
59 * values pointing to right stream and buffer.
74 struct kbase_tlstream *stream = &timeline->streams[i]; in kbasep_timeline_io_packet_pending() local
75 *rb_idx_raw = atomic_read(&stream->rbi); in kbasep_timeline_io_packet_pending()
81 if (atomic_read(&stream->wbi) != *rb_idx_raw) { in kbasep_timeline_io_packet_pending()
82 *ready_stream = stream; in kbasep_timeline_io_packet_pending()
108 * copy_stream_header() - copy timeline stream header.
114 * @hdr: Pointer to the stream heade
211 struct kbase_tlstream *stream = NULL; kbasep_timeline_io_read() local
296 struct kbase_tlstream *stream; kbasep_timeline_io_poll() local
[all...]
/third_party/skia/third_party/externals/swiftshader/src/OpenGL/compiler/preprocessor/
H A Dnumeric_lex.h48 std::istringstream stream(str); in numeric_lex_int()
51 stream.setf(numeric_base_int(str), std::ios::basefield); in numeric_lex_int()
53 stream >> (*value); in numeric_lex_int()
54 return !stream.fail(); in numeric_lex_int()
60 std::istringstream stream(str); in numeric_lex_float()
63 stream.imbue(std::locale::classic()); in numeric_lex_float()
65 stream >> (*value); in numeric_lex_float()
66 return !stream.fail() && std::isfinite(*value); in numeric_lex_float()
/third_party/ffmpeg/libavdevice/
H A Dpulse_audio_enc.c50 pa_stream *stream; member
132 if (!(op = pa_context_get_sink_input_info(ctx, pa_stream_get_index(s->stream), in pulse_update_sink_input_info()
169 static void pulse_stream_writable(pa_stream *stream, size_t nbytes, void *userdata) in pulse_stream_writable() argument
175 if (stream != s->stream) in pulse_stream_writable()
182 static void pulse_overflow(pa_stream *stream, void *userdata) in pulse_overflow() argument
188 static void pulse_underflow(pa_stream *stream, void *userdata) in pulse_underflow() argument
194 static void pulse_stream_state(pa_stream *stream, void *userdata) in pulse_stream_state() argument
198 if (stream != s->stream) in pulse_stream_state()
252 pulse_stream_result(pa_stream *stream, int success, void *userdata) pulse_stream_result() argument
694 pulse_get_output_timestamp(AVFormatContext *h, int stream, int64_t *dts, int64_t *wall) pulse_get_output_timestamp() argument
[all...]
/third_party/mesa3d/src/gallium/tools/trace/
H A Dformat.py36 def __init__(self, stream):
37 self.stream = stream
40 self.stream.write(text)
122 def __init__(self, stream):
123 Formatter.__init__(self, stream)
125 if stream is sys.stdin:
127 elif stream is sys.stdout:
129 elif stream is sys.stderr:
166 def DefaultFormatter(stream)
[all...]
/third_party/ffmpeg/tools/
H A Duncoded_frame.c13 AVStream *stream; member
96 av_log(NULL, AV_LOG_ERROR, "Graph has no output stream\n"); in main()
158 if (!(st->stream = avformat_new_stream(st->mux, NULL))) { in main()
160 av_log(NULL, AV_LOG_ERROR, "Failed to create output stream\n"); in main()
163 st->stream->codecpar->codec_type = av_buffersink_get_type(st->sink); in main()
164 st->stream->time_base = av_buffersink_get_time_base(st->sink); in main()
167 st->stream->codecpar->codec_id = AV_CODEC_ID_RAWVIDEO; in main()
168 st->stream->avg_frame_rate = in main()
169 st->stream-> r_frame_rate = av_buffersink_get_frame_rate(st->sink); in main()
170 st->stream in main()
[all...]
/third_party/ffmpeg/libavformat/
H A Drtmphttp.c41 URLContext *stream; ///< HTTP stream member
65 av_opt_set_bin(rt->stream->priv_data, "post_data", rt->out_data, in rtmp_http_send_cmd()
69 if ((ret = ff_http_do_new_request(rt->stream, uri)) < 0) in rtmp_http_send_cmd()
76 if ((ret = ffurl_read(rt->stream, &c, 1)) < 0) in rtmp_http_send_cmd()
112 ret = ffurl_read(rt->stream, buf + off, size); in rtmp_http_read()
179 ffurl_closep(&rt->stream); in rtmp_http_close()
211 if ((ret = ffurl_alloc(&rt->stream, url, AVIO_FLAG_READ_WRITE, &h->interrupt_callback)) < 0) in rtmp_http_open()
219 av_opt_set(rt->stream->priv_data, "headers", headers, 0); in rtmp_http_open()
220 av_opt_set(rt->stream in rtmp_http_open()
[all...]
/third_party/libuv/src/win/
H A Dstream.c30 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { in uv_listen() argument
32 if (uv__is_closing(stream)) { in uv_listen()
36 switch (stream->type) { in uv_listen()
38 err = uv__tcp_listen((uv_tcp_t*)stream, backlog, cb); in uv_listen()
41 err = uv__pipe_listen((uv_pipe_t*)stream, backlog, cb); in uv_listen()
171 int uv_try_write(uv_stream_t* stream, in uv_try_write() argument
174 if (stream->flags & UV_HANDLE_CLOSING) in uv_try_write()
176 if (!(stream->flags & UV_HANDLE_WRITABLE)) in uv_try_write()
179 switch (stream->type) { in uv_try_write()
181 return uv__tcp_try_write((uv_tcp_t*) stream, buf in uv_try_write()
193 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
/third_party/node/deps/undici/src/lib/api/
H A Dreadable.js6 const { Readable } = require('stream')
41 // Is stream being consumed through Readable API?
147 this[kBody].getReader() // Ensure stream is locked.
212 async function consume (stream, type) {
213 if (isUnusable(stream)) {
217 assert(!stream[kConsume])
220 stream[kConsume] = {
222 stream,
229 stream
239 process.nextTick(consumeStart, stream[kConsum
[all...]
/third_party/node/deps/uv/src/win/
H A Dstream.c30 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { in uv_listen() argument
32 if (uv__is_closing(stream)) { in uv_listen()
36 switch (stream->type) { in uv_listen()
38 err = uv__tcp_listen((uv_tcp_t*)stream, backlog, cb); in uv_listen()
41 err = uv__pipe_listen((uv_pipe_t*)stream, backlog, cb); in uv_listen()
171 int uv_try_write(uv_stream_t* stream, in uv_try_write() argument
174 if (stream->flags & UV_HANDLE_CLOSING) in uv_try_write()
176 if (!(stream->flags & UV_HANDLE_WRITABLE)) in uv_try_write()
179 switch (stream->type) { in uv_try_write()
181 return uv__tcp_try_write((uv_tcp_t*) stream, buf in uv_try_write()
193 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
/third_party/node/test/fixtures/wpt/streams/readable-byte-streams/
H A Dgeneral.any.js154 const stream = new ReadableStream({
158 const reader = stream.getReader();
165 const stream = new ReadableStream({
169 const reader = stream.getReader({ mode: 'byob' });
176 const stream = new ReadableStream({
184 const reader = stream.getReader();
187 assert_throws_js(TypeError, () => stream.getReader(), 'getReader() must throw');
189 }, 'ReadableStream with byte source: Test that closing a stream does not release a reader automatically');
192 const stream = new ReadableStream({
200 const reader = stream
[all...]
/third_party/node/deps/v8/third_party/jinja2/
H A Dext.py96 def filter_stream(self, stream):
102 return stream
106 parser as first argument. The token the parser stream is pointing at
231 lineno = next(parser.stream).lineno
241 while parser.stream.current.type != "block_end":
243 parser.stream.expect("comma")
246 if parser.stream.skip_if("colon"):
249 name = parser.stream.expect("name")
258 if parser.stream.current.type == "assign":
259 next(parser.stream)
[all...]
/third_party/skia/third_party/externals/jinja2/
H A Dext.py96 def filter_stream(self, stream):
102 return stream
106 parser as first argument. The token the parser stream is pointing at
231 lineno = next(parser.stream).lineno
241 while parser.stream.current.type != "block_end":
243 parser.stream.expect("comma")
246 if parser.stream.skip_if("colon"):
249 name = parser.stream.expect("name")
258 if parser.stream.current.type == "assign":
259 next(parser.stream)
[all...]
/third_party/node/test/parallel/
H A Dtest-repl-editor.js17 const stream = new ArrayStream();
20 stream.write = (msg) => found += msg.replace('\r', '');
30 input: stream,
31 output: stream,
35 stream.emit('data', '.editor\n');
36 stream.emit('data', input);
81 const stream = new ArrayStream();
84 stream.write = () => { throw new Error('Writing not allowed!'); };
89 input: stream,
94 stream
[all...]
/third_party/node/deps/uvwasi/src/
H A Dsync_helpers.c38 uv_stream_t* stream, in shutdown_stream_sync()
45 stream_loop = uv_handle_get_loop((uv_handle_t*) stream); in shutdown_stream_sync()
47 uv_handle_set_data((uv_handle_t*) stream, (void*) shutdown_data); in shutdown_stream_sync()
48 uv_shutdown(&req, stream, do_stream_shutdown); in shutdown_stream_sync()
64 void do_stream_recv(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in do_stream_recv() argument
66 recv_data = uv_handle_get_data((uv_handle_t*) stream); in do_stream_recv()
67 uv_read_stop(stream); in do_stream_recv()
73 uv_stream_t* stream, in read_stream_sync()
80 recv_loop = uv_handle_get_loop((uv_handle_t*) stream); in read_stream_sync()
82 uv_handle_set_data((uv_handle_t*) stream, (voi in read_stream_sync()
37 shutdown_stream_sync(struct uvwasi_s* uvwasi, uv_stream_t* stream, shutdown_data_t* shutdown_data) shutdown_stream_sync() argument
72 read_stream_sync(struct uvwasi_s* uvwasi, uv_stream_t* stream, recv_data_t* recv_data) read_stream_sync() argument
[all...]
/third_party/skia/third_party/externals/freetype/src/tools/
H A Dtest_afm.c76 FT_Stream stream, in parse_afm()
88 error = FT_Stream_EnterFrame( stream, stream->size ); in parse_afm()
94 stream->cursor, in parse_afm()
95 stream->limit ); in parse_afm()
114 FT_StreamRec stream; in main() local
126 FT_ZERO( &stream ); in main()
127 error = FT_Stream_Open( &stream, argv[1] ); in main()
130 stream.memory = library->memory; in main()
133 error = parse_afm( library, &stream, in main()
75 parse_afm( FT_Library library, FT_Stream stream, AFM_FontInfo fi ) parse_afm() argument
[all...]
/third_party/pulseaudio/sonic/
H A Dmain.c29 sonicStream stream = sonicCreateStream(sampleRate, numChannels); in runSonic() local
33 sonicSetSpeed(stream, speed); in runSonic()
34 sonicSetPitch(stream, pitch); in runSonic()
35 sonicSetRate(stream, rate); in runSonic()
36 sonicSetVolume(stream, volume); in runSonic()
37 sonicSetChordPitch(stream, emulateChordPitch); in runSonic()
38 sonicSetQuality(stream, quality); in runSonic()
42 sonicFlushStream(stream); in runSonic()
44 sonicWriteShortToStream(stream, inBuffer, samplesRead); in runSonic()
47 samplesWritten = sonicReadShortFromStream(stream, outBuffe in runSonic()
[all...]

Completed in 18 milliseconds

1...<<11121314151617181920>>...97