Home
last modified time | relevance | path

Searched refs:stream (Results 51 - 75 of 2489) sorted by relevance

12345678910>>...100

/third_party/node/lib/internal/http2/
H A Dcompat.js23 const Stream = require('stream');
73 const kStream = Symbol('stream');
162 // Cause the request stream to end as well.
202 function resumeStream(stream) {
203 stream.resume();
207 has(stream, prop) {
208 const ref = stream.session !== undefined ? stream.session[kSocket] : stream;
209 return (prop in stream) || (pro
[all...]
/third_party/PyYAML/lib/yaml/
H A D__init__.py29 def scan(stream, Loader=Loader):
31 Scan a YAML stream and produce scanning tokens.
33 loader = Loader(stream)
40 def parse(stream, Loader=Loader):
42 Parse a YAML stream and produce parsing events.
44 loader = Loader(stream)
51 def compose(stream, Loader=Loader):
53 Parse the first YAML document in a stream
56 loader = Loader(stream)
62 def compose_all(stream, Loade
[all...]
/third_party/python/Lib/test/test_asyncio/
H A Dtest_streams.py128 stream = asyncio.StreamReader(loop=self.loop)
130 stream.feed_data(b'')
131 self.assertEqual(b'', stream._buffer)
134 stream = asyncio.StreamReader(loop=self.loop)
136 stream.feed_data(self.DATA)
137 self.assertEqual(self.DATA, stream._buffer)
141 stream = asyncio.StreamReader(loop=self.loop)
142 stream.feed_data(self.DATA)
144 data = self.loop.run_until_complete(stream.read(0))
146 self.assertEqual(self.DATA, stream
[all...]
/third_party/skia/third_party/externals/freetype/builds/windows/
H A Dftsystem.c151 /* system-specific stream handle from a given FreeType stream object */
152 #define STREAM_FILE( stream ) ( (FILE*)stream->descriptor.pointer )
161 * The function to close a stream which is opened by mmap.
164 * stream :: A pointer to the stream object.
167 ft_close_stream_by_munmap( FT_Stream stream ) in ft_close_stream_by_munmap()
169 UnmapViewOfFile( (LPCVOID)stream->descriptor.pointer ); in ft_close_stream_by_munmap()
171 stream in ft_close_stream_by_munmap()
[all...]
/third_party/curl/src/
H A Dtool_writeout_json.c89 void jsonWriteString(FILE *stream, const char *in, bool lowercase) in jsonWriteString() argument
95 fputc('\"', stream); in jsonWriteString()
97 fputs(curlx_dyn_ptr(&out), stream); in jsonWriteString() local
98 fputc('\"', stream); in jsonWriteString()
103 void ourWriteOutJSON(FILE *stream, const struct writeoutvar mappings[], in ourWriteOutJSON() argument
108 fputs("{", stream); in ourWriteOutJSON()
112 mappings[i].writefunc(stream, &mappings[i], per, per_result, true)) in ourWriteOutJSON()
113 fputs(",", stream); in ourWriteOutJSON()
118 fprintf(stream, "\"curl_version\":"); in ourWriteOutJSON()
119 jsonWriteString(stream, curl_versio in ourWriteOutJSON()
128 headerJSON(FILE *stream, struct per_transfer *per) headerJSON() argument
[all...]
/third_party/ltp/testcases/kernel/fs/stream/
H A Dstream05.c20 /* ported from SPIE, section2/filesuite/stream.c, by Airong Zhang */
29 >HOW: < 1) open a stream and immediately execute ferror
31 < written with stream - compare actual vs expected.
32 < 3) open stream and ensure feof returns zero, read to end of
57 FILE *stream; in main() local
76 if ((stream = fopen(tempfile, "a+")) == NULL) { in main()
81 fprintf(stream, "a"); in main()
82 fclose(stream); in main()
84 if ((stream = fopen(tempfile, "r+")) == NULL) { in main()
91 if (ferror(stream) ! in main()
[all...]
H A Dstream03.c51 FILE *stream; in main() local
72 if ((stream = fopen(tempfile1, "a+")) == NULL) { in main()
79 pos = ftell(stream); in main()
87 if (fwrite(junk, sizeof(*junk), strlen(junk), stream) == 0) { in main()
92 pos = ftell(stream); in main()
102 rewind(stream); in main()
103 pos = ftell(stream); in main()
113 if (fseek(stream, strlen(junk), 1) != 0) { in main()
118 pos = ftell(stream); in main()
128 if (fseek(stream, in main()
[all...]
/third_party/python/Lib/test/
H A Dtest_imghdr.py40 with open(cls.testfile, 'rb') as stream:
41 cls.testdata = stream.read()
50 with open(filename, 'rb') as stream:
51 self.assertEqual(imghdr.what(stream), expected)
52 with open(filename, 'rb') as stream:
53 data = stream.read()
72 with open(TESTFN, 'wb') as stream:
73 stream.write(b'ababagalamaga')
74 pos = stream.tell()
75 stream
[all...]
/third_party/python/Lib/
H A Dgetpass.py3 getpass(prompt[, stream]) - Prompt for a password, with echo turned off.
29 def unix_getpass(prompt='Password: ', stream=None):
33 prompt: Written on stream to ask for the input. Default: 'Password: '
34 stream: A writable file object to display the prompt. Defaults to
53 if not stream:
54 stream = input
62 passwd = fallback_getpass(prompt, stream)
64 if not stream:
65 stream = sys.stderr
77 passwd = _raw_input(prompt, stream, inpu
[all...]
H A Dpprint.py19 Handle pretty-printing operations onto a stream using a configured
29 Pretty-print a Python object to a stream [default is sys.stdout].
48 def pprint(object, stream=None, indent=1, width=80, depth=None, *,
50 """Pretty-print a Python object to a stream [default is sys.stdout]."""
52 stream=stream, indent=indent, width=width, depth=depth,
107 def __init__(self, indent=1, width=80, depth=None, stream=None, *,
109 """Handle pretty printing operations onto a stream using a set of
121 stream
122 The desired output stream
[all...]
/third_party/curl/lib/vquic/
H A Dcurl_msh3.c136 * All about the H3 internals of a stream
146 uint64_t error3; /* HTTP/3 stream error code */
167 struct stream_ctx *stream = H3_STREAM_CTX(data); in h3_data_setup() local
169 if(stream) in h3_data_setup()
172 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
173 if(!stream) in h3_data_setup()
176 H3_STREAM_LCTX(data) = stream; in h3_data_setup()
177 stream->req = ZERO_NULL; in h3_data_setup()
178 msh3_lock_initialize(&stream in h3_data_setup()
187 struct stream_ctx *stream = H3_STREAM_CTX(data); h3_data_done() local
198 drain_stream_from_other_thread(struct Curl_easy *data, struct stream_ctx *stream) drain_stream_from_other_thread() argument
216 struct stream_ctx *stream = H3_STREAM_CTX(data); drain_stream() local
314 struct stream_ctx *stream = H3_STREAM_CTX(data); write_resp_raw() local
340 struct stream_ctx *stream = H3_STREAM_CTX(data); msh3_header_received() local
389 struct stream_ctx *stream = H3_STREAM_CTX(data); msh3_data_received() local
428 struct stream_ctx *stream = H3_STREAM_CTX(data); msh3_complete() local
447 struct stream_ctx *stream = H3_STREAM_CTX(data); msh3_shutdown_complete() local
459 struct stream_ctx *stream = H3_STREAM_CTX(data); msh3_data_sent() local
471 struct stream_ctx *stream = H3_STREAM_CTX(data); recv_closed_stream() local
504 struct stream_ctx *stream = H3_STREAM_CTX(data); set_quic_expire() local
521 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_msh3_recv() local
573 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_msh3_send() local
685 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_msh3_adjust_pollset() local
704 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_msh3_data_pending() local
757 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_msh3_data_event() local
[all...]
/third_party/node/deps/v8/third_party/zlib/
H A Duncompr.c25 an incomplete zlib stream.
33 z_stream stream; local
37 Byte buf[1]; /* for detection of incomplete stream when *destLen == 0 */
49 stream.next_in = (z_const Bytef *)source;
50 stream.avail_in = 0;
51 stream.zalloc = (alloc_func)0;
52 stream.zfree = (free_func)0;
53 stream.opaque = (voidpf)0;
55 err = inflateInit(&stream);
58 stream
[all...]
/third_party/node/deps/zlib/
H A Duncompr.c25 an incomplete zlib stream.
29 z_stream stream; in uncompress2() local
33 Byte buf[1]; /* for detection of incomplete stream when *destLen == 0 */ in uncompress2()
45 stream.next_in = (z_const Bytef *)source; in uncompress2()
46 stream.avail_in = 0; in uncompress2()
47 stream.zalloc = (alloc_func)0; in uncompress2()
48 stream.zfree = (free_func)0; in uncompress2()
49 stream.opaque = (voidpf)0; in uncompress2()
51 err = inflateInit(&stream); in uncompress2()
54 stream in uncompress2()
[all...]
/third_party/skia/third_party/externals/zlib/
H A Duncompr.c25 an incomplete zlib stream.
33 z_stream stream; local
37 Byte buf[1]; /* for detection of incomplete stream when *destLen == 0 */
49 stream.next_in = (z_const Bytef *)source;
50 stream.avail_in = 0;
51 stream.zalloc = (alloc_func)0;
52 stream.zfree = (free_func)0;
53 stream.opaque = (voidpf)0;
55 err = inflateInit(&stream);
58 stream
[all...]
/third_party/zlib/
H A Duncompr.c25 an incomplete zlib stream.
29 z_stream stream; in uncompress2() local
33 Byte buf[1]; /* for detection of incomplete stream when *destLen == 0 */ in uncompress2()
45 stream.next_in = (z_const Bytef *)source; in uncompress2()
46 stream.avail_in = 0; in uncompress2()
47 stream.zalloc = (alloc_func)0; in uncompress2()
48 stream.zfree = (free_func)0; in uncompress2()
49 stream.opaque = (voidpf)0; in uncompress2()
51 err = inflateInit(&stream); in uncompress2()
54 stream in uncompress2()
[all...]
/third_party/skia/third_party/externals/freetype/src/base/
H A Dftsystem.c160 /* system-specific stream handle from a given FreeType stream object */
161 #define STREAM_FILE( stream ) ( (FT_FILE*)stream->descriptor.pointer )
170 * The function to close a stream.
173 * stream ::
174 * A pointer to the stream object.
177 ft_ansi_stream_close( FT_Stream stream ) in ft_ansi_stream_close()
179 ft_fclose( STREAM_FILE( stream ) ); in ft_ansi_stream_close()
181 stream in ft_ansi_stream_close()
214 ft_ansi_stream_io( FT_Stream stream, unsigned long offset, unsigned char* buffer, unsigned long count ) ft_ansi_stream_io() argument
[all...]
/third_party/skia/third_party/externals/freetype/builds/vms/
H A Dftsystem.c178 /* system-specific stream handle from a given FreeType stream object */
179 #define STREAM_FILE( stream ) ( (FILE*)stream->descriptor.pointer )
188 /* The function to close a stream. */
191 /* stream :: A pointer to the stream object. */
194 ft_close_stream( FT_Stream stream ) in ft_close_stream()
196 munmap( (MUNMAP_ARG_CAST)stream->descriptor.pointer, stream in ft_close_stream()
[all...]
/third_party/ffmpeg/libavformat/
H A Dmpegenc.c74 /* stream info */
141 /* maximum bit rate of the multiplexed stream */ in put_system_header()
145 /* This header applies only to the video stream in put_system_header()
172 /* This header applies only to the audio stream in put_system_header()
185 * id (0xB9) video, maximum P-STD for stream 0xE0. (P-STD_buffer_bound_scale = 1) in put_system_header()
187 * id (0xBD) private stream 1 (audio other than MPEG and subpictures). (P-STD_buffer_bound_scale = 1) in put_system_header()
188 * id (0xBF) private stream 2, NAV packs, set to 2x1024. */ in put_system_header()
196 StreamInfo *stream = ctx->streams[i]->priv_data; in put_system_header() local
198 id = stream->id; in put_system_header()
199 if (id == 0xbd && stream in put_system_header()
239 StreamInfo *stream = ctx->streams[i]->priv_data; put_system_header() local
280 StreamInfo *stream; get_system_header_size() local
305 StreamInfo *stream; mpeg_mux_init() local
616 get_nb_frames(AVFormatContext *ctx, StreamInfo *stream, int len) get_nb_frames() argument
642 StreamInfo *stream = ctx->streams[stream_index]->priv_data; flush_packet() local
975 StreamInfo *stream = st->priv_data; remove_decoded_packets() local
1002 StreamInfo *stream; output_packet() local
1015 StreamInfo *stream = st->priv_data; output_packet() local
1051 StreamInfo *stream = st->priv_data; output_packet() local
1151 StreamInfo *stream = st->priv_data; mpeg_mux_write_packet() local
1241 StreamInfo *stream; mpeg_mux_end() local
1268 StreamInfo *stream = ctx->streams[i]->priv_data; mpeg_mux_deinit() local
[all...]
/third_party/node/test/pseudo-tty/
H A Dtest-tty-window-size.js24 const stream = WriteStream(1);
26 assert(stream instanceof WriteStream);
27 assert.strictEqual(stream.columns, undefined);
28 assert.strictEqual(stream.rows, undefined);
34 const stream = WriteStream(1);
36 stream.on('error', common.mustCall((err) => {
44 stream._refreshSize();
55 const stream = WriteStream(1);
57 stream.on('resize', common.mustCall(() => {
58 assert.strictEqual(stream
[all...]
/test/xts/acts/commonlibrary/thirdparty/musl/entry/src/main/cpp/
H A Dstdioextndk.cpp219 FILE *stream = fopen(path, mode); in FEof_unlocked() local
220 NAPI_ASSERT(env, stream != nullptr, "FEof_unlocked fopen Error"); in FEof_unlocked()
221 backParam = feof_unlocked(stream); in FEof_unlocked()
222 fclose(stream); in FEof_unlocked()
233 FILE *stream = fopen(path, mode); in FError_unlocked() local
234 NAPI_ASSERT(env, stream != nullptr, "FError_unlocked fopen Error"); in FError_unlocked()
236 if (stream != nullptr) { in FError_unlocked()
237 fileDescribe = ferror_unlocked(stream); in FError_unlocked()
240 fclose(stream); in FError_unlocked()
249 FILE *stream in FFlush_unlocked() local
263 FILE *stream = fopen(path, mode); FGetC_unlocked() local
280 FILE *stream = fopen(path, mode); FGetLn() local
299 FILE *stream = fopen(path, mode); FGetS_unlocked() local
316 FILE *stream = fopen(path, mode); FileNo_unlocked() local
331 FILE *stream = fopen(path, mode); FClose() local
346 FILE *stream = fopen(path, mode); FMemOpen() local
366 FILE *stream = fopen(path, mode); FlockFile() local
382 FILE *stream = fopen(path, mode); FileNo() local
396 FILE *stream = fopen(path, mode); FError() local
412 FILE *stream = fopen(path, mode); FGets() local
430 FILE *stream = fopen(path, mode); FGetPos64() local
445 FILE *stream = fopen(path, mode); FGetPos() local
459 FILE *stream = fopen(path, mode); FGetC() local
475 FILE *stream = fopen(path, mode); FFlush() local
490 FILE *stream = fdopen(fileDescribe, mode); FdOpen() local
[all...]
/third_party/mbedtls/tests/scripts/
H A Dtest_generate_test_code.py334 stream = StringIOWrapper('test_suite_ut.function', data, line_no=0)
335 headers = parse_until_pattern(stream, END_HEADER_REGEX)
355 stream = StringIOWrapper('test_suite_ut.function', data,
357 headers = parse_until_pattern(stream, END_HEADER_REGEX)
371 stream = StringIOWrapper('test_suite_ut.function', data)
372 self.assertRaises(GeneratorInputError, parse_until_pattern, stream,
392 stream = StringIOWrapper('test_suite_ut.function', data)
393 dependencies = parse_suite_dependencies(stream)
404 stream = StringIOWrapper('test_suite_ut.function', data)
406 stream)
[all...]
/third_party/node/lib/internal/readline/
H A DemitKeypressEvents.js34 function emitKeypressEvents(stream, iface = {}) {
35 if (stream[KEYPRESS_DECODER]) return;
37 stream[KEYPRESS_DECODER] = new StringDecoder('utf8');
39 stream[ESCAPE_DECODER] = emitKeys(stream);
40 stream[ESCAPE_DECODER].next();
42 const triggerEscape = () => stream[ESCAPE_DECODER].next('');
47 if (stream.listenerCount('keypress') > 0) {
48 const string = stream[KEYPRESS_DECODER].write(input);
64 stream[ESCAPE_DECODE
[all...]
/third_party/skia/third_party/externals/piex/src/
H A Dpiex.cc82 const std::uint32_t number_of_ifds, StreamInterface* stream, in GetPreviewData()
93 TiffParser tiff_parser(stream, tiff_offset); in GetPreviewData()
99 // Returns false if the stream does not contain any TIFF structure. in GetPreviewData()
106 const std::uint32_t number_of_ifds, StreamInterface* stream, in GetPreviewData()
110 return GetPreviewData(extended_tags, kTiffOffset, number_of_ifds, stream, in GetPreviewData()
114 bool GetExifData(const std::uint32_t exif_offset, StreamInterface* stream, in GetExifData() argument
119 return GetPreviewData(kExtendedTags, exif_offset, kNumberOfIfds, stream, in GetExifData()
125 StreamInterface* stream, in GetThumbnailOffsetAndLength()
132 if (GetPreviewData(desired_tags, kNumberOfIfds, stream, &thumbnail_data)) { in GetThumbnailOffsetAndLength()
137 bool GetExifIfd(const Endian endian, StreamInterface* stream, in GetExifIfd() argument
80 GetPreviewData(const TagSet& extended_tags, const std::uint32_t tiff_offset, const std::uint32_t number_of_ifds, StreamInterface* stream, TiffContent* tiff_content, PreviewImageData* preview_image_data) GetPreviewData() argument
105 GetPreviewData(const TagSet& extended_tags, const std::uint32_t number_of_ifds, StreamInterface* stream, PreviewImageData* preview_image_data) GetPreviewData() argument
124 GetThumbnailOffsetAndLength(const TagSet& extended_tags, StreamInterface* stream, PreviewImageData* preview_image_data) GetThumbnailOffsetAndLength() argument
162 GetMakernoteIfd(const TiffDirectory& exif_ifd, const Endian endian, const std::uint32_t skip_offset, StreamInterface* stream, std::uint32_t* makernote_offset, TiffDirectory* makernote_ifd) GetMakernoteIfd() argument
180 GetCameraSettingsIfd(const TiffDirectory& makernote_ifd, const std::uint32_t makernote_offset, const Endian endian, StreamInterface* stream, TiffDirectory* camera_settings_ifd) GetCameraSettingsIfd() argument
203 GetRawProcessingIfd(const TagSet& desired_tags, const TiffDirectory& makernote_ifd, const std::uint32_t makernote_offset, const Endian endian, StreamInterface* stream, TiffDirectory* raw_processing_ifd) GetRawProcessingIfd() argument
229 GetOlympusPreviewImage(StreamInterface* stream, PreviewImageData* preview_image_data) GetOlympusPreviewImage() argument
301 PefGetColorSpace(StreamInterface* stream, PreviewImageData* preview_image_data) PefGetColorSpace() argument
332 RafGetOrientation(StreamInterface* stream, std::uint32_t* orientation) RafGetOrientation() argument
346 RafGetDimension(StreamInterface* stream, std::uint32_t* width, std::uint32_t* height) RafGetDimension() argument
381 ArwGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) ArwGetPreviewData() argument
387 GetThumbnailOffsetAndLength(TagSet(), stream, preview_image_data); ArwGetPreviewData() local
397 Cr2GetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) Cr2GetPreviewData() argument
402 GetThumbnailOffsetAndLength(TagSet(), stream, preview_image_data); Cr2GetPreviewData() local
412 DngGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) DngGetPreviewData() argument
471 NefGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) NefGetPreviewData() argument
485 GetThumbnailOffsetAndLength(TagSet(), stream, &thumbnail_data); NefGetPreviewData() local
520 OrfGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) OrfGetPreviewData() argument
530 PefGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) PefGetPreviewData() argument
543 GetThumbnailOffsetAndLength(TagSet(), stream, &thumbnail_data); PefGetPreviewData() local
549 RafGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) RafGetPreviewData() argument
581 Rw2GetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) Rw2GetPreviewData() argument
613 SrwGetPreviewData(StreamInterface* stream, PreviewImageData* preview_image_data) SrwGetPreviewData() argument
[all...]
/third_party/skia/src/core/
H A DSkFontStream.cpp40 static bool read(SkStream* stream, void* buffer, size_t amount) { in read() argument
41 return stream->read(buffer, amount) == amount; in read()
44 static bool skip(SkStream* stream, size_t amount) { in skip() argument
45 return stream->skip(amount) == amount; in skip()
51 table headers (SkSFNTDirEntry), relative to the start of the stream.
55 static int count_tables(SkStream* stream, int ttcIndex, size_t* offsetToDir) { in count_tables() argument
61 if (!read(stream, header, sizeof(SkSharedTTHeader))) { in count_tables()
65 // by default, SkSFNTHeader is at the start of the stream in count_tables()
77 stream->rewind(); in count_tables()
80 if (!read(stream, heade in count_tables()
139 CountTTCEntries(SkStream* stream) CountTTCEntries() argument
156 GetTableTags(SkStream* stream, int ttcIndex, SkFontTableTag tags[]) GetTableTags() argument
171 GetTableData(SkStream* stream, int ttcIndex, SkFontTableTag tag, size_t offset, size_t length, void* data) GetTableData() argument
[all...]
/third_party/node/lib/internal/webstreams/
H A Dtransformstream.js289 stream,
293 } = stream[kState];
326 stream: this[kState].stream,
349 stream,
360 return transformStreamDefaultSinkWriteAlgorithm(stream, chunk);
363 return transformStreamDefaultSinkAbortAlgorithm(stream, reason);
366 return transformStreamDefaultSinkCloseAlgorithm(stream);
377 return transformStreamDefaultSourcePullAlgorithm(stream);
380 transformStreamErrorWritableAndUnblockWrite(stream, reaso
[all...]

Completed in 11 milliseconds

12345678910>>...100