Home
last modified time | relevance | path

Searched refs:highWaterMark (Results 1 - 25 of 79) sorted by relevance

1234

/third_party/node/lib/internal/webstreams/
H A Dqueuingstrategies.js46 * highWaterMark : number,
75 * highWaterMark : number
80 if (init.highWaterMark === undefined)
81 throw new ERR_MISSING_OPTION('init.highWaterMark');
83 // The highWaterMark value is not checked until the strategy
86 highWaterMark: +init.highWaterMark,
94 get highWaterMark() {
97 return this[kState].highWaterMark;
111 highWaterMark
85 highWaterMark: +init.highWaterMark, global() property
140 highWaterMark: +init.highWaterMark, global() property
[all...]
H A Dadapters.js124 const highWaterMark = streamWritable.writableHighWaterMark;
127 new CountQueuingStrategy({ highWaterMark }) :
128 { highWaterMark };
209 * highWaterMark? : number,
225 highWaterMark,
238 highWaterMark,
407 const highWaterMark = streamReadable.readableHighWaterMark;
417 return new CountQueuingStrategy({ highWaterMark });
421 // back to a minimal strategy that just specifies the highWaterMark
424 return { highWaterMark };
[all...]
/third_party/node/test/parallel/
H A Dtest-stream-transform-split-highwatermark.js11 assert.strictEqual(t._readableState.highWaterMark, expectedReadableHwm);
12 assert.strictEqual(t._writableState.highWaterMark, expectedWritableHwm);
23 // Test highWaterMark overriding
25 highWaterMark: 555,
29 highWaterMark: 555,
33 highWaterMark: 555,
42 testTransform(666, DEFAULT, { highWaterMark: v, readableHighWaterMark: 666 });
43 testTransform(DEFAULT, 777, { highWaterMark: v, writableHighWaterMark: 777 });
70 assert.strictEqual(r._readableState.highWaterMark, DEFAULT);
72 assert.strictEqual(w._writableState.highWaterMark, DEFAUL
[all...]
H A Dtest-https-hwm.js3 // Test https highWaterMark
15 function loadCallback(highWaterMark) {
17 assert.strictEqual(highWaterMark, res.readableHighWaterMark);
20 `highWaterMark = ${res.readableHighWaterMark}`);
46 highWaterMark: 128000,
55 highWaterMark: 0,
64 highWaterMark: undefined,
H A Dtest-stream-transform-split-objectmode.js35 parser._readableState.highWaterMark);
37 parser._writableState.highWaterMark);
63 parser._readableState.highWaterMark);
65 parser._writableState.highWaterMark);
H A Dtest-stream2-readable-wrap.js28 function runTest(highWaterMark, objectMode, produce) {
31 const r = new Readable({ highWaterMark, objectMode });
73 const w = new Writable({ highWaterMark: highWaterMark * 2,
H A Dtest-http-server-options-highwatermark.js25 highWaterMark: getDefaultHighWaterMark() * 2,
27 assert.strictEqual(req._readableState.highWaterMark, getDefaultHighWaterMark() * 2);
39 assert.strictEqual(req._readableState.highWaterMark, getDefaultHighWaterMark());
H A Dtest-stream-readable-event.js32 highWaterMark: 3
52 highWaterMark: 3
69 // the highWaterMark but *has* reached EOF.
71 highWaterMark: 30
H A Dtest-stream2-writable.js53 highWaterMark: 100
71 highWaterMark: 100
92 highWaterMark: 50
126 highWaterMark: 100
158 highWaterMark: 100,
207 highWaterMark: 100
H A Dtest-stream-readable-unshift.js133 const highWaterMark = 50;
136 super({ highWaterMark });
138 this.buffer = new Array(highWaterMark * 2).fill(0).map(String);
H A Dtest-http2-backpressure.js20 req._readableState.highWaterMark = 20;
21 stream._writableState.highWaterMark = 20;
H A Dtest-whatwg-readablestream.js180 new ReadableStream(source, { highWaterMark: 10 });
203 ['a', {}].forEach((highWaterMark) => {
205 new ReadableStream({}, { highWaterMark });
211 new ReadableStream({ type: 'bytes' }, { highWaterMark });
217 [-1, NaN].forEach((highWaterMark) => {
219 new ReadableStream({}, { highWaterMark });
225 new ReadableStream({ type: 'bytes' }, { highWaterMark });
232 new ReadableStream({}, new ByteLengthQueuingStrategy({ highWaterMark: 1 }));
233 new ReadableStream({}, new CountQueuingStrategy({ highWaterMark: 1 }));
237 const strategy = new ByteLengthQueuingStrategy({ highWaterMark
[all...]
/third_party/node/benchmark/fs/
H A Dread-stream-throughput.js17 highWaterMark: [1024, 4096, 65535, 1024 * 1024],
22 const { encodingType, highWaterMark, filesize } = conf;
59 ws.on('close', runTest.bind(null, filesize, highWaterMark, encoding, n));
71 function runTest(filesize, highWaterMark, encoding, n) {
74 highWaterMark,
/third_party/node/lib/internal/streams/
H A Doperators.js86 let highWaterMark = concurrency - 1;
87 if (options?.highWaterMark != null) {
88 highWaterMark = MathFloor(options.highWaterMark);
92 validateInteger(highWaterMark, 'options.highWaterMark', 0);
94 highWaterMark += concurrency;
122 queue.length < highWaterMark
162 if (!done && (queue.length >= highWaterMark || cnt >= concurrency)) {
H A Dstate.js15 return options.highWaterMark != null ? options.highWaterMark :
36 const name = isDuplex ? `options.${duplexKey}` : 'options.highWaterMark';
H A Dtransform.js96 highWaterMark: null,
188 rState.length < rState.highWaterMark
H A Dreadable.js175 this.highWaterMark = options ?
274 // This returns true if the highWaterMark has not been hit yet,
349 // We can push more data if we are below the highWaterMark.
353 (state.length < state.highWaterMark || state.length === 0);
459 if (n > state.highWaterMark)
460 state.highWaterMark = computeNewHighWaterMark(n);
470 ((state.highWaterMark !== 0 ?
471 state.length >= state.highWaterMark :
517 // If we currently have less than the highWaterMark, then also read some.
518 if (state.length === 0 || state.length - n < state.highWaterMark) {
[all...]
/third_party/icu/icu4j/main/classes/core/src/com/ibm/icu/text/
H A DNFRuleSet.java759 ParsePosition highWaterMark = new ParsePosition(0); in parse()
776 if (parsePosition.getIndex() > highWaterMark.getIndex()) { in parse()
778 highWaterMark.setIndex(parsePosition.getIndex()); in parse()
781 // if (parsePosition.getErrorIndex() > highWaterMark.getErrorIndex()) { in parse()
782 // highWaterMark.setErrorIndex(parsePosition.getErrorIndex()); in parse()
797 for (int i = rules.length - 1; i >= 0 && highWaterMark.getIndex() < text.length(); i--) { in parse()
803 if (parsePosition.getIndex() > highWaterMark.getIndex()) { in parse()
805 highWaterMark.setIndex(parsePosition.getIndex()); in parse()
808 // if (parsePosition.getErrorIndex() > highWaterMark.getErrorIndex()) { in parse()
809 // highWaterMark in parse()
[all...]
/third_party/icu/ohos_icu4j/src/main/java/ohos/global/icu/text/
H A DNFRuleSet.java760 ParsePosition highWaterMark = new ParsePosition(0); in parse()
777 if (parsePosition.getIndex() > highWaterMark.getIndex()) { in parse()
779 highWaterMark.setIndex(parsePosition.getIndex()); in parse()
782 // if (parsePosition.getErrorIndex() > highWaterMark.getErrorIndex()) { in parse()
783 // highWaterMark.setErrorIndex(parsePosition.getErrorIndex()); in parse()
798 for (int i = rules.length - 1; i >= 0 && highWaterMark.getIndex() < text.length(); i--) { in parse()
804 if (parsePosition.getIndex() > highWaterMark.getIndex()) { in parse()
806 highWaterMark.setIndex(parsePosition.getIndex()); in parse()
809 // if (parsePosition.getErrorIndex() > highWaterMark.getErrorIndex()) { in parse()
810 // highWaterMark in parse()
[all...]
/third_party/node/test/fixtures/wpt/streams/transform-streams/
H A Dproperties.any.js30 }, undefined, { highWaterMark: Infinity });
44 const ts = new TransformStream(new Transformer(), undefined, { highWaterMark: Infinity });
/third_party/node/deps/undici/src/node_modules/@fastify/busboy/lib/
H A Dmain.js61 highWaterMark: this.opts.highWaterMark,
/third_party/node/deps/undici/src/node_modules/@fastify/busboy/lib/types/
H A Dmultipart.js37 const fileOpts = { highWaterMark: cfg.fileHwm }
81 partHwm: fileOpts.highWaterMark,
82 highWaterMark: cfg.highWaterMark
/third_party/icu/icu4c/source/i18n/
H A Dnfrs.cpp697 ParsePosition highWaterMark; in parse() local
716 if (success && (workingPos.getIndex() > highWaterMark.getIndex())) { in parse()
718 highWaterMark = workingPos; in parse()
726 fprintf(stderr, "' hwm: %d\n", highWaterMark.getIndex()); in parse()
749 for (int32_t i = rules.size(); --i >= 0 && highWaterMark.getIndex() < text.length();) { in parse()
755 if (success && workingPos.getIndex() > highWaterMark.getIndex()) { in parse()
757 highWaterMark = workingPos; in parse()
768 pos = highWaterMark; in parse()
/third_party/node/deps/icu-small/source/i18n/
H A Dnfrs.cpp697 ParsePosition highWaterMark; in parse() local
716 if (success && (workingPos.getIndex() > highWaterMark.getIndex())) { in parse()
718 highWaterMark = workingPos; in parse()
726 fprintf(stderr, "' hwm: %d\n", highWaterMark.getIndex()); in parse()
749 for (int32_t i = rules.size(); --i >= 0 && highWaterMark.getIndex() < text.length();) { in parse()
755 if (success && workingPos.getIndex() > highWaterMark.getIndex()) { in parse()
757 highWaterMark = workingPos; in parse()
768 pos = highWaterMark; in parse()
/third_party/skia/third_party/externals/icu/source/i18n/
H A Dnfrs.cpp697 ParsePosition highWaterMark; in parse() local
716 if (success && (workingPos.getIndex() > highWaterMark.getIndex())) { in parse()
718 highWaterMark = workingPos; in parse()
726 fprintf(stderr, "' hwm: %d\n", highWaterMark.getIndex()); in parse()
749 for (int32_t i = rules.size(); --i >= 0 && highWaterMark.getIndex() < text.length();) { in parse()
755 if (success && workingPos.getIndex() > highWaterMark.getIndex()) { in parse()
757 highWaterMark = workingPos; in parse()
768 pos = highWaterMark; in parse()

Completed in 14 milliseconds

1234