| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/ |
| D | sync_mpsc_weak.rs | 26 let tx2 = tx_weak in weak_sender() localVariable
256 let tx2 = tx.clone(); in downgrade_upgrade_get_permit_no_senders() localVariable
287 let tx2 = tx_weak in weak_unbounded_sender() localVariable
537 let tx2 = tx.clone(); in sender_strong_count_when_cloned() localVariable
558 let tx2 = tx.clone(); in sender_strong_count_when_dropped() localVariable
582 let tx2 = tx.clone(); in sender_strong_and_weak_conut() localVariable
615 let tx2 = tx.clone(); in unbounded_sender_strong_count_when_cloned() localVariable
637 let tx2 = tx.clone(); in unbounded_sender_strong_count_when_dropped() localVariable
661 let tx2 = tx.clone(); in unbounded_sender_strong_and_weak_conut() localVariable
|
| D | sync_mpsc.rs | 78 let tx2 = tx.clone(); in reserve_disarm() localVariable
180 let tx2 = tx1.clone(); in start_send_past_cap() localVariable
473 let tx2 = tx1.clone(); in recv_close_gets_none_reserved() localVariable
730 let tx2 = tx1.clone(); in drop_permit_releases_permit() localVariable
749 let tx2 = tx1.clone(); in drop_permit_iterator_releases_permits() localVariable
891 let tx2 = tx1.clone(); in permit_available_not_acquired_close() localVariable
|
| D | sync_watch.rs | 341 let tx2 = tx1.clone(); in multiple_sender() localVariable
360 let tx2 = tx1.clone(); in receiver_is_notified_when_last_sender_is_dropped() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 266 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
284 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
302 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
951 let tx2 = tx.clone(); in destroy_upgraded_shared_port_when_sender_still_active() localVariable
1037 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
1055 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
1073 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
1600 let tx2 = tx.clone(); in destroy_upgraded_shared_port_when_sender_still_active() localVariable
1643 let tx2 = tx.clone(); in send4() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | sync_tests.rs | 72 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
89 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
106 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
603 let tx2 = tx.clone(); in send4() localVariable
|
| H A D | tests.rs | 70 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
87 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
104 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | sync_tests.rs | 72 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
89 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
106 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
603 let tx2 = tx.clone(); in send4() localVariable
|
| H A D | tests.rs | 70 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
87 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
104 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | sync_tests.rs | 72 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
89 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
106 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
603 let tx2 = tx.clone(); in send4() localVariable
|
| H A D | tests.rs | 70 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
87 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
104 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | sync_tests.rs | 72 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
89 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
106 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
603 let tx2 = tx.clone(); in send4() localVariable
|
| H A D | tests.rs | 70 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
87 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
104 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpsc/ |
| H A D | sync_tests.rs | 72 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
89 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
106 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
603 let tx2 = tx.clone(); in send4() localVariable
|
| H A D | tests.rs | 70 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
87 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
104 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/tests/ |
| D | loom_mpsc.rs | 49 let tx2 = tx1.clone(); in closing_bounded_rx() localVariable
64 let tx2 = tx1.clone(); in closing_and_sending() localVariable
90 let tx2 = tx1.clone(); in closing_unbounded_rx() localVariable
|
| D | loom_watch.rs | 46 let tx2 = tx_arc.clone(); in wait_for_test() localVariable
96 let tx2 = tx1.clone(); in multiple_sender_drop_concurrently() localVariable
|
| D | loom_broadcast.rs | 14 let tx2 = tx1.clone(); in broadcast_send() localVariable
190 let tx2 = tx.clone(); in drop_multiple_rx_with_overflow() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures/tests/ |
| D | future_basic_combinators.rs | 8 let tx2 = tx1.clone(); in basic_future_combinators() localVariable
37 let tx2 = tx1.clone(); in basic_try_future_combinators() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-channel/tests/ |
| D | mpsc-close.rs | 75 let mut tx2 = tx1.clone(); in multiple_senders_close_channel() localVariable
91 let mut tx2 = tx1.clone(); in multiple_senders_close_channel() localVariable
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/ |
| D | powerd_suspend_manager.rs | 230 let tx2 = self.tx.clone(); in init() localVariable
252 let tx2 = self.tx.clone(); in init() localVariable
276 let tx2 = self.tx.clone(); in init() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/parking_lot/src/ |
| D | fair_mutex.rs | 139 let tx2 = tx.clone(); in lots_and_lots() localVariable
145 let tx2 = tx.clone(); in lots_and_lots() localVariable
|
| D | mutex.rs | 153 let tx2 = tx.clone(); in lots_and_lots() localVariable
159 let tx2 = tx.clone(); in lots_and_lots() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/net/udp/ |
| H A D | tests.rs | 106 let tx2 = tx1.clone(); in udp_clone_two_read() localVariable
151 let tx2 = tx.clone(); in udp_clone_two_write() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/net/udp/ |
| H A D | tests.rs | 106 let tx2 = tx1.clone(); in udp_clone_two_read() localVariable
151 let tx2 = tx.clone(); in udp_clone_two_write() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/net/udp/ |
| H A D | tests.rs | 106 let tx2 = tx1.clone(); in udp_clone_two_read() localVariable
151 let tx2 = tx.clone(); in udp_clone_two_write() localVariable
|