| /external/llvm-project/lldb/third_party/Python/module/pexpect-4.6/pexpect/ |
| D | expect.py | 6 def __init__(self, spawn, searcher, searchwindowsize=-1): argument
7 self.spawn = spawn
10 searchwindowsize = spawn.searchwindowsize
14 spawn = self.spawn
17 pos = spawn._buffer.tell()
18 spawn._buffer.write(data)
19 spawn._before.write(data)
24 spawn._buffer.seek(max(0, pos - self.searchwindowsize))
25 window = spawn._buffer.read(self.searchwindowsize + len(data))
28 window = spawn.buffer
[all …]
|
| D | _async.py | 10 previously_read = expecter.spawn.buffer
11 expecter.spawn._buffer = expecter.spawn.buffer_type()
12 expecter.spawn._before = expecter.spawn.buffer_type()
16 if not expecter.spawn.async_pw_transport:
20 .connect_read_pipe(lambda: pw, expecter.spawn)
21 expecter.spawn.async_pw_transport = pw, transport
23 pw, transport = expecter.spawn.async_pw_transport
54 spawn = self.expecter.spawn
55 s = spawn._decoder.decode(data)
56 spawn._log(s, 'read')
[all …]
|
| /external/rust/crates/futures-executor/tests/ |
| D | local_pool.rs | 45 let spawn = pool.spawner(); in run_until_ignores_spawned() localVariable
46 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in run_until_ignores_spawned()
54 let spawn = pool.spawner(); in run_until_executes_spawned() localVariable
55 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_until_executes_spawned()
74 let spawn = pool.spawner(); in run_executes_spawned() localVariable
77 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_executes_spawned()
96 let spawn = pool.spawner(); in run_spawn_many() localVariable
100 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_spawn_many()
123 let spawn = pool.spawner(); in try_run_one_executes_one_ready() localVariable
126 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in try_run_one_executes_one_ready()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | fs_file_mocked.rs | 81 let mut t = task::spawn(file.read(&mut buf)); in open_read()
107 let mut t = task::spawn(file.read(&mut buf)); in read_twice_before_dispatch()
130 let mut t = task::spawn(file.read(&mut buf)); in read_with_smaller_buf()
138 let mut t = task::spawn(file.read(&mut buf)); in read_with_smaller_buf()
146 let mut t = task::spawn(file.read(&mut buf)); in read_with_smaller_buf()
163 let mut t = task::spawn(file.read(&mut buf)); in read_with_bigger_buf()
171 let mut t = task::spawn(file.read(&mut buf)); in read_with_bigger_buf()
179 let mut t = task::spawn(file.read(&mut buf)); in read_with_bigger_buf()
204 let mut t = task::spawn(file.read(&mut buf)); in read_err_then_read_success()
214 let mut t = task::spawn(file.read(&mut buf)); in read_err_then_read_success()
[all …]
|
| D | sync_rwlock.rs | 11 use tokio_test::task::spawn;
25 let mut t1 = spawn(rwlock.read()); in read_shared()
27 let mut t2 = spawn(rwlock.read()); in read_shared()
35 let mut t1 = spawn(rwlock.read()); in write_shared_pending()
38 let mut t2 = spawn(rwlock.write()); in write_shared_pending()
46 let mut t1 = spawn(rwlock.write()); in read_exclusive_pending()
49 let mut t2 = spawn(rwlock.read()); in read_exclusive_pending()
60 let mut t = spawn(rwlock.read()); in exhaust_reading()
67 let mut t1 = spawn(rwlock.read()); in exhaust_reading()
79 let mut t1 = spawn(rwlock.write()); in write_exclusive_pending()
[all …]
|
| D | sync_watch.rs | 6 use tokio_test::task::spawn;
15 let mut t = spawn(rx.changed()); in single_rx_recv()
21 let mut t = spawn(rx.changed()); in single_rx_recv()
33 let mut t = spawn(rx.changed()); in single_rx_recv()
50 let mut t1 = spawn(rx1.changed()); in multi_rx()
51 let mut t2 = spawn(rx2.changed()); in multi_rx()
59 let mut t2 = spawn(rx2.changed()); in multi_rx()
62 let mut t1 = spawn(rx1.changed()); in multi_rx()
77 let mut t1 = spawn(rx1.changed()); in multi_rx()
96 let mut t1 = spawn(rx1.changed()); in multi_rx()
[all …]
|
| D | sync_notify.rs | 5 use tokio_test::task::spawn;
14 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one()
23 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify()
35 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify()
36 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify()
55 let mut notified1 = spawn(async { notify.notified().await }); in notify_notified_multi()
56 let mut notified2 = spawn(async { notify.notified().await }); in notify_notified_multi()
70 let mut notified1 = spawn(async { notify.notified().await }); in notified_drop_notified_notify()
71 let mut notified2 = spawn(async { notify.notified().await }); in notified_drop_notified_notify()
87 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify_drop_one()
[all …]
|
| D | sync_barrier.rs | 7 use tokio_test::task::spawn;
22 let mut w = spawn(b.wait()); in zero_does_not_block()
27 let mut w = spawn(b.wait()); in zero_does_not_block()
38 let mut w = spawn(b.wait()); in single()
43 let mut w = spawn(b.wait()); in single()
48 let mut w = spawn(b.wait()); in single()
58 let mut w1 = spawn(b.wait()); in tango()
61 let mut w2 = spawn(b.wait()); in tango()
76 let mut w = spawn(b.wait()); in lots()
85 let mut w = spawn(b.wait()); in lots()
|
| D | rt_common.rs | 93 thread::spawn(move || {
111 tokio::spawn(async move {
128 let handle = tokio::spawn(async move {
152 tokio::spawn(async move {
156 tokio::spawn(async move {
183 tokio::spawn(async move {
195 thread::spawn(move || {
226 tokio::spawn(async move {
242 tokio::spawn(async move {
254 thread::spawn(move || {
[all …]
|
| D | sync_oneshot.rs | 31 let mut rx = task::spawn(rx); in send_recv()
54 let mut rx = task::spawn(rx); in close_tx()
75 let mut tx = task::spawn(tx); in close_rx()
92 tokio::spawn(async move { in async_rx_closed()
103 let mut rx = task::spawn(rx); in explicit_close_poll()
114 let mut tx = task::spawn(tx); in explicit_close_poll()
115 let mut rx = task::spawn(rx); in explicit_close_poll()
130 let mut tx = task::spawn(tx); in explicit_close_poll()
131 let mut rx = task::spawn(rx); in explicit_close_poll()
158 let mut tx = task::spawn(tx); in explicit_close_try_recv()
[all …]
|
| D | rt_threaded.rs | 42 rt.spawn(async move { in many_oneshot_futures()
75 rt.spawn(async move { in many_multishot_futures()
89 rt.spawn(async move { in many_multishot_futures()
127 tokio::spawn(client_server(tx.clone())); in spawn_shutdown()
131 rt.spawn(client_server(tx)); in spawn_shutdown()
147 tokio::spawn(async move { in client_server()
201 rt.spawn(Never(num_drop.clone())); in drop_threadpool_drops_futures()
242 rt.spawn(async move { in start_stop_callbacks_called()
270 rt.spawn(async move { in blocking()
283 rt.spawn(async move { in blocking()
[all …]
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | zero.rs | 45 scope.spawn(|_| s.send(0).unwrap()); in len_empty_full()
46 scope.spawn(|_| r.recv().unwrap()); in len_empty_full()
63 scope.spawn(move |_| { in try_recv()
70 scope.spawn(move |_| { in try_recv()
83 scope.spawn(move |_| { in recv()
91 scope.spawn(move |_| { in recv()
106 scope.spawn(move |_| { in recv_timeout()
114 scope.spawn(move |_| { in recv_timeout()
127 scope.spawn(move |_| { in try_send()
134 scope.spawn(move |_| { in try_send()
[all …]
|
| D | array.rs | 85 scope.spawn(move |_| { in try_recv()
92 scope.spawn(move |_| { in try_recv()
105 scope.spawn(move |_| { in recv()
113 scope.spawn(move |_| { in recv()
128 scope.spawn(move |_| { in recv_timeout()
136 scope.spawn(move |_| { in recv_timeout()
149 scope.spawn(move |_| { in try_send()
157 scope.spawn(move |_| { in try_send()
172 scope.spawn(|_| { in send()
181 scope.spawn(|_| { in send()
[all …]
|
| D | mpsc.rs | 237 let t = thread::spawn(move || { in smoke_threads()
270 let t = thread::spawn(move || { in port_gone_concurrent()
281 let t = thread::spawn(move || { in port_gone_concurrent_shared()
307 let t = thread::spawn(move || { in chan_gone_concurrent()
318 let t = thread::spawn(move || { in stress()
335 let t = thread::spawn(move || { in stress_shared()
348 let t = thread::spawn(move || { in stress_shared()
366 let t1 = thread::spawn(move || { in send_from_outside_runtime()
373 let t2 = thread::spawn(move || { in send_from_outside_runtime()
385 let t = thread::spawn(move || { in recv_from_outside_runtime()
[all …]
|
| D | list.rs | 74 scope.spawn(move |_| { in try_recv()
81 scope.spawn(move |_| { in try_recv()
94 scope.spawn(move |_| { in recv()
102 scope.spawn(move |_| { in recv()
117 scope.spawn(move |_| { in recv_timeout()
125 scope.spawn(move |_| { in recv_timeout()
229 scope.spawn(move |_| { in disconnect_wakes_receiver()
232 scope.spawn(move |_| { in disconnect_wakes_receiver()
247 scope.spawn(move |_| { in spsc()
253 scope.spawn(move |_| { in spsc()
[all …]
|
| D | select_macro.rs | 64 scope.spawn(|_| { in disconnected()
87 scope.spawn(|_| { in disconnected()
142 scope.spawn(|_| { in timeout()
164 scope.spawn(move |_| { in timeout()
236 scope.spawn(|_| { in unblocks()
250 scope.spawn(|_| { in unblocks()
270 scope.spawn(|_| { in both_ready()
296 scope.spawn(|_| loop { in loop_try()
308 scope.spawn(|_| loop { in loop_try()
320 scope.spawn(|_| { in loop_try()
[all …]
|
| /external/rust/crates/crossbeam-utils/tests/ |
| D | thread.rs | 17 let handle = scope.spawn(|_| { in join()
22 let panic_handle = scope.spawn(|_| { in join()
38 scope.spawn(|_| { in counter()
57 .spawn(|_| { in counter_builder()
74 scope.spawn(|_| { in counter_panic()
80 scope.spawn(|_| { in counter_panic()
95 scope.spawn(|_| { in panic_twice()
99 scope.spawn(|_| { in panic_twice()
121 scope.spawn(|_| panic!("deliberate panic #1")); in panic_many()
122 scope.spawn(|_| panic!("deliberate panic #2")); in panic_many()
[all …]
|
| /external/rust/crates/rayon-core/src/scope/ |
| D | test.rs | 27 s.spawn(move |_| { in scope_two()
30 s.spawn(move |_| { in scope_two()
42 scope(|s| s.spawn(move |s| divide_and_conquer(s, counter_p, 1024))); in scope_divide_and_conquer()
54 scope.spawn(move |scope| divide_and_conquer(scope, counter, size / 2)); in divide_and_conquer()
55 scope.spawn(move |scope| divide_and_conquer(scope, counter, size / 2)); in divide_and_conquer()
101 scope.spawn(move |scope| { in update_in_scope()
103 scope.spawn(move |scope| child.update_in_scope(op, scope)); in update_in_scope()
187 s.spawn(move |s| the_final_countdown(s, bottom_of_stack, max, n - 1)); in the_final_countdown()
200 scope(|s| s.spawn(|_| panic!("Hello, world!"))); in panic_propagate_spawn()
206 scope(|s| s.spawn(|s| s.spawn(|s| s.spawn(|_| panic!("Hello, world!"))))); in panic_propagate_nested_spawn()
[all …]
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_pool.rs | 10 use crate::{spawn, task};
40 pool.spawn(track(async { in racy_shutdown()
43 pool.spawn(track(async {})); in racy_shutdown()
60 pool.spawn(track(async move { in pool_multi_spawn()
61 spawn(track(async move { in pool_multi_spawn()
69 pool.spawn(track(async move { in pool_multi_spawn()
70 spawn(track(async move { in pool_multi_spawn()
86 pool.spawn(track(async move { in only_blocking_inner()
124 pool.spawn(track(async move { in blocking_and_regular_inner()
137 pool.spawn(track(async move { in blocking_and_regular_inner()
[all …]
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | semaphore_batch.rs | 10 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_one_available()
20 assert_ready_ok!(task::spawn(s.acquire(5)).poll()); in poll_acquire_many_available()
23 assert_ready_ok!(task::spawn(s.acquire(5)).poll()); in poll_acquire_many_available()
56 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_one_unavailable()
59 let mut acquire_2 = task::spawn(s.acquire(1)); in poll_acquire_one_unavailable()
80 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_many_unavailable()
84 let mut acquire_2 = task::spawn(s.acquire(5)); in poll_acquire_many_unavailable()
89 let mut acquire_3 = task::spawn(s.acquire(3)); in poll_acquire_many_unavailable()
159 let mut acquire = task::spawn(s.acquire(1)); in poll_acquire_one_zero_permits()
182 assert_ready_err!(task::spawn(s.acquire(1)).poll()); in close_semaphore_prevents_acquire()
[all …]
|
| D | loom_mpsc.rs | 14 thread::spawn(move || { in closing_tx()
32 thread::spawn(move || { in closing_unbounded_tx()
50 thread::spawn(move || { in closing_bounded_rx()
66 let th1 = thread::spawn(move || { in closing_and_sending()
70 let th2 = thread::spawn(move || { in closing_and_sending()
74 let th3 = thread::spawn(move || { in closing_and_sending()
91 thread::spawn(move || { in closing_unbounded_rx()
107 thread::spawn(move || { in dropping_tx()
125 thread::spawn(move || { in dropping_unbounded_tx()
|
| D | loom_broadcast.rs | 16 let th1 = thread::spawn(move || { in broadcast_send()
24 let th2 = thread::spawn(move || { in broadcast_send()
56 let th1 = thread::spawn(move || { in broadcast_two()
71 let th2 = thread::spawn(move || { in broadcast_two()
101 let th1 = thread::spawn(move || { in broadcast_wrap()
117 let th2 = thread::spawn(move || { in broadcast_wrap()
150 let th1 = thread::spawn(move || { in drop_rx()
168 let th2 = thread::spawn(move || { in drop_rx()
191 let th1 = thread::spawn(move || { in drop_multiple_rx_with_overflow()
200 let th2 = thread::spawn(move || { in drop_multiple_rx_with_overflow()
|
| /external/rust/crates/rayon-core/src/spawn/ |
| D | test.rs | 6 use super::{spawn, spawn_fifo};
13 spawn(move || tx.send(22).unwrap()); in spawn_then_join_in_worker()
21 spawn(move || tx.send(22).unwrap()); in spawn_then_join_outside_worker()
48 .spawn(move || panic!("Hello, world!")); in panic_fwd()
65 thread_pool.spawn(move || { in termination_while_things_are_executing()
71 spawn(move || { in termination_while_things_are_executing()
96 builder.build().unwrap().spawn(move || { in custom_panic_handler_and_spawn()
124 builder.build().unwrap().spawn(move || { in custom_panic_handler_and_nested_spawn()
128 spawn(move || { in custom_panic_handler_and_nested_spawn()
170 let vec = test_order!(spawn, spawn); in lifo_order()
[all …]
|
| /external/rust/crates/parking_lot/src/ |
| D | deadlock.rs | 74 let _t1 = thread::spawn(move || { in test_mutex_deadlock()
80 let _t2 = thread::spawn(move || { in test_mutex_deadlock()
86 let _t3 = thread::spawn(move || { in test_mutex_deadlock()
109 let _t1 = thread::spawn(move || { in test_mutex_deadlock_reentrant()
138 let _t1 = thread::spawn(move || { in test_remutex_deadlock()
145 let _t2 = thread::spawn(move || { in test_remutex_deadlock()
152 let _t3 = thread::spawn(move || { in test_remutex_deadlock()
186 let _t1 = thread::spawn(move || { in test_rwlock_deadlock()
192 let _t2 = thread::spawn(move || { in test_rwlock_deadlock()
198 let _t3 = thread::spawn(move || { in test_rwlock_deadlock()
[all …]
|
| /external/rust/crates/crossbeam-channel/benches/ |
| D | crossbeam.rs | 47 scope.spawn(|_| { in par_inout()
79 scope.spawn(|_| { in spsc()
110 scope.spawn(|_| { in spmc()
146 scope.spawn(|_| { in mpsc()
182 scope.spawn(|_| { in mpmc()
192 scope.spawn(|_| { in mpmc()
227 scope.spawn(|_| { in spsc()
258 scope.spawn(|_| { in spmc()
294 scope.spawn(|_| { in mpsc()
330 scope.spawn(|_| { in par_inout()
[all …]
|