Home
last modified time | relevance | path

Searched refs:rs (Results 1 – 25 of 1202) sorted by relevance

12345678910>>...49

/third_party/node/test/fixtures/wpt/streams/piping/
Dclose-propagation-forward.any.js11 const rs = recordingReadableStream({ constant
19 return rs.pipeTo(ws).then(value => {
23 assert_array_equals(rs.events, []);
27 rs.getReader().closed,
36 const rs = recordingReadableStream({ constant
48 …return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the same error')…
49 assert_array_equals(rs.events, []);
53 rs.getReader().closed,
65 const rs = recordingReadableStream({ constant
73 return rs.pipeTo(ws, { preventClose: falsy }).then(value => {
[all …]
Derror-propagation-forward.any.js14 const rs = recordingReadableStream({ constant
22 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the same error')
24 assert_array_equals(rs.events, []);
32 const rs = recordingReadableStream({ constant
44 …return promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the abort error')
46 assert_array_equals(rs.events, []);
57 const rs = recordingReadableStream({ constant
65 …return promise_rejects_exactly(t, error1, rs.pipeTo(ws, { preventAbort: falsy }), 'pipeTo must rej…
67 assert_array_equals(rs.events, []);
78 const rs = recordingReadableStream({ constant
[all …]
Derror-propagation-backward.any.js14 const rs = recordingReadableStream(); constant
22 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the same error')
24 assert_array_equals(rs.eventsWithoutPulls, ['cancel', error1]);
32 const rs = recordingReadableStream(); constant
47 …return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the write error')
49 assert_array_equals(rs.eventsWithoutPulls, ['cancel', error1]);
59 const rs = recordingReadableStream({ constant
78 …return promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the cancel error…
80 assert_array_equals(rs.eventsWithoutPulls, ['cancel', error1]);
93 const rs = recordingReadableStream(); constant
[all …]
Dmultiple-propagation.any.js31 const rs = recordingReadableStream({ constant
43 …return promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the writable str…
44 assert_array_equals(rs.events, []);
48 …promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored wit…
56 const rs = recordingReadableStream({ constant
63 ….then(ws => promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readabl…
65 assert_array_equals(rs.events, []);
67 …return promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be erro…
72 const rs = recordingReadableStream({ constant
83 return promise_rejects_exactly(t, error1, rs.pipeTo(ws, { preventAbort: true }),
[all …]
Dgeneral.any.js8 const rs = new ReadableStream(); constant
11 assert_false(rs.locked, 'sanity check: the ReadableStream must not start locked');
14 rs.pipeTo(ws);
16 assert_true(rs.locked, 'the ReadableStream must become locked');
23 const rs = new ReadableStream({ constant
30 return rs.pipeTo(ws).then(() => {
31 assert_false(rs.locked, 'the ReadableStream must become unlocked');
48 const rs = new ReadableStream(); constant
51 return methodRejects(t, ReadableStream.prototype, 'pipeTo', rs, [fakeWS]);
57 const rs = new ReadableStream(); constant
[all …]
Dpipe-through.any.js89 const rs = new ReadableStream(); constant
92 const result = rs.pipeThrough({ readable, writable });
108 const rs = new ReadableStream(); constant
112 () => rs.pipeThrough({
128 const rs = new ReadableStream({ constant
134 assert_throws_js(TypeError, () => rs.pipeThrough({
150 const rs = new ReadableStream({ constant
155 readable: rs,
161 () => ReadableStream.prototype.pipeThrough.call(rs, throwingWritable, {}),
171 () => ReadableStream.prototype.pipeThrough.call(rs, throwingReadable, {}),
[all …]
Dabort.any.js26 const rs = recordingReadableStream(errorOnPull, hwm0); constant
28 …return promise_rejects_js(t, TypeError, rs.pipeTo(ws, { signal: invalidSignal }), 'pipeTo should r…
30 assert_equals(rs.events.length, 0, 'no ReadableStream methods should have been called');
37 const rs = recordingReadableStream(errorOnPull, hwm0); constant
42 return promise_rejects_dom(t, 'AbortError', rs.pipeTo(ws, { signal }), 'pipeTo should reject')
44 rs.getReader().closed,
48 assert_equals(rs.events.length, 2, 'cancel should have been called');
49 assert_equals(rs.events[0], 'cancel', 'first event should be cancel');
50 … assert_equals(rs.events[1].name, 'AbortError', 'the argument to cancel should be an AbortError');
51 assert_equals(rs.events[1].constructor.name, 'DOMException',
[all …]
/third_party/libunwind/libunwind/src/aarch64/
DGstash_frame.c30 tdep_stash_frame (struct dwarf_cursor *d, struct dwarf_reg_state *rs) in tdep_stash_frame() argument
39 rs->reg.where[DWARF_CFA_REG_COLUMN], in tdep_stash_frame()
40 rs->reg.val[DWARF_CFA_REG_COLUMN], in tdep_stash_frame()
41 rs->reg.val[DWARF_CFA_OFF_COLUMN], in tdep_stash_frame()
42 DWARF_GET_LOC(d->loc[rs->ret_addr_column]), in tdep_stash_frame()
43 rs->reg.where[FP], rs->reg.val[FP], DWARF_GET_LOC(d->loc[FP]), in tdep_stash_frame()
44 rs->reg.where[LR], rs->reg.val[LR], DWARF_GET_LOC(d->loc[LR]), in tdep_stash_frame()
45 rs->reg.where[SP], rs->reg.val[SP], DWARF_GET_LOC(d->loc[SP])); in tdep_stash_frame()
54 && (rs->reg.where[DWARF_CFA_REG_COLUMN] == DWARF_WHERE_REG) in tdep_stash_frame()
55 && (rs->reg.val[DWARF_CFA_REG_COLUMN] == FP in tdep_stash_frame()
[all …]
/third_party/libunwind/libunwind/src/arm/
DGstash_frame.c30 tdep_stash_frame (struct dwarf_cursor *d, struct dwarf_reg_state *rs) in tdep_stash_frame() argument
39 rs->reg.where[DWARF_CFA_REG_COLUMN], in tdep_stash_frame()
40 rs->reg.val[DWARF_CFA_REG_COLUMN], in tdep_stash_frame()
41 rs->reg.val[DWARF_CFA_OFF_COLUMN], in tdep_stash_frame()
42 DWARF_GET_LOC(d->loc[rs->ret_addr_column]), in tdep_stash_frame()
43 rs->reg.where[R7], rs->reg.val[R7], DWARF_GET_LOC(d->loc[R7]), in tdep_stash_frame()
44 rs->reg.where[LR], rs->reg.val[LR], DWARF_GET_LOC(d->loc[LR]), in tdep_stash_frame()
45 rs->reg.where[SP], rs->reg.val[SP], DWARF_GET_LOC(d->loc[SP])); in tdep_stash_frame()
54 && (rs->reg.where[DWARF_CFA_REG_COLUMN] == DWARF_WHERE_REG) in tdep_stash_frame()
55 && (rs->reg.val[DWARF_CFA_REG_COLUMN] == R7 in tdep_stash_frame()
[all …]
/third_party/node/test/fixtures/wpt/streams/readable-streams/
Ddefault-reader.any.js22 const rs = new ReadableStream(); constant
23 new ReadableStreamDefaultReader(rs); // Constructing directly the first time should be fine.
24 assert_throws_js(TypeError, () => new ReadableStreamDefaultReader(rs),
32 const rs = new ReadableStream(); constant
33 new ReadableStreamDefaultReader(rs); // Constructing directly should be fine.
34 assert_throws_js(TypeError, () => rs.getReader(), 'getReader() should fail');
41 const rs = new ReadableStream(); constant
42 rs.getReader(); // getReader() should be fine.
43 …assert_throws_js(TypeError, () => new ReadableStreamDefaultReader(rs), 'constructing directly shou…
49 const rs = new ReadableStream(); constant
[all …]
Dtee.any.js10 const rs = new ReadableStream(); constant
11 const result = rs.tee();
22 const rs = new ReadableStream({ constant
30 const branch = rs.tee();
59 const rs = new ReadableStream({ constant
65 const branch = rs.tee();
80 const rs = new ReadableStream({ constant
90 const branches = rs.tee();
115 const rs = new ReadableStream({ constant
123 const branches = rs.tee();
[all …]
Dcancel.any.js11 const rs = new ReadableStream({ constant
34 const reader = rs.getReader();
44 return readableStreamToArray(rs, reader).then(chunks => {
59 const rs = new ReadableStream({ constant
66 rs.cancel(passedReason);
75 const rs = new ReadableStream({ constant
85 const reader = rs.getReader();
87 return rs.cancel().then(() => {
104 const rs = new ReadableStream({ constant
111 return rs.cancel(cancelReason).then(() => {
[all …]
/third_party/mesa3d/src/gallium/frontends/nine/
Dnine_pipe.c31 const DWORD *rs) in nine_convert_dsa_state() argument
37 if (rs[D3DRS_ZENABLE]) { in nine_convert_dsa_state()
39 dsa.depth_func = d3dcmpfunc_to_pipe_func(rs[D3DRS_ZFUNC]); in nine_convert_dsa_state()
41 dsa.depth_writemask = !!rs[D3DRS_ZWRITEENABLE] && in nine_convert_dsa_state()
46 if (rs[D3DRS_STENCILENABLE]) { in nine_convert_dsa_state()
48 dsa.stencil[0].func = d3dcmpfunc_to_pipe_func(rs[D3DRS_STENCILFUNC]); in nine_convert_dsa_state()
49 dsa.stencil[0].fail_op = d3dstencilop_to_pipe_stencil_op(rs[D3DRS_STENCILFAIL]); in nine_convert_dsa_state()
50 dsa.stencil[0].zpass_op = d3dstencilop_to_pipe_stencil_op(rs[D3DRS_STENCILPASS]); in nine_convert_dsa_state()
51 dsa.stencil[0].zfail_op = d3dstencilop_to_pipe_stencil_op(rs[D3DRS_STENCILZFAIL]); in nine_convert_dsa_state()
52 dsa.stencil[0].valuemask = rs[D3DRS_STENCILMASK]; in nine_convert_dsa_state()
[all …]
/third_party/node/deps/ngtcp2/ngtcp2/lib/
Dngtcp2_rst.c33 void ngtcp2_rs_init(ngtcp2_rs *rs) { in ngtcp2_rs_init() argument
34 rs->interval = UINT64_MAX; in ngtcp2_rs_init()
35 rs->delivered = 0; in ngtcp2_rs_init()
36 rs->prior_delivered = 0; in ngtcp2_rs_init()
37 rs->prior_ts = 0; in ngtcp2_rs_init()
38 rs->tx_in_flight = 0; in ngtcp2_rs_init()
39 rs->lost = 0; in ngtcp2_rs_init()
40 rs->prior_lost = 0; in ngtcp2_rs_init()
41 rs->send_elapsed = 0; in ngtcp2_rs_init()
42 rs->ack_elapsed = 0; in ngtcp2_rs_init()
[all …]
/third_party/libunwind/libunwind/src/x86_64/
DGstash_frame.c29 tdep_stash_frame (struct dwarf_cursor *d, struct dwarf_reg_state *rs) in tdep_stash_frame() argument
37 rs->reg.where[DWARF_CFA_REG_COLUMN], in tdep_stash_frame()
38 rs->reg.val[DWARF_CFA_REG_COLUMN], in tdep_stash_frame()
39 rs->reg.val[DWARF_CFA_OFF_COLUMN], in tdep_stash_frame()
40 DWARF_GET_LOC(d->loc[rs->ret_addr_column]), in tdep_stash_frame()
41 rs->reg.where[RBP], rs->reg.val[RBP], DWARF_GET_LOC(d->loc[RBP]), in tdep_stash_frame()
42 rs->reg.where[RSP], rs->reg.val[RSP], DWARF_GET_LOC(d->loc[RSP])); in tdep_stash_frame()
44 if (rs->reg.where[DWARF_CFA_REG_COLUMN] == DWARF_WHERE_EXPR && in tdep_stash_frame()
45 rs->reg.where[RBP] == DWARF_WHERE_EXPR) { in tdep_stash_frame()
49 unw_word_t cfa_addr = rs->reg.val[DWARF_CFA_REG_COLUMN]; in tdep_stash_frame()
[all …]
/third_party/rust/crates/clap/
DCHANGELOG.md354 See [Issue 2688](https://github.com/clap-rs/clap/issues/2688) for more background.
417 See [Issue 4132](https://github.com/clap-rs/clap/issues/4132) for more background.
451 0. [Upgrade to v3](https://github.com/clap-rs/clap/blob/v3-master/CHANGELOG.md#migrating) if you ha…
452 …h` and `--help` output at a minimum (recommendation: [trycmd](https://docs.rs/trycmd/) for snapsho…
601 …atures](https://github.com/clap-rs/clap/issues/1807) and [clarify relationship to the builder](htt…
1138 …detect external subcommands aliasing when escaped](https://github.com/clap-rs/clap/issues/3263) (#…
1185 **[StructOpt](https://docs.rs/structopt/) Integration**
1187 [StructOpt](https://docs.rs/structopt/) provides a serde-like declarative
1211 …precated in favor of the builder API with `arg!` ([clap-rs/clap#2835](https://github.com/clap-rs/c…
1212 …om_usage` has been deprecated in favor of `arg!` ([clap-rs/clap#3087](https://github.com/clap-rs/c…
[all …]
DCargo.toml16 "build.rs",
29 repository = "https://github.com/clap-rs/clap"
43 [package.metadata.docs.rs]
59 …rl -->", replace="<!-- next-url -->\n[Unreleased]: https://github.com/clap-rs/clap/compare/{{tag_n…
74 …oc = ["derive", "cargo", "wrap_help", "env", "unicode", "string", "unstable-replace"] # for docs.rs
159 path = "examples/multicall-busybox.rs"
163 path = "examples/multicall-hostname.rs"
167 path = "examples/repl.rs"
172 path = "examples/tutorial_builder/01_quick.rs"
177 path = "examples/tutorial_builder/02_apps.rs"
[all …]
/third_party/node/test/fixtures/wpt/streams/readable-byte-streams/
Dtee.any.js10 const rs = new ReadableStream({ type: 'bytes' }); constant
11 const result = rs.tee();
22 const rs = new ReadableStream({ constant
31 const [branch1, branch2] = rs.tee();
69 const rs = new ReadableStream({ constant
79 const [branch1, branch2] = rs.tee();
101 const rs = new ReadableStream({ constant
112 const [branch1, branch2] = rs.tee();
134 const rs = new ReadableStream({ constant
145 const [branch1, branch2] = rs.tee();
[all …]
/third_party/mesa3d/src/mesa/state_tracker/
Dst_cb_rasterpos.c141 struct rastpos_stage *rs = rastpos_stage(stage); in rastpos_point() local
142 struct gl_context *ctx = rs->ctx; in rastpos_point()
192 struct rastpos_stage *rs = CALLOC_STRUCT(rastpos_stage); in new_draw_rastpos_stage() local
194 rs->stage.draw = draw; in new_draw_rastpos_stage()
195 rs->stage.next = NULL; in new_draw_rastpos_stage()
196 rs->stage.point = rastpos_point; in new_draw_rastpos_stage()
197 rs->stage.line = rastpos_line; in new_draw_rastpos_stage()
198 rs->stage.tri = rastpos_tri; in new_draw_rastpos_stage()
199 rs->stage.flush = rastpos_flush; in new_draw_rastpos_stage()
200 rs->stage.destroy = rastpos_destroy; in new_draw_rastpos_stage()
[all …]
/third_party/mesa3d/src/amd/vulkan/radix_sort/
Dradix_sort_vk.c35 radix_sort_vk_get_memory_requirements(radix_sort_vk_t const * rs, in radix_sort_vk_get_memory_requirements() argument
42 mr->keyval_size = rs->config.keyval_dwords * sizeof(uint32_t); in radix_sort_vk_get_memory_requirements()
47 uint32_t const histo_sg_size = 1 << rs->config.histogram.subgroup_size_log2; in radix_sort_vk_get_memory_requirements()
48 uint32_t const histo_wg_size = 1 << rs->config.histogram.workgroup_size_log2; in radix_sort_vk_get_memory_requirements()
49 uint32_t const prefix_sg_size = 1 << rs->config.prefix.subgroup_size_log2; in radix_sort_vk_get_memory_requirements()
50 uint32_t const scatter_wg_size = 1 << rs->config.scatter.workgroup_size_log2; in radix_sort_vk_get_memory_requirements()
80 uint32_t const scatter_block_kvs = scatter_wg_size * rs->config.scatter.block_rows; in radix_sort_vk_get_memory_requirements()
90 uint32_t const histo_block_kvs = histo_wg_size * rs->config.histogram.block_rows; in radix_sort_vk_get_memory_requirements()
125 rs_debug_utils_set(VkDevice device, struct radix_sort_vk * rs) in rs_debug_utils_set() argument
135 duoni.objectHandle = (uint64_t)rs->pipelines.named.init; in rs_debug_utils_set()
[all …]
/third_party/node/test/parallel/
Dtest-webstreams-finished.js10 const rs = new ReadableStream({ constant
16 finished(rs, common.mustSucceed());
19 for await (const chunk of rs) {
28 const rs = new ReadableStream({ constant
34 finished(rs, common.mustCall((err) => {
40 const rs = new ReadableStream({ constant
46 finished(rs, common.mustCall((err) => {
52 const rs = new ReadableStream({ constant
61 for await (const chunk of rs) {
67 finishedPromise(rs).then(common.mustSucceed());
[all …]
Dtest-stream-finished.js20 const rs = new Readable({ constant
24 finished(rs, common.mustSucceed());
26 rs.push(null);
27 rs.resume();
70 const rs = fs.createReadStream(__filename); constant
72 rs.resume();
73 finished(rs, common.mustCall());
80 const rs = fs.createReadStream(__filename);
84 rs.resume();
85 rs.on('end', () => {
[all …]
/third_party/node/deps/v8/src/codegen/mips64/
Dmacro-assembler-mips64.cc338 void TurboAssembler::Addu(Register rd, Register rs, const Operand& rt) { in CallRecordWriteStub() argument
340 addu(rd, rs, rt.rm()); in CallRecordWriteStub()
343 addiu(rd, rs, static_cast<int32_t>(rt.immediate())); in CallRecordWriteStub()
348 DCHECK(rs != scratch); in CallRecordWriteStub()
350 addu(rd, rs, scratch); in CallRecordWriteStub()
355 void TurboAssembler::Daddu(Register rd, Register rs, const Operand& rt) { in CallRecordWriteStub() argument
357 daddu(rd, rs, rt.rm()); in CallRecordWriteStub()
360 daddiu(rd, rs, static_cast<int32_t>(rt.immediate())); in CallRecordWriteStub()
365 DCHECK(rs != scratch); in CallRecordWriteStub()
367 daddu(rd, rs, scratch); in CallRecordWriteStub()
[all …]
/third_party/rust/crates/nom/doc/
Dchoosing_a_combinator.md3 …er way to find a nom parser than reading through the documentation on docs.rs. Function combinator…
13 | [char](https://docs.rs/nom/latest/nom/character/complete/fn.char.html) | `char('a')` | `"abc"` |…
14 | [is_a](https://docs.rs/nom/latest/nom/bytes/complete/fn.is_a.html) | ` is_a("ab")` | `"ababc"` |…
15 | [is_not](https://docs.rs/nom/latest/nom/bytes/complete/fn.is_not.html) | `is_not("cd")` | `"abab…
16 | [one_of](https://docs.rs/nom/latest/nom/character/complete/fn.one_of.html) | `one_of("abc")` | `…
17 | [none_of](https://docs.rs/nom/latest/nom/character/complete/fn.none_of.html) | `none_of("abc")` |…
18 | [tag](https://docs.rs/nom/latest/nom/bytes/complete/fn.tag.html) | `tag("hello")` | `"hello worl…
19 | [tag_no_case](https://docs.rs/nom/latest/nom/bytes/complete/fn.tag_no_case.html) | `tag_no_case("…
20 | [take](https://docs.rs/nom/latest/nom/bytes/complete/fn.take.html) | `take(4)` | `"hello"` | `Ok…
21 | [take_while](https://docs.rs/nom/latest/nom/bytes/complete/fn.take_while.html) | `take_while(is_a…
[all …]
/third_party/openssl/crypto/
Dmips_arch.h26 # define dmultu(rs,rt) argument
27 # define mflo(rd,rs,rt) dmulu rd,rs,rt argument
28 # define mfhi(rd,rs,rt) dmuhu rd,rs,rt argument
30 # define multu(rs,rt) argument
31 # define mflo(rd,rs,rt) mulu rd,rs,rt argument
32 # define mfhi(rd,rs,rt) muhu rd,rs,rt argument
34 # define dmultu(rs,rt) dmultu rs,rt argument
35 # define multu(rs,rt) multu rs,rt argument
36 # define mflo(rd,rs,rt) mflo rd argument
37 # define mfhi(rd,rs,rt) mfhi rd argument

12345678910>>...49