Home
last modified time | relevance | path

Searched refs:reading (Results 1 - 25 of 57) sorted by relevance

123

/third_party/node/test/parallel/
H A Dtest-stream-readable-reading-readingMore.js14 assert.strictEqual(state.reading, false);
19 // we should not be reading more
24 assert.strictEqual(state.reading, !state.ended);
28 // End of stream; state.reading is false
31 assert.strictEqual(state.reading, false);
40 // If the stream has ended, we shouldn't be reading
41 assert.strictEqual(state.ended, !state.reading);
55 // reading
56 assert.strictEqual(state.reading, true);
74 assert.strictEqual(state.reading, fals
[all...]
H A Dtest-stream2-push.js60 let reading = false;
64 reading = true;
69 reading = false;
108 assert(reading);
110 assert(reading);
112 assert(reading);
114 assert(reading);
116 assert(!reading);
131 assert(!reading);
H A Dtest-stream-readable-event.js29 // First test, not reading when the readable is added.
42 assert(!r._readableState.reading);
49 // already a length, while it IS reading.
62 assert(r._readableState.reading);
68 // Third test, not reading when the stream has not passed
82 assert(!r._readableState.reading);
H A Dtest-fs-read.js82 /TypeError: Cannot read properties of null \(reading 'byteLength'\)/,
/third_party/node/lib/internal/streams/
H A Dfrom.js48 let reading = false;
51 if (!reading) {
52 reading = true;
96 reading = false;
101 reading = false;
H A Dpipeline.js50 function destroyer(stream, reading, writing) {
56 const cleanup = eos(stream, { readable: reading, writable: writing }, (err) => {
254 const reading = i < streams.length - 1;
256 const end = reading || opts?.end !== false;
261 const { destroy, cleanup } = destroyer(stream, reading, writing);
307 if (reading) {
455 // eos will only fail with premature close on the reading side for
H A Dreadable.js120 reading: makeBitMapDescriptor(kReading),
513 // if we need a readable event, then we need to do some reading.
524 // reading, then it's unnecessary, if we're constructing we have to wait,
526 if (state.ended || state.reading || state.destroyed || state.errored ||
529 debug('reading, ended or constructing', doRead);
545 // If _read pushed data synchronously, then `reading` will be false,
547 if (!state.reading)
653 // in turn another _read(n) call, in which case reading = true if
655 // However, if we're not ended, or reading, and the length < hwm,
667 // The conditions for reading mor
[all...]
/third_party/node/test/common/
H A Dudppair.js23 this.reading = false;
29 if (!this.reading) return;
39 this.reading = true;
44 this.reading = false;
58 if (!this.reading) {
/third_party/node/lib/internal/bootstrap/switches/
H A Dis_main_thread.js250 // not-reading state.
252 stdin._handle.reading = false;
253 stdin._readableState.reading = false;
257 // If the user calls stdin.pause(), then we need to stop reading
267 if (stdin._handle.reading && !stdin.readableFlowing) {
268 stdin._readableState.reading = false;
269 stdin._handle.reading = false;
/third_party/python/Modules/_io/
H A D_iomodule.c33 "separation between reading and writing to streams; implementations are\n"
36 "Extending IOBase is RawIOBase which deals simply with the reading and\n"
90 is opened. It defaults to 'r' which means open for reading in text
97 (For reading and writing raw bytes use binary mode and leave encoding
103 'r' open for reading (default)
109 '+' open a disk file for updating (reading and writing)
112 The default mode is 'rt' (open for reading text). For binary random
182 through which the standard file operations such as reading and writing
191 reading and writing. For strings StringIO can be used like a file
204 int creating = 0, reading in _io_open_impl()
203 int creating = 0, reading = 0, writing = 0, appending = 0, updating = 0; _io_open_impl() local
[all...]
/third_party/ltp/testcases/kernel/device-drivers/tbio/tbio_kernel/
H A Dltp_tbio.c123 int reading = 0, writing = 0; in tbio_io() local
146 reading = 1; in tbio_io()
151 inter.data_len, reading, GFP_KERNEL); in tbio_io()
290 int reading = 0, writing = 0; in test_bio_split() local
320 reading = 1; in test_bio_split()
325 inter.data_len, reading, GFP_KERNEL); in test_bio_split()
/third_party/openssl/demos/digest/
H A DBIO_f_md.c92 BIO *reading = BIO_push( bio_digest, input ); in main() local
94 while( BIO_read(reading, buffer, sizeof(buffer)) > 0 ) in main()
/third_party/zlib/contrib/pascal/
H A Dzlibpas.pas57 extra_max: Integer; (* space at extra (only when reading header) *)
59 name_max: Integer; (* space at name (only when reading header) *)
61 comm_max: Integer; (* space at comment (only when reading header) *)
63 done: Integer; (* true when done reading gzip header *)
/third_party/python/Lib/
H A Dsocket.py314 reading = "r" in mode or not writing
315 assert reading or writing
318 if reading:
332 if reading and writing:
334 elif reading:
475 *offset* tells from where to start reading the file.
732 """True if the SocketIO is open for reading.
/third_party/python/Lib/idlelib/
H A Dpyshell.py1026 reading = False variable in PyShell
1169 if not self.reading: # no nested mainloop to exit.
1175 save = self.reading
1177 self.reading = True
1180 self.reading = save
1206 if not (self.executing or self.reading):
1218 if self.reading:
1223 if self.executing and not self.reading:
1239 if self.reading:
1247 if self.executing and not self.reading
[all...]
/third_party/node/test/fixtures/wpt/streams/resources/
H A Drs-utils.js61 throw new Error('Can\'t pause reading an unstarted source.');
/third_party/node/deps/openssl/openssl/external/perl/Text-Template-1.56/t/
H A Dtaint.t82 open $fh, '<', $file or die "Couldn't open $file for reading: $!; aborting";
86 open $fh, '<', $file or die "Couldn't open $file for reading: $!; aborting";
/third_party/openssl/external/perl/Text-Template-1.56/t/
H A Dtaint.t82 open $fh, '<', $file or die "Couldn't open $file for reading: $!; aborting";
86 open $fh, '<', $file or die "Couldn't open $file for reading: $!; aborting";
/third_party/backends/backend/
H A Dxerox_mfp-usb.c88 if (dev->reading) in usb_dev_close()
H A Dxerox_mfp-tcp.c158 if (dev->reading) sane_read(dev, NULL, 1, NULL); in tcp_dev_close()
/third_party/protobuf/csharp/src/Google.Protobuf/
H A DCodedInputStream.cs92 /// Creates a new CodedInputStream reading data from the given byte array.
115 /// Creates a new <see cref="CodedInputStream"/> reading data from the given stream, which will be disposed
124 /// Creates a new <see cref="CodedInputStream"/> reading data from the given stream.
136 /// Creates a new CodedInputStream reading data from the given
154 /// Creates a new CodedInputStream reading data from the given
178 /// Creates a <see cref="CodedInputStream"/> with the specified size and recursion limits, reading
188 /// <param name="recursionLimit">The maximum recursion depth to allow while reading.</param>
189 /// <returns>A <c>CodedInputStream</c> reading from <paramref name="input"/> with the specified size
222 /// This limit is applied when reading from the underlying stream, as a sanity check. It is
223 /// not applied when reading fro
[all...]
/third_party/node/lib/
H A D_http_server.js747 // If we previously paused, then start reading again.
1039 // If the writable end isn't consuming, then stop reading
1157 if (this._handle && !this._handle.reading) {
1158 this._handle.reading = true;
1164 if (this._handle && this._handle.reading) {
1165 this._handle.reading = false;
/third_party/ltp/scripts/coccinelle/
H A Drun-spatch.sh78 -h You are reading it
/third_party/node/test/fixtures/wpt/streams/transform-streams/
H A Dlipfuzz.any.js152 assert_false(done, `done should be false when reading ${outputChunk}`);
/third_party/zlib/contrib/dotzlib/DotZLib/
H A DGZipStream.cs141 #region Basic reading and writing

Completed in 13 milliseconds

123