/third_party/node/test/parallel/ |
H A D | test-http2-info-headers.js | 12 server.on('stream', common.mustCall(onStream)); 19 function onStream(stream, headers, flags) { 21 assert.throws(() => stream.additionalHeaders({ ':status': 201 }), 28 assert.throws(() => stream.additionalHeaders({ ':status': 101 }), 36 () => stream.additionalHeaders({ ':method': 'POST' }), 45 stream.additionalHeaders({ ':status': 100 }); 46 stream.additionalHeaders({ ':status': 100 }); 48 stream.respond({ 53 assert.throws(() => stream.additionalHeaders({ abc: 123 }), 60 stream [all...] |
H A D | test-fs-read-stream.js | 167 const stream = fs.createReadStream(rangeFile, common.mustNotMutateObjectDeep({ start: 0, end: 0 })); 168 stream.data = ''; 170 stream.on('data', function(chunk) { 171 stream.data += chunk; 174 stream.on('end', common.mustCall(function() { 175 assert.strictEqual(stream.data, 'x'); 181 const stream = new fs.createReadStream(rangeFile, common.mustNotMutateObjectDeep({ end: 1 })); 182 stream.data = ''; 184 stream.on('data', function(chunk) { 185 stream [all...] |
H A D | test-event-emitter-prepend.js | 22 const stream = require('stream'); 28 stream.Stream.call(this); 30 Object.setPrototypeOf(Writable.prototype, stream.Stream.prototype); 31 Object.setPrototypeOf(Writable, stream.Stream); 35 stream.Stream.call(this); 37 Object.setPrototypeOf(Readable.prototype, stream.Stream.prototype); 38 Object.setPrototypeOf(Readable, stream.Stream);
|
/kernel/linux/linux-6.6/drivers/gpu/drm/amd/display/dc/dcn30/ |
H A D | dcn30_hwseq.c | 94 const struct dc_stream_state *stream) in dcn30_set_mpc_shaper_3dlut() 105 if (stream->func_shaper) { in dcn30_set_mpc_shaper_3dlut() 106 if (stream->func_shaper->type == TF_TYPE_HWPWL) { in dcn30_set_mpc_shaper_3dlut() 107 shaper_lut = &stream->func_shaper->pwl; in dcn30_set_mpc_shaper_3dlut() 108 } else if (stream->func_shaper->type == TF_TYPE_DISTRIBUTED_POINTS) { in dcn30_set_mpc_shaper_3dlut() 109 cm_helper_translate_curve_to_hw_format(stream->ctx, stream->func_shaper, in dcn30_set_mpc_shaper_3dlut() 115 if (stream->lut3d_func && in dcn30_set_mpc_shaper_3dlut() 116 stream->lut3d_func->state.bits.initialized == 1 && in dcn30_set_mpc_shaper_3dlut() 117 stream in dcn30_set_mpc_shaper_3dlut() 93 dcn30_set_mpc_shaper_3dlut(struct pipe_ctx *pipe_ctx, const struct dc_stream_state *stream) dcn30_set_mpc_shaper_3dlut() argument 189 dcn30_set_output_transfer_func(struct dc *dc, struct pipe_ctx *pipe_ctx, const struct dc_stream_state *stream) dcn30_set_output_transfer_func() argument 363 dcn30_program_all_writeback_pipes_in_tree( struct dc *dc, const struct dc_stream_state *stream, struct dc_state *context) dcn30_program_all_writeback_pipes_in_tree() argument 662 struct dc_stream_state *stream = pipe_ctx->stream; dcn30_program_dmdata_engine() local 692 struct dc_stream_state *stream = NULL; dcn30_apply_idle_power_optimizations() local [all...] |
/kernel/linux/linux-5.10/drivers/gpu/drm/amd/display/dc/dcn30/ |
H A D | dcn30_hwseq.c | 91 struct pipe_ctx *pipe_ctx, const struct dc_stream_state *stream) in dcn30_set_mpc_shaper_3dlut() 102 if (stream->func_shaper) { in dcn30_set_mpc_shaper_3dlut() 103 if (stream->func_shaper->type == TF_TYPE_HWPWL) in dcn30_set_mpc_shaper_3dlut() 104 shaper_lut = &stream->func_shaper->pwl; in dcn30_set_mpc_shaper_3dlut() 105 else if (stream->func_shaper->type == TF_TYPE_DISTRIBUTED_POINTS) { in dcn30_set_mpc_shaper_3dlut() 107 stream->func_shaper, in dcn30_set_mpc_shaper_3dlut() 113 if (stream->lut3d_func && in dcn30_set_mpc_shaper_3dlut() 114 stream->lut3d_func->state.bits.initialized == 1 && in dcn30_set_mpc_shaper_3dlut() 115 stream->lut3d_func->state.bits.rmu_idx_valid == 1) { in dcn30_set_mpc_shaper_3dlut() 116 if (stream in dcn30_set_mpc_shaper_3dlut() 90 dcn30_set_mpc_shaper_3dlut( struct pipe_ctx *pipe_ctx, const struct dc_stream_state *stream) dcn30_set_mpc_shaper_3dlut() argument 185 dcn30_set_output_transfer_func(struct dc *dc, struct pipe_ctx *pipe_ctx, const struct dc_stream_state *stream) dcn30_set_output_transfer_func() argument 366 dcn30_program_all_writeback_pipes_in_tree( struct dc *dc, const struct dc_stream_state *stream, struct dc_state *context) dcn30_program_all_writeback_pipes_in_tree() argument 678 struct dc_stream_state *stream = pipe_ctx->stream; dcn30_program_dmdata_engine() local [all...] |
/third_party/node/deps/v8/third_party/jinja2/ |
H A D | ext.py | 96 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 D | ext.py | 96 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/fixtures/wpt/streams/readable-byte-streams/ |
H A D | general.any.js | 154 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...] |
/kernel/linux/linux-6.6/drivers/gpu/drm/i915/ |
H A D | i915_perf_types.h | 101 * struct i915_perf_stream_ops - the OPs to support a specific stream type 106 * `I915_PERF_IOCTL_ENABLE` or implicitly called when stream is opened 109 void (*enable)(struct i915_perf_stream *stream); 114 * the stream. 116 void (*disable)(struct i915_perf_stream *stream); 120 * once there is something ready to read() for the stream 122 void (*poll_wait)(struct i915_perf_stream *stream, 128 * something to ready to read() for the stream. E.g. wait on the same 131 int (*wait_unlocked)(struct i915_perf_stream *stream); 141 * Copy as many buffered i915 perf samples and records for this stream [all...] |
/third_party/curl/tests/libtest/ |
H A D | lib552.c | 39 FILE *stream, unsigned char *ptr, size_t size, in dump() 51 fprintf(stream, "%s, %zu bytes (0x%zx)\n", text, size, size); in dump() 55 fprintf(stream, "%04zx: ", i); in dump() 61 fprintf(stream, "%02x ", ptr[i + c]); in dump() 63 fputs(" ", stream); in dump() 73 fprintf(stream, "%c", in dump() 82 fputc('\n', stream); /* newline */ in dump() 84 fflush(stream); in dump() 131 static size_t read_callback(char *ptr, size_t size, size_t nmemb, void *stream) in read_callback() argument 137 (void)stream; in read_callback() 38 dump(const char *text, FILE *stream, unsigned char *ptr, size_t size, char nohex) dump() argument 144 write_callback(void *ptr, size_t size, size_t nmemb, void *stream) write_callback() argument [all...] |
/third_party/node/lib/internal/bootstrap/switches/ |
H A D | is_main_thread.js | 48 let stream; 49 // Note stream._type is used for test-module-load-list.js 53 stream = new tty.WriteStream(fd); 54 stream._type = 'tty'; 60 stream = new SyncWriteStream(fd, { autoClose: false }); 61 stream._type = 'fs'; 74 stream = new net.Socket({ 80 stream = new net.Socket({ 87 stream._type = 'pipe'; 94 const { Writable } = require('stream'); [all...] |
/third_party/vk-gl-cts/modules/gles31/functional/ |
H A D | es31fAtomicCounterTests.cpp | 1052 std::ostringstream stream; in specToTestName() local 1054 stream << spec.atomicCounterCount << (spec.atomicCounterCount == 1 ? "_counter" : "_counters"); in specToTestName() 1055 stream << "_" << spec.callCount << (spec.callCount == 1 ? "_call" : "_calls"); in specToTestName() 1056 stream << "_" << spec.threadCount << (spec.threadCount == 1 ? "_thread" : "_threads"); in specToTestName() 1058 return stream.str(); in specToTestName() 1063 std::ostringstream stream; in specToTestDescription() local 1066 stream in specToTestDescription() 1071 stream << "atomicCounter()"; in specToTestDescription() 1078 stream << ", "; in specToTestDescription() 1080 stream << " atomicCounterIncremen in specToTestDescription() 1105 std::ostringstream stream; operationToName() local 1140 std::ostringstream stream; operationToDescription() local 1181 std::ostringstream stream; layoutTypesToName() local 1239 std::ostringstream stream; layoutTypesToDesc() local [all...] |
/third_party/vk-gl-cts/external/vulkancts/scripts/ |
H A D | gen_framework.py | 2461 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...] |
/kernel/linux/linux-5.10/include/sound/ |
H A D | soc-dai.h | 163 bool snd_soc_dai_stream_valid(struct snd_soc_dai *dai, int stream); 166 int stream, int action); 168 int stream) in snd_soc_dai_activate() 170 snd_soc_dai_action(dai, stream, 1); in snd_soc_dai_activate() 173 int stream) in snd_soc_dai_deactivate() 175 snd_soc_dai_action(dai, stream, -1); in snd_soc_dai_deactivate() 243 void *stream, int direction); 250 int (*mute_stream)(struct snd_soc_dai *dai, int mute, int stream); 399 snd_soc_dai_get_pcm_stream(const struct snd_soc_dai *dai, int stream) in snd_soc_dai_get_pcm_stream() argument 401 return (stream in snd_soc_dai_get_pcm_stream() 167 snd_soc_dai_activate(struct snd_soc_dai *dai, int stream) snd_soc_dai_activate() argument 172 snd_soc_dai_deactivate(struct snd_soc_dai *dai, int stream) snd_soc_dai_deactivate() argument 406 snd_soc_dai_get_widget( struct snd_soc_dai *dai, int stream) snd_soc_dai_get_widget() argument 460 snd_soc_dai_set_stream(struct snd_soc_dai *dai, void *stream, int direction) snd_soc_dai_set_stream() argument 490 snd_soc_dai_stream_active(struct snd_soc_dai *dai, int stream) snd_soc_dai_stream_active() argument [all...] |
/third_party/elfio/elfio/ |
H A D | elfio_section.hpp | 66 virtual bool load( std::istream& stream, 69 virtual void save( std::ostream& stream, 220 bool load( std::istream& stream, 224 pstream = &stream; 229 stream.seekg( 0, std::istream::end ); 230 set_stream_size( size_t( stream.tellg() ) ); 236 stream.seekg( ( *translator )[header_offset] ); 237 stream.read( reinterpret_cast<char*>( &header ), sizeof( header ) ); 292 void save( std::ostream& stream, 301 save_header( stream, header_offse [all...] |
/third_party/skia/third_party/externals/freetype/src/type1/ |
H A D | t1parse.c | 69 read_pfb_tag( FT_Stream stream, in read_pfb_tag() argument 97 check_type1_format( FT_Stream stream, in check_type1_format() argument 109 error = read_pfb_tag( stream, &tag, &dummy ); in check_type1_format() 123 if ( ft_memcmp( stream->cursor, header_string, header_length ) != 0 ) in check_type1_format() 136 FT_Stream stream, in FT_LOCAL_DEF() 147 parser->stream = stream; in FT_LOCAL_DEF() 157 error = check_type1_format( stream, "%!PS-AdobeFont", 14 ); in FT_LOCAL_DEF() 163 error = check_type1_format( stream, "%!FontType", 10 ); in FT_LOCAL_DEF() 180 * in the case of a memory-based stream in FT_LOCAL_DEF() 263 FT_Stream stream = parser->stream; FT_LOCAL_DEF() local [all...] |
/third_party/skia/third_party/externals/tint/tools/src/cmd/remote-compile/ |
H A D | main.cc | 227 /// Writes the message `m` to the stream `s` 237 /// Reads the message `m` from the stream `s` 255 /// Writes the request message `req` to the stream `s`, then reads and returns 256 /// the response message from the same stream. 357 Stream stream{conn.get()}; in RunServer() 361 stream >> req; in RunServer() 362 if (!stream.error.empty()) { in RunServer() 363 printf("%s\n", stream.error.c_str()); in RunServer() 370 stream << resp; in RunServer() 373 stream << res in RunServer() [all...] |
/third_party/node/tools/inspector_protocol/jinja2/ |
H A D | ext.py | 89 def filter_stream(self, stream): 99 return stream 103 parser as first argument. The token the parser stream is pointing at 219 lineno = next(parser.stream).lineno 229 while parser.stream.current.type != 'block_end': 231 parser.stream.expect('comma') 234 if parser.stream.skip_if('colon'): 237 name = parser.stream.expect('name') 244 if parser.stream.current.type == 'assign': 245 next(parser.stream) [all...] |
/kernel/linux/linux-5.10/sound/firewire/dice/ |
H A D | dice-pcm.c | 29 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in dice_rate_constraint() 67 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in dice_channels_constraint() 132 struct amdtp_stream *stream; in init_hw_info() local 135 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) { in init_hw_info() 138 stream = &dice->tx_stream[index]; in init_hw_info() 142 stream = &dice->rx_stream[index]; in init_hw_info() 161 return amdtp_am824_add_pcm_hw_constraints(stream, runtime); in init_hw_info() 201 // When source of clock is not internal or any stream is reserved for in pcm_open() 309 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; in capture_prepare() local 316 amdtp_stream_pcm_prepare(stream); in capture_prepare() 323 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_prepare() local 338 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; capture_trigger() local 356 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_trigger() local 375 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; capture_pointer() local 382 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_pointer() local 390 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; capture_ack() local 398 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_ack() local [all...] |
/kernel/linux/linux-6.6/sound/firewire/dice/ |
H A D | dice-pcm.c | 29 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in dice_rate_constraint() 67 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) in dice_channels_constraint() 132 struct amdtp_stream *stream; in init_hw_info() local 135 if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) { in init_hw_info() 138 stream = &dice->tx_stream[index]; in init_hw_info() 142 stream = &dice->rx_stream[index]; in init_hw_info() 161 return amdtp_am824_add_pcm_hw_constraints(stream, runtime); in init_hw_info() 201 // When source of clock is not internal or any stream is reserved for in pcm_open() 309 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; in capture_prepare() local 316 amdtp_stream_pcm_prepare(stream); in capture_prepare() 323 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_prepare() local 338 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; capture_trigger() local 356 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_trigger() local 375 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; capture_pointer() local 382 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_pointer() local 390 struct amdtp_stream *stream = &dice->tx_stream[substream->pcm->device]; capture_ack() local 398 struct amdtp_stream *stream = &dice->rx_stream[substream->pcm->device]; playback_ack() local [all...] |
/third_party/skia/third_party/externals/microhttpd/src/microspdy/ |
H A D | applicationlayer.c | 51 * Callback called when new stream is created. It extracts the info from 52 * the stream to create (HTTP) request object and pass it to the client. 55 * @param stream the new SPDY stream 60 struct SPDYF_Stream * stream) in spdy_handler_new_stream() 71 struct SPDY_NameValue * iterator = stream->headers; in spdy_handler_new_stream() 74 daemon = stream->session->daemon; in spdy_handler_new_stream() 87 request->stream = stream; in spdy_handler_new_stream() 89 /* extract the mandatory fields from stream in spdy_handler_new_stream() 59 spdy_handler_new_stream(void *cls, struct SPDYF_Stream * stream) spdy_handler_new_stream() argument 187 spdy_handler_new_data(void * cls, struct SPDYF_Stream *stream, const void * buf, size_t size, bool more) spdy_handler_new_data() argument [all...] |
/third_party/skia/src/utils/ |
H A D | SkCustomTypeface.cpp | 249 static void write_scaled_float_to_16(SkWStream* stream, float x, float scale) { in write_scaled_float_to_16() argument 250 stream->write16(SkToS16(sk_float_round2int(x * scale)) & 0xFFFF); in write_scaled_float_to_16() 260 static void compress_write(SkWStream* stream, const SkPath& path, int upem) { in compress_write() argument 275 stream->write16(upem); // share w/ other paths? in compress_write() 276 stream->write16(vCount); in compress_write() 277 stream->write16(pCount); in compress_write() 279 stream->write8((verbs[i+0]<<6) | (verbs[i+1]<<4) | (verbs[i+2]<<2) | verbs[i+3]); in compress_write() 288 stream->write8(b); in compress_write() 291 stream->write8(0); in compress_write() 297 write_scaled_float_to_16(stream, pt in compress_write() 359 AutoRestorePosition(SkStream* stream) AutoRestorePosition() argument 373 Deserialize(SkStream* stream) Deserialize() argument [all...] |
/third_party/skia/third_party/externals/dng_sdk/source/ |
H A D | dng_preview.cpp | 236 dng_stream &stream) const in WriteData() 242 stream, in WriteData() 388 dng_stream &stream) const in WriteData() 391 basic.SetTileOffset (0, (uint32) stream.Position ()); in WriteData() 395 stream.Put (fCompressedData->Buffer (), in WriteData() 400 stream.Put_uint8 (0); in WriteData() 407 void dng_jpeg_preview::SpoolAdobeThumbnail (dng_stream &stream) const in SpoolAdobeThumbnail() 418 stream.Put_uint32 (DNG_CHAR4 ('8','B','I','M')); in SpoolAdobeThumbnail() 419 stream.Put_uint16 (1036); in SpoolAdobeThumbnail() 420 stream in SpoolAdobeThumbnail() [all...] |
/third_party/node/test/fixtures/wpt/streams/resources/ |
H A D | rs-test-templates.js | 3 // 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 D | codecs.py | 348 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...] |