/third_party/node/tools/inspector_protocol/jinja2/ |
H A D | lexer.py | 191 useful for extensions that filter a stream. 277 """The iterator for tokenstreams. Iterate over the stream 281 def __init__(self, stream): 282 self.stream = stream 288 token = self.stream.current 290 self.stream.close() 292 next(self.stream) 298 """A token stream is an iterable that yields :class:`Token`\\s. The 319 eos = property(lambda x: not x, doc="Are we at the end of the stream [all...] |
/third_party/libphonenumber/cpp/src/phonenumbers/ |
H A D | phonenumber.pb.cc | 347 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { in _InternalSerialize() 355 target = stream->EnsureSpace(target); in _InternalSerialize() 361 target = stream->EnsureSpace(target); in _InternalSerialize() 367 target = stream->WriteStringMaybeAliased( in _InternalSerialize() 373 target = stream->EnsureSpace(target); in _InternalSerialize() 379 target = stream->WriteStringMaybeAliased( in _InternalSerialize() 385 target = stream->EnsureSpace(target); in _InternalSerialize() 392 target = stream->WriteStringMaybeAliased( in _InternalSerialize() 398 target = stream->EnsureSpace(target); in _InternalSerialize() 403 target = stream in _InternalSerialize() [all...] |
/third_party/skia/third_party/externals/jinja2/ |
H A D | lexer.py | 200 useful for extensions that filter a stream. 301 """The iterator for tokenstreams. Iterate over the stream 305 def __init__(self, stream): 306 self.stream = stream 312 token = self.stream.current 314 self.stream.close() 316 next(self.stream) 322 """A token stream is an iterable that yields :class:`Token`\\s. The 346 """Are we at the end of the stream [all...] |
/third_party/protobuf/java/core/src/test/java/com/google/protobuf/ |
H A D | NioByteStringTest.java | 227 InputStream stream = testString.newInput(); in testMarkSupported() 228 assertTrue(CLASSNAME + ".newInput() must support marking", stream.markSupported()); in testMarkSupported() 234 InputStream stream = testString.newInput(); in testMarkAndReset() 235 stream.mark(testString.size()); // First, mark() the end. in testMarkAndReset() 237 skipFully(stream, fraction); // Skip a large fraction, but not all. in testMarkAndReset() 241 stream.available()); in testMarkAndReset() 242 stream.reset(); in testMarkAndReset() 246 stream.available()); in testMarkAndReset() 248 skipFully(stream, testString.size()); // Skip to the end. in testMarkAndReset() 252 stream in testMarkAndReset() [all...] |
/kernel/linux/linux-5.10/net/wireless/ |
H A D | wext-core.c | 1130 char *iwe_stream_add_event(struct iw_request_info *info, char *stream, in iwe_stream_add_event() argument 1138 if (likely((stream + event_len) < ends)) { in iwe_stream_add_event() 1141 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_event() 1142 memcpy(stream + lcp_len, &iwe->u, in iwe_stream_add_event() 1144 stream += event_len; in iwe_stream_add_event() 1147 return stream; in iwe_stream_add_event() 1151 char *iwe_stream_add_point(struct iw_request_info *info, char *stream, in iwe_stream_add_point() argument 1159 if (likely((stream + event_len) < ends)) { in iwe_stream_add_point() 1161 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_point() 1162 memcpy(stream in iwe_stream_add_point() [all...] |
/kernel/linux/linux-6.6/net/wireless/ |
H A D | wext-core.c | 1149 char *iwe_stream_add_event(struct iw_request_info *info, char *stream, in iwe_stream_add_event() argument 1157 if (likely((stream + event_len) < ends)) { in iwe_stream_add_event() 1160 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_event() 1161 memcpy(stream + lcp_len, &iwe->u, in iwe_stream_add_event() 1163 stream += event_len; in iwe_stream_add_event() 1166 return stream; in iwe_stream_add_event() 1170 char *iwe_stream_add_point(struct iw_request_info *info, char *stream, in iwe_stream_add_point() argument 1178 if (likely((stream + event_len) < ends)) { in iwe_stream_add_point() 1180 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_point() 1181 memcpy(stream in iwe_stream_add_point() [all...] |
/third_party/curl/tests/server/ |
H A D | rtspd.c | 84 #define RCMD_STREAM 2 /* told to stream */ 155 /* 'stream' means to send a never-ending stream of data */ 156 #define CMD_STREAM "stream" 251 FILE *stream; in ProcessRequest() local 291 stream = test2fopen(req->testno, logdir); in ProcessRequest() 293 if(!stream) { in ProcessRequest() 312 int error = getpart(&cmd, &cmdsize, "reply", "servercmd", stream); in ProcessRequest() 313 fclose(stream); in ProcessRequest() 335 logmsg("instructed to stream"); in ProcessRequest() 859 FILE *stream = test2fopen(req->testno, logdir); send_doc() local [all...] |
/third_party/skia/src/codec/ |
H A D | SkJpegCodec.cpp | 160 SkCodec::Result SkJpegCodec::ReadHeader(SkStream* stream, SkCodec** codecOut, in ReadHeader() argument 165 std::unique_ptr<JpegDecoderMgr> decoderMgr(new JpegDecoderMgr(stream)); in ReadHeader() 249 SkJpegCodec* codec = new SkJpegCodec(std::move(info), std::unique_ptr<SkStream>(stream), in ReadHeader() 259 std::unique_ptr<SkCodec> SkJpegCodec::MakeFromStream(std::unique_ptr<SkStream> stream, in MakeFromStream() argument 261 return SkJpegCodec::MakeFromStream(std::move(stream), result, nullptr); in MakeFromStream() 264 std::unique_ptr<SkCodec> SkJpegCodec::MakeFromStream(std::unique_ptr<SkStream> stream, in MakeFromStream() argument 267 *result = ReadHeader(stream.get(), &codec, nullptr, std::move(defaultColorProfile)); in MakeFromStream() 269 // Codec has taken ownership of the stream, we do not need to delete it in MakeFromStream() 271 stream.release(); in MakeFromStream() 277 SkJpegCodec::SkJpegCodec(SkEncodedInfo&& info, std::unique_ptr<SkStream> stream, in SkJpegCodec() argument [all...] |
/third_party/skia/third_party/externals/abseil-cpp/absl/random/internal/ |
H A D | pcg_engine_test.cc | 148 std::stringstream stream; in TYPED_TEST() local 149 stream << engine; in TYPED_TEST() 152 stream >> new_engine; in TYPED_TEST() 463 std::ostringstream stream; in TEST() local 464 stream << engine; in TEST() 465 auto str = stream.str(); in TEST() 476 std::istringstream stream( in TEST() 479 stream >> engine; in TEST() 614 std::ostringstream stream; in TEST() local 615 stream << engin in TEST() [all...] |
/third_party/vk-gl-cts/modules/egl/ |
H A D | teglBufferAgeTests.cpp | 530 std::ostringstream stream; in iterate() local 531 stream << "Fail, the age is invalid. Age: " << currentBufferAge << ", frameNdx: " << frameNdx; in iterate() 532 m_testCtx.setTestResult(QP_TEST_RESULT_FAIL, stream.str().c_str()); in iterate() 538 std::ostringstream stream; in iterate() local 539 stream << "Fail, EGL_BUFFER_PRESERVED is set to true, but buffer age is: " << currentBufferAge << " (should be 1)"; in iterate() 540 m_testCtx.setTestResult(QP_TEST_RESULT_FAIL, stream.str().c_str()); in iterate() 634 std::ostringstream stream; in generateDrawTypeName() local 641 stream << "_render"; in generateDrawTypeName() 643 stream << "_clear"; in generateDrawTypeName() 647 return stream in generateDrawTypeName() 721 std::ostringstream stream; compareToReference() local [all...] |
/kernel/linux/linux-6.6/drivers/gpu/drm/amd/display/modules/power/ |
H A D | power_helpers.c | 856 * @stream: [input] dc stream state pointer 877 const struct dc_stream_state *stream) in mod_power_calc_psr_configs() 887 num_vblank_lines = stream->timing.v_total - in mod_power_calc_psr_configs() 888 stream->timing.v_addressable - in mod_power_calc_psr_configs() 889 stream->timing.v_border_top - in mod_power_calc_psr_configs() 890 stream->timing.v_border_bottom; in mod_power_calc_psr_configs() 892 vblank_time_in_us = (stream->timing.h_total * num_vblank_lines * 1000) / (stream->timing.pix_clk_100hz / 10); in mod_power_calc_psr_configs() 894 line_time_in_us = ((stream in mod_power_calc_psr_configs() 875 mod_power_calc_psr_configs(struct psr_config *psr_config, struct dc_link *link, const struct dc_stream_state *stream) mod_power_calc_psr_configs() argument 936 mod_power_only_edp(const struct dc_state *context, const struct dc_stream_state *stream) mod_power_only_edp() argument 941 psr_su_set_dsc_slice_height(struct dc *dc, struct dc_link *link, struct dc_stream_state *stream, struct psr_config *config) psr_su_set_dsc_slice_height() argument [all...] |
/third_party/rust/crates/proc-macro2/src/ |
H A D | wrapper.rs | 24 stream: proc_macro::TokenStream, 51 fn new(stream: proc_macro::TokenStream) -> Self { in new() 53 stream, in new() 59 self.stream.is_empty() && self.extra.is_empty() in is_empty() 67 self.stream.extend(self.extra.drain(..)); in evaluate_now() 73 self.stream in into_token_stream() 204 first.stream.extend(streams.map(|s| match s { in from_iter() 223 fn extend<I: IntoIterator<Item = TokenTree>>(&mut self, stream: I) { in extend() 227 for token in stream { in extend() 231 TokenStream::Fallback(tts) => tts.extend(stream), in extend() 582 pub fn stream(&self) -> TokenStream { stream() functions [all...] |
/kernel/linux/linux-5.10/tools/testing/selftests/kvm/lib/aarch64/ |
H A D | processor.c | 186 static void pte_dump(FILE *stream, struct kvm_vm *vm, uint8_t indent, uint64_t page, int level) in pte_dump() argument 199 fprintf(stream, "%*s%s: %lx: %lx at %p\n", indent, "", type[level], pte, *ptep, ptep); in pte_dump() 200 pte_dump(stream, vm, indent + 1, pte_addr(vm, *ptep), level + 1); in pte_dump() 205 void virt_dump(FILE *stream, struct kvm_vm *vm, uint8_t indent) in virt_dump() argument 217 fprintf(stream, "%*spgd: %lx: %lx at %p\n", indent, "", pgd, *ptep, ptep); in virt_dump() 218 pte_dump(stream, vm, indent + 1, pte_addr(vm, *ptep), level); in virt_dump() 304 void vcpu_dump(FILE *stream, struct kvm_vm *vm, uint32_t vcpuid, uint8_t indent) in vcpu_dump() argument 311 fprintf(stream, "%*spstate: 0x%.16lx pc: 0x%.16lx\n", in vcpu_dump()
|
/kernel/linux/linux-5.10/drivers/soundwire/ |
H A D | generic_bandwidth_allocation.c | 51 rate = m_rt->stream->params.rate; in sdw_compute_slave_ports() 52 bps = m_rt->stream->params.bps; in sdw_compute_slave_ports() 80 * of the stream, which indicates that they operate in in sdw_compute_slave_ports() 100 rate = m_rt->stream->params.rate; in sdw_compute_master_ports() 101 bps = m_rt->stream->params.bps; in sdw_compute_master_ports() 160 m_rt->stream->params.bps; in _sdw_compute_port_params() 184 rate = m_rt->stream->params.rate; in sdw_compute_group_params() 185 bps = m_rt->stream->params.bps; in sdw_compute_group_params() 253 rate = m_rt->stream->params.rate; in sdw_get_group_count()
|
/kernel/linux/linux-5.10/sound/soc/atmel/ |
H A D | atmel-pcm-pdc.c | 38 int stream) in atmel_pcm_preallocate_dma_buffer() 40 struct snd_pcm_substream *substream = pcm->streams[stream].substream; in atmel_pcm_preallocate_dma_buffer() 103 int stream; in atmel_pcm_free() local 105 for (stream = 0; stream < 2; stream++) { in atmel_pcm_free() 106 substream = pcm->streams[stream].substream; in atmel_pcm_free() 164 substream->stream == SNDRV_PCM_STREAM_PLAYBACK in atmel_pcm_dma_irq() 37 atmel_pcm_preallocate_dma_buffer(struct snd_pcm *pcm, int stream) atmel_pcm_preallocate_dma_buffer() argument
|
/kernel/linux/linux-6.6/drivers/soundwire/ |
H A D | generic_bandwidth_allocation.c | 45 rate = m_rt->stream->params.rate; in sdw_compute_slave_ports() 46 bps = m_rt->stream->params.bps; in sdw_compute_slave_ports() 74 * of the stream, which indicates that they operate in in sdw_compute_slave_ports() 95 rate = m_rt->stream->params.rate; in sdw_compute_master_ports() 96 bps = m_rt->stream->params.bps; in sdw_compute_master_ports() 151 port_bo += m_rt->ch_count * m_rt->stream->params.bps; in _sdw_compute_port_params() 174 rate = m_rt->stream->params.rate; in sdw_compute_group_params() 175 bps = m_rt->stream->params.bps; in sdw_compute_group_params() 243 rate = m_rt->stream->params.rate; in sdw_get_group_count()
|
/kernel/linux/linux-6.6/drivers/gpu/drm/amd/display/dc/dce/ |
H A D | dmub_psr.c | 142 static bool dmub_psr_set_version(struct dmub_psr *dmub, struct dc_stream_state *stream, uint8_t panel_inst) in dmub_psr_set_version() argument 147 if (stream->link->psr_settings.psr_version == DC_PSR_VERSION_UNSUPPORTED) in dmub_psr_set_version() 153 switch (stream->link->psr_settings.psr_version) { in dmub_psr_set_version() 308 if (res_ctx->pipe_ctx[i].stream && in dmub_psr_copy_settings() 309 res_ctx->pipe_ctx[i].stream->link == link && in dmub_psr_copy_settings() 310 res_ctx->pipe_ctx[i].stream->link->connector_signal == SIGNAL_TYPE_EDP) { in dmub_psr_copy_settings() 321 if (!dmub_psr_set_version(dmub, pipe_ctx->stream, panel_inst)) in dmub_psr_copy_settings() 383 copy_settings_data->dsc_enable_status = (pipe_ctx->stream->timing.flags.DSC == 1); in dmub_psr_copy_settings()
|
/kernel/linux/linux-6.6/drivers/gpu/drm/amd/display/dc/dml/dcn314/ |
H A D | dcn314_fpu.c | 326 if (!res_ctx->pipe_ctx[i].stream) in dcn314_populate_dml_pipes_from_context_fpu() 329 timing = &pipe->stream->timing; in dcn314_populate_dml_pipes_from_context_fpu() 333 if (pipe->stream->adjust.v_total_min != 0) in dcn314_populate_dml_pipes_from_context_fpu() 334 pipes[pipe_cnt].pipe.dest.vtotal = pipe->stream->adjust.v_total_min; in dcn314_populate_dml_pipes_from_context_fpu() 415 if (!pipe->stream) in dcn314_populate_dml_pipes_from_context_fpu() 418 if (pipe->stream->signal == SIGNAL_TYPE_EDP && dc->debug.seamless_boot_odm_combine && in dcn314_populate_dml_pipes_from_context_fpu() 419 pipe->stream->apply_seamless_boot_optimization) { in dcn314_populate_dml_pipes_from_context_fpu() 421 if (pipe->stream->apply_boot_odm_mode == dm_odm_combine_policy_2to1) { in dcn314_populate_dml_pipes_from_context_fpu()
|
/third_party/mesa3d/src/gallium/drivers/r600/sfn/ |
H A D | sfn_shader_gs.cpp | 218 int stream = nir_intrinsic_stream_id(instr); in emit_vertex() local 219 assert(stream < 4); in emit_vertex() 221 auto cut_instr = new EmitVertexInstr(stream, cut); in emit_vertex() 224 if (stream == 0 || v.first != VARYING_SLOT_POS) { in emit_vertex() 225 v.second->patch_ring(stream, m_export_base[stream]); in emit_vertex() 237 auto ir = new AluInstr(op2_add_int, m_export_base[stream], m_export_base[stream], in emit_vertex()
|
/third_party/node/deps/v8/third_party/zlib/contrib/minizip/ |
H A D | miniunz.c | 33 #define FTELLO_FUNC(stream) ftello(stream) 34 #define FSEEKO_FUNC(stream, offset, origin) fseeko(stream, offset, origin) 37 #define FTELLO_FUNC(stream) ftello64(stream) 38 #define FSEEKO_FUNC(stream, offset, origin) fseeko64(stream, offset, origin)
|
/third_party/musl/porting/linux/user/src/fortify/ |
H A D | fortify.c | 343 size_t __fread_chk(void* buf, size_t size, size_t count, FILE* stream, size_t buf_size) in __fread_chk() argument 348 return fread(buf, size, count, stream); in __fread_chk() 351 return __DIAGNOSE_CALL_BYPASSING_FORTIFY(fread)(buf, size, count, stream); in __fread_chk() 354 size_t __fwrite_chk(const void* buf, size_t size, size_t count, FILE* stream, size_t buf_size) in __fwrite_chk() argument 359 return fwrite(buf, size, count, stream); in __fwrite_chk() 362 return __DIAGNOSE_CALL_BYPASSING_FORTIFY(fwrite)(buf, size, count, stream); in __fwrite_chk() 365 char* __fgets_chk(char* dest, int supplied_size, FILE* stream, size_t dst_len_from_compiler) in __fgets_chk() argument 368 return __DIAGNOSE_CALL_BYPASSING_FORTIFY(fgets)(dest, supplied_size, stream); in __fgets_chk()
|
/third_party/musl/src/fortify/linux/ |
H A D | fortify.c | 354 size_t __fread_chk(void* buf, size_t size, size_t count, FILE* stream, size_t buf_size) in __fread_chk() argument 359 return fread(buf, size, count, stream); in __fread_chk() 362 return __DIAGNOSE_CALL_BYPASSING_FORTIFY(fread)(buf, size, count, stream); in __fread_chk() 365 size_t __fwrite_chk(const void* buf, size_t size, size_t count, FILE* stream, size_t buf_size) in __fwrite_chk() argument 370 return fwrite(buf, size, count, stream); in __fwrite_chk() 373 return __DIAGNOSE_CALL_BYPASSING_FORTIFY(fwrite)(buf, size, count, stream); in __fwrite_chk() 376 char* __fgets_chk(char* dest, int supplied_size, FILE* stream, size_t dst_len_from_compiler) in __fgets_chk() argument 379 return __DIAGNOSE_CALL_BYPASSING_FORTIFY(fgets)(dest, supplied_size, stream); in __fgets_chk()
|
/third_party/ltp/utils/sctp/func_tests/ |
H A D | test_basic.c | 85 uint32_t stream; in main() local 186 stream = 1; in main() 188 sinfo->sinfo_stream = stream; in main() 257 MSG_EOR, stream, ppid); in main() 301 stream++; in main() 303 sinfo->sinfo_stream = stream; in main() 341 MSG_EOR, stream, ppid); in main() 346 MSG_EOR, stream, ppid); in main()
|
/third_party/skia/third_party/externals/libwebp/imageio/ |
H A D | wicdec.c | 88 static HRESULT OpenInputStream(const char* filename, IStream** stream) { in OpenInputStream() argument 101 IFS(CreateStreamOnHGlobal(image, TRUE, stream)); in OpenInputStream() 113 IFS(SHCreateStreamOnFile((const LPTSTR)filename, STGM_READ, stream)); in OpenInputStream() 269 IStream* stream = NULL; in ReadPictureWithWIC() local 304 IFS(OpenInputStream(filename, &stream)); in ReadPictureWithWIC() 306 factory, stream, NULL, in ReadPictureWithWIC() 393 if (stream != NULL) IUnknown_Release(stream); in ReadPictureWithWIC()
|
/third_party/skia/third_party/externals/zlib/contrib/minizip/ |
H A D | miniunz.c | 33 #define FTELLO_FUNC(stream) ftello(stream) 34 #define FSEEKO_FUNC(stream, offset, origin) fseeko(stream, offset, origin) 37 #define FTELLO_FUNC(stream) ftello64(stream) 38 #define FSEEKO_FUNC(stream, offset, origin) fseeko64(stream, offset, origin)
|