Home
last modified time | relevance | path

Searched refs:stream (Results 501 - 525 of 4343) sorted by relevance

1...<<21222324252627282930>>...174

/third_party/node/deps/ngtcp2/nghttp3/lib/
H A Dnghttp3_conn.h56 /* NGHTTP3_CONN_FLAG_CONTROL_OPENED is set when a control stream has
60 stream has opened. */
63 stream has opened. */
109 initiated bidirectional stream ID the remote endpoint can
149 nghttp3_stream *stream, const uint8_t *src,
152 nghttp3_ssize nghttp3_conn_read_uni(nghttp3_conn *conn, nghttp3_stream *stream,
156 nghttp3_stream *stream,
167 int nghttp3_conn_on_data(nghttp3_conn *conn, nghttp3_stream *stream,
174 nghttp3_stream *stream,
182 nghttp3_stream *stream);
[all...]
/third_party/mesa3d/src/gallium/drivers/etnaviv/
H A Detnaviv_uniforms.c69 struct etna_cmd_stream *stream = ctx->stream; in etna_uniforms_write() local
78 etna_cmd_stream_reserve(stream, align(uinfo->count + 1, 2)); in etna_uniforms_write()
79 etna_emit_load_state(stream, base >> 2, uinfo->count, 0); in etna_uniforms_write()
86 etna_cmd_stream_emit(stream, val); in etna_uniforms_write()
91 etna_cmd_stream_emit(stream, ((uint32_t*) cb->user_buffer)[val]); in etna_uniforms_write()
96 etna_cmd_stream_emit(stream, in etna_uniforms_write()
102 etna_cmd_stream_reloc(stream, &(struct etna_reloc) { in etna_uniforms_write()
110 etna_cmd_stream_emit(stream, 0); in etna_uniforms_write()
116 etna_cmd_stream_emit(stream, in etna_uniforms_write()
[all...]
/third_party/protobuf/csharp/src/Google.Protobuf.Test/
H A DProto3OptionalTest.cs100 var stream = new MemoryStream(); in Serialization_NotSet()
102 message.WriteTo(stream); in Serialization_NotSet()
103 Assert.AreEqual(0, stream.Length); in Serialization_NotSet()
109 var stream = new MemoryStream(); in Serialization_SetToDefault()
111 message.WriteTo(stream); in Serialization_SetToDefault()
112 Assert.AreEqual(2, stream.Length); // Tag and value in Serialization_SetToDefault()
119 var stream = new MemoryStream(); in Serialization_Roundtrip()
120 original.WriteTo(stream); in Serialization_Roundtrip()
121 stream.Position = 0; in Serialization_Roundtrip()
122 var deserialized = TestProto3Optional.Parser.ParseFrom(stream); in Serialization_Roundtrip()
[all...]
/third_party/skia/src/ports/skia_ohos/
H A DSkTypeface_ohos.cpp34 /*! To get stream of the typeface
36 * \return The stream object of the typeface
44 if (fontInfo->stream == nullptr) { in onOpenStream()
45 fontInfo->stream = SkStream::MakeFromFile(fontInfo->fname.c_str()); in onOpenStream()
47 if (fontInfo->stream) { in onOpenStream()
48 return fontInfo->stream->duplicate(); in onOpenStream()
63 if (fontInfo->stream.get() == nullptr) { in onMakeFontData()
64 fontInfo->stream = SkStream::MakeFromFile(fontInfo->fname.c_str()); in onMakeFontData()
66 if (fontInfo->stream.get() == nullptr) { in onMakeFontData()
69 return std::make_unique<SkFontData>(fontInfo->stream in onMakeFontData()
134 auto stream = openStream(&ttcIndex); onMakeClone() local
[all...]
/third_party/skia/tools/
H A Dskpinfo.cpp45 SkFILEStream stream(FLAGS_input[0]); in main()
46 if (!stream.isValid()) { in main()
53 size_t totStreamSize = stream.getLength(); in main()
56 if (!SkPicture_StreamIsSKP(&stream, &info)) { in main()
71 if (!stream.readBool(&hasData)) { return kTruncatedFile; } in main()
81 if (!stream.readU32(&tag)) { return kTruncatedFile; } in main()
87 if (!stream.readU32(&chunkSize)) { return kTruncatedFile; } in main()
88 size_t curPos = stream.getPosition(); in main()
122 if (!SkFontDescriptor::Deserialize(&stream, &desc)) { in main()
153 if (!stream in main()
[all...]
/third_party/vk-gl-cts/external/vulkancts/scripts/
H A Dgen_framework.py2461 stream = []
2465 stream.append("tcu::TestStatus testPhysicalDeviceFeature" + x.instanceName[len('device'):]+" (Context& context)")
2466 stream.append("""{
2475 stream.append("\t"+structureDefinitions[n])
2476 stream.append("\t"+featureEnabledFlags[n])
2477 stream.append('')
2478 stream.append('\tfor (int ndx = 0; ndx < count; ++ndx)\n\t{')
2479 stream.append("\t" + clearStructures[n])
2480 stream.extend(structureChain[n])
2481 stream
2853 stream = [''] global() variable
[all...]
/device/soc/rockchip/rk3588/kernel/drivers/media/platform/rockchip/cif/
H A Dsubdev-itf.c38 rkcif_update_sensor_info(&cif_dev->stream[0]); in sditf_get_hdr_mode()
62 rkcif_update_sensor_info(&cif_dev->stream[0]); in sditf_g_frame_interval()
80 rkcif_update_sensor_info(&cif_dev->stream[0]); in sditf_g_mbus_config()
101 rkcif_update_sensor_info(&cif_dev->stream[0]); in sditf_get_set_fmt()
133 rkcif_set_fmt(&cif_dev->stream[0], &pixm, false); in sditf_get_set_fmt()
135 rkcif_set_fmt(&cif_dev->stream[0], &pixm, false); in sditf_get_set_fmt()
136 rkcif_set_fmt(&cif_dev->stream[1], &pixm, false); in sditf_get_set_fmt()
138 rkcif_set_fmt(&cif_dev->stream[0], &pixm, false); in sditf_get_set_fmt()
139 rkcif_set_fmt(&cif_dev->stream[1], &pixm, false); in sditf_get_set_fmt()
140 rkcif_set_fmt(&cif_dev->stream[ in sditf_get_set_fmt()
[all...]
/third_party/node/test/fixtures/wpt/streams/resources/
H A Drs-test-templates.js3 // These tests can be run against any readable stream produced by the web platform that meets the given descriptions.
4 // For readable stream tests, the factory should return the stream. For reader tests, the factory should return a
5 // { stream, reader } object. (You can use this to vary the time at which you acquire a reader.)
137 const reader = rs.getReader(); // Calling getReader() twice does not throw (the stream is not locked).
203 const stream = factory().stream;
205 assert_true(stream.locked, 'locked getter should return true');
249 const stream = factory().stream;
[all...]
/third_party/python/Lib/
H A Dcodecs.py348 def __init__(self, stream, errors='strict'):
352 stream must be a file-like object open for writing.
370 self.stream = stream
375 """ Writes the object's contents encoded to self.stream.
378 self.stream.write(data)
382 """ Writes the concatenated list of strings to the stream
394 stream to recover state.
400 self.stream.seek(offset, whence)
407 """ Inherit all other methods from the underlying stream
[all...]
/third_party/pulseaudio/src/modules/
H A Dmodule-tunnel-source-new.c29 #include <pulse/stream.h>
47 PA_MODULE_DESCRIPTION("Create a network source which connects via a stream to a remote PulseAudio server");
67 static void stream_state_cb(pa_stream *stream, void *userdata);
97 pa_stream *stream; member
142 pa_assert(u->stream); in cork_stream()
144 if ((operation = pa_stream_cork(u->stream, cork, NULL, NULL))) in cork_stream()
173 /* called from io context to read samples from the stream into our source */
184 if (PA_UNLIKELY(!u->connected || pa_stream_get_state(u->stream) != PA_STREAM_READY)) in read_new_samples()
187 readable = pa_stream_readable_size(u->stream); in read_new_samples()
190 if (PA_UNLIKELY(pa_stream_peek(u->stream, in read_new_samples()
297 stream_state_cb(pa_stream *stream, void *userdata) stream_state_cb() argument
[all...]
/third_party/node/test/parallel/
H A Dtest-http2-respond-file-fd-errors.js33 server.on('stream', common.mustCall((stream) => {
41 () => stream.respondWithFD(types[type], {
61 () => stream.respondWithFD(fd, {
78 () => stream.respondWithFD(fd, {
90 stream.respond();
92 () => stream.respondWithFD(fd, {
102 // Should throw if stream already destroyed
103 stream.destroy();
105 () => stream
[all...]
H A Dtest-http2-respond-nghttperrors.js17 // - every other NGHTTP2 error from binding (should emit stream error)
35 type: 'stream'
47 server.on('stream', common.mustCall((stream, headers) => {
53 if (currentError.type === 'stream') {
54 stream.session.on('error', errorMustNotCall);
55 stream.on('error', errorMustCall);
56 stream.on('error', common.mustCall(() => {
57 stream.destroy();
60 stream
[all...]
H A Dtest-stream2-push.js25 const { Readable, Writable } = require('stream');
32 const stream = new Readable({
39 stream._read = function() {
40 console.error('stream._read');
45 stream.on('end', function() {
50 const ret = stream.push(chunk);
51 console.error('data', stream.readableLength);
57 stream.push(null);
71 const r = stream.read();
132 writer.end(stream
[all...]
H A Dtest-fs-write-stream-err.js30 const stream = fs.createWriteStream(`${tmpdir.path}/out`, {
58 console.error('fs.close', fd_, stream.fd);
59 assert.strictEqual(fd_, stream.fd);
64 stream.on('error', common.mustCall(function(err_) {
66 assert.strictEqual(stream.fd, null);
71 stream.write(Buffer.allocUnsafe(256), function() {
73 stream.write(Buffer.allocUnsafe(256), common.mustCall(function(err_) {
H A Dtest-http2-pack-end-stream-flag.js13 server.on('stream', (stream, headers) => {
14 stream.respond({
20 stream.end('OK');
23 stream.write('OK');
24 stream.end();
27 stream.write('OK', () => stream.end());
H A Dtest-http2-zero-length-write.js9 const { Readable } = require('stream');
27 server.on('stream', common.mustCall((stream) => {
29 stream.respond();
30 stream.resume();
31 stream.setEncoding('utf8');
32 stream.on('data', (chunk) => actual += chunk);
33 stream.on('end', common.mustCall(() => {
34 getSrc().pipe(stream);
/third_party/skia/src/ports/
H A DSkImageEncoder_CG.cpp33 SkWStream* stream = reinterpret_cast<SkWStream*>(info); in consumer_put() local
34 return stream->write(buffer, count) ? count : 0; in consumer_put()
38 // we do nothing, since by design we don't "own" the stream (i.e. info) in consumer_release()
41 static SkUniqueCFRef<CGDataConsumerRef> SkStreamToCGDataConsumer(SkWStream* stream) { in SkStreamToCGDataConsumer() argument
45 // we don't own/reference the stream, so it our consumer must not live in SkStreamToCGDataConsumer()
46 // longer that our caller's ownership of the stream in SkStreamToCGDataConsumer()
47 return SkUniqueCFRef<CGDataConsumerRef>(CGDataConsumerCreate(stream, &procs)); in SkStreamToCGDataConsumer()
50 static SkUniqueCFRef<CGImageDestinationRef> SkStreamToImageDestination(SkWStream* stream, in SkStreamToImageDestination() argument
52 SkUniqueCFRef<CGDataConsumerRef> consumer = SkStreamToCGDataConsumer(stream); in SkStreamToImageDestination()
65 bool SkEncodeImageWithCG(SkWStream* stream, cons argument
[all...]
/third_party/rust/crates/clap/src/output/
H A Dfmt.rs12 stream: Stream,
19 pub(crate) fn new(stream: Stream, color_when: ColorChoice) -> Self {
21 stream,
41 ColorChoice::Auto if is_a_tty(self.stream) => DepColorChoice::Auto,
45 let writer = match self.stream {
61 match self.stream {
84 fn is_a_tty(stream: Stream) -> bool { in is_a_tty()
86 match stream { in is_a_tty()
/kernel/linux/linux-5.10/drivers/media/usb/pvrusb2/
H A Dpvrusb2-dvb.c26 struct pvr2_stream *stream; in pvr2_dvb_feed_func() local
31 stream = adap->channel.stream->stream; in pvr2_dvb_feed_func()
39 bp = pvr2_stream_get_ready_buffer(stream); in pvr2_dvb_feed_func()
67 (pvr2_stream_get_ready_count(stream) > 0) || in pvr2_dvb_feed_func()
99 struct pvr2_stream *stream; in pvr2_dvb_stream_end() local
106 if (adap->channel.stream) { in pvr2_dvb_stream_end()
107 stream = adap->channel.stream in pvr2_dvb_stream_end()
135 struct pvr2_stream *stream = NULL; pvr2_dvb_stream_do_start() local
[all...]
/kernel/linux/linux-6.6/drivers/media/usb/pvrusb2/
H A Dpvrusb2-dvb.c26 struct pvr2_stream *stream; in pvr2_dvb_feed_func() local
31 stream = adap->channel.stream->stream; in pvr2_dvb_feed_func()
39 bp = pvr2_stream_get_ready_buffer(stream); in pvr2_dvb_feed_func()
67 (pvr2_stream_get_ready_count(stream) > 0) || in pvr2_dvb_feed_func()
101 struct pvr2_stream *stream; in pvr2_dvb_stream_end() local
108 if (adap->channel.stream) { in pvr2_dvb_stream_end()
109 stream = adap->channel.stream in pvr2_dvb_stream_end()
137 struct pvr2_stream *stream = NULL; pvr2_dvb_stream_do_start() local
[all...]
/kernel/linux/linux-6.6/drivers/gpu/drm/amd/display/amdgpu_dm/
H A Damdgpu_dm_crtc.c125 if (vblank_work->stream && vblank_work->stream->link) { in vblank_control_worker()
127 if (vblank_work->stream->link->psr_settings.psr_version < DC_PSR_VERSION_SU_1 && in vblank_control_worker()
128 vblank_work->stream->link->psr_settings.psr_allow_active) in vblank_control_worker()
129 amdgpu_dm_psr_disable(vblank_work->stream); in vblank_control_worker()
130 } else if (vblank_work->stream->link->psr_settings.psr_feature_enabled && in vblank_control_worker()
131 !vblank_work->stream->link->psr_settings.psr_allow_active && in vblank_control_worker()
136 amdgpu_dm_psr_enable(vblank_work->stream); in vblank_control_worker()
142 dc_stream_release(vblank_work->stream); in vblank_control_worker()
192 if (acrtc_state->stream) { in dm_set_vblank()
[all...]
/third_party/gn/src/gn/
H A Drust_project_writer_unittest.cc44 std::ostringstream stream; in TEST_F() local
47 RustProjectWriter::RenderJSON(setup.build_settings(), targets, stream); in TEST_F()
48 std::string out = stream.str(); in TEST_F()
109 std::ostringstream stream; in TEST_F() local
112 RustProjectWriter::RenderJSON(setup.build_settings(), targets, stream); in TEST_F()
113 std::string out = stream.str(); in TEST_F()
207 std::ostringstream stream; in TEST_F() local
210 RustProjectWriter::RenderJSON(setup.build_settings(), targets, stream); in TEST_F()
211 std::string out = stream.str(); in TEST_F()
344 std::ostringstream stream; in TEST_F() local
447 std::ostringstream stream; TEST_F() local
502 std::ostringstream stream; TEST_F() local
557 std::ostringstream stream; TEST_F() local
613 std::ostringstream stream; TEST_F() local
[all...]
/third_party/mesa3d/src/gallium/drivers/radeonsi/
H A Dgfx10_query.c207 result->u64 += qmem->stream[query->stream].emitted_primitives & mask; in gfx10_sh_query_add_result()
210 result->u64 += qmem->stream[query->stream].generated_primitives & mask; in gfx10_sh_query_add_result()
214 qmem->stream[query->stream].emitted_primitives & mask; in gfx10_sh_query_add_result()
216 qmem->stream[query->stream].generated_primitives & mask; in gfx10_sh_query_add_result()
219 result->b |= qmem->stream[query->stream] in gfx10_sh_query_add_result()
[all...]
/third_party/pulseaudio/src/pulse/
H A Dsimple.c41 pa_stream *stream; member
71 !(p)->stream || !PA_STREAM_IS_GOOD(pa_stream_get_state((p)->stream))) { \
73 ((p)->stream && pa_stream_get_state((p)->stream) == PA_STREAM_FAILED)) { \
195 if (!(p->stream = pa_stream_new(p->context, stream_name, ss, map))) { in pa_simple_new()
200 pa_stream_set_state_callback(p->stream, stream_state_cb, p); in pa_simple_new()
201 pa_stream_set_read_callback(p->stream, stream_request_cb, p); in pa_simple_new()
202 pa_stream_set_write_callback(p->stream, stream_request_cb, p); in pa_simple_new()
203 pa_stream_set_latency_update_callback(p->stream, stream_latency_update_c in pa_simple_new()
[all...]
/kernel/linux/linux-6.6/include/net/sctp/
H A Dstream_sched.h5 * These are definitions used by the stream schedulers, defined in RFC
20 /* Property handling for a given stream */
21 int (*set)(struct sctp_stream *stream, __u16 sid, __u16 value,
23 int (*get)(struct sctp_stream *stream, __u16 sid, __u16 *value);
26 int (*init)(struct sctp_stream *stream);
27 /* Init a stream */
28 int (*init_sid)(struct sctp_stream *stream, __u16 sid, gfp_t gfp);
29 /* free a stream */
30 void (*free_sid)(struct sctp_stream *stream, __u16 sid);
54 int sctp_sched_init_sid(struct sctp_stream *stream, __u1
[all...]

Completed in 17 milliseconds

1...<<21222324252627282930>>...174