/third_party/node/test/parallel/ |
H A D | test-stream2-basic.js | 50 if (!this.ended) 180 let ended = 0; 183 ended++; 184 assert.strictEqual(ended, 1); 189 ended++; 190 assert.strictEqual(ended, 2); 254 let ended = 0; 257 ended++; 258 assert.strictEqual(ended, 1); 263 ended [all...] |
H A D | test-stream-writableState-ending.js | 10 function testStates(ending, finished, ended) { 13 assert.strictEqual(writable._writableState.ended, ended); 17 // Ending, finished, ended start in false. 23 // Ending, finished, ended = true. 28 // Ending, finished, ended = true. 35 // Ending, ended = true.
|
H A D | test-stream-readable-reading-readingMore.js | 23 // Reading as long as we've not ended 24 assert.strictEqual(state.reading, !state.ended); 40 // If the stream has ended, we shouldn't be reading 41 assert.strictEqual(state.ended, !state.reading); 83 // Reading as long as we've not ended 84 assert.strictEqual(state.reading, !state.ended); 132 // Reading as long as we've not ended 133 assert.strictEqual(state.reading, !state.ended);
|
H A D | test-stream2-push.js | 44 let ended = false; 46 ended = true; 134 assert(ended);
|
H A D | test-stream-finished.js | 50 let ended = false; 53 ended = true; 62 assert(ended); 83 let ended = false; 86 ended = true; 89 assert(ended);
|
H A D | test-stream2-transform.js | 411 let ended = false; 413 ended = true; 427 assert.strictEqual(ended, true); 452 let ended = false; 454 ended = true; 468 assert.strictEqual(ended, true);
|
H A D | test-stream-pipeline.js | 1645 let ended = false; 1647 ended = true; 1655 assert.strictEqual(ended, true);
|
/third_party/node/lib/internal/streams/ |
H A D | utils.js | 120 if (typeof wState?.ended !== 'boolean') return null; 121 return wState.ended; 133 (strict === false && wState.ended === true && wState.length === 0) 143 if (typeof rState?.ended !== 'boolean') return null; 144 return rState.ended; 155 (strict === false && rState.ended === true && rState.length === 0)
|
H A D | readable.js | 118 ended: makeBitMapDescriptor(kEnded), 328 } else if (state.ended) { 352 return !state.ended && 430 if (n <= 0 || (state.length === 0 && state.ended)) 442 return state.ended ? state.length : 0; 473 state.ended)) { 474 debug('read: emitReadable', state.length, state.ended); 475 if (state.length === 0 && state.ended) 484 // If we've ended, and we're now clear, then finish it up. 485 if (n === 0 && state.ended) { [all...] |
H A D | pipeline.js | 413 let ended = false; 415 if (!ended) { 429 ended = true; 433 if (isReadableFinished(src)) { // End the destination if the source has already ended. 447 (rState && rState.ended && !rState.errored && !rState.errorEmitted) 451 // stream has been ended and no error emitted. This should be allowed in
|
H A D | duplex.js | 66 this._readableState.ended = true; 73 this._writableState.ended = true;
|
H A D | destroy.js | 166 r.ended = r.readable === false; 179 w.ended = w.writable === false;
|
H A D | duplexify.js | 47 this._readableState.ended = true; 54 this._writableState.ended = true;
|
H A D | transform.js | 186 wState.ended || // Backwards compat.
|
H A D | writable.js | 109 this.ended = false; 635 state.ended = true; 797 !w.ending && !w.ended;
|
/third_party/ffmpeg/doc/ |
H A D | texi2pod.pl | 158 my $ended = $1; 159 next if $skipping && $ended !~ /^(?:ifset|ifclear|ignore|menu|iftex|ifhtml|ifnothtml)$/; 161 die "\@end $ended without \@$ended at line $.\n" unless defined $endw; 162 die "\@$endw ended by \@end $ended at line $.\n" unless $ended eq $endw; 166 if ($ended =~ /^(?:ifset|ifclear|ignore|menu|iftex|ifhtml|ifnothtml)$/) { 169 } elsif ($ended =~ /^(?:example|smallexample|verbatim|display)$/) { 172 } elsif ($ended [all...] |
/third_party/node/benchmark/fs/ |
H A D | write-stream-throughput.js | 46 let ended = false; 53 ended = true; 77 if (!ended)
|
/third_party/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cancel/ |
H A D | stress.c | 89 static long long canceled, ended; variable 138 ended++; in threaded() 219 output(" - %llu threads ended\n", ended); in main()
|
/third_party/curl/tests/unit/ |
H A D | unit2600.c | 105 struct curltime ended; member 239 duration_ms = Curl_timediff(tr->ended, tr->started); in check_result() 261 duration_ms = Curl_timediff(tr->ended, tr->started); in check_result() 321 tr.ended = Curl_now(); in test_connect()
|
/third_party/curl/src/ |
H A D | tool_operate.c | 2375 struct per_transfer *ended; in parallel_transfers() local 2378 curl_easy_getinfo(easy, CURLINFO_PRIVATE, (void *)&ended); in parallel_transfers() 2381 if(ended->abort && (tres == CURLE_ABORTED_BY_CALLBACK) && in parallel_transfers() 2382 ended->errorbuffer) { in parallel_transfers() 2383 msnprintf(ended->errorbuffer, CURL_ERROR_SIZE, in parallel_transfers() 2387 tres = post_per_transfer(global, ended, tres, &retry, &delay); in parallel_transfers() 2388 progress_finalize(ended); /* before it goes away */ in parallel_transfers() 2392 ended->added = FALSE; /* add it again */ in parallel_transfers() 2394 ended->startat = delay ? time(NULL) + delay/1000 : 0; in parallel_transfers() 2399 if(tres && (!ended in parallel_transfers() [all...] |
/third_party/node/lib/internal/bootstrap/switches/ |
H A D | is_main_thread.js | 232 stdin._writableState.ended = true;
|
/third_party/node/lib/internal/test_runner/ |
H A D | harness.js | 59 'activity after the test ended. This activity created the error ' + 64 `the test ended. This activity created the error "${err}" which ` +
|
/third_party/node/deps/undici/src/lib/core/ |
H A D | util.js | 172 return state && state.objectMode === false && state.ended === true && Number.isFinite(state.length)
|
/third_party/node/deps/undici/src/lib/fetch/ |
H A D | index.js | 1869 if (fetchParams.controller.ended && !timingInfo.encodedBodySize) { 2098 fetchParams.controller.ended = true
|
/third_party/node/deps/v8/src/json/ |
H A D | json-stringifier.cc | 978 // preceded by a leading surrogate, we would've ended up in the other in SerializeStringUnchecked_() 1044 // been preceded by a leading surrogate, we would've ended up in the in SerializeString_()
|