| /external/rust/crates/tokio/src/runtime/task/ |
| D | core.rs | 120 pub(super) fn with_mut<R>(&self, f: impl FnOnce(*mut Option<S>) -> R) -> R { in with_mut() method
121 self.scheduler.with_mut(f) in with_mut()
147 self.scheduler.with_mut(|ptr| unsafe { in bind_scheduler()
206 pub(super) fn with_mut<R>(&self, f: impl FnOnce(*mut Stage<T>) -> R) -> R { in with_mut() method
207 self.stage.with_mut(f) in with_mut()
225 self.stage.with_mut(|ptr| { in poll()
278 self.stage.with_mut(|ptr| { in take_output()
288 self.stage.with_mut(|ptr| *ptr = stage) in set_stage()
302 self.queue_next.with_mut(|ptr| *ptr = next);
309 self.waker.with_mut(|ptr| { in set_waker()
|
| D | harness.rs | 94 self.trailer().waker.with_mut(drop); in dealloc()
97 self.core().stage.with_mut(drop); in dealloc()
98 self.core().scheduler.with_mut(drop); in dealloc()
|
| D | stack.rs | 36 .with_mut(|ptr| *ptr = NonNull::new(curr)) in push()
|
| D | mod.rs | 220 NonNull::from(target.as_ref().owned.with_mut(|ptr| &mut *ptr)) in pointers()
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 182 self.waker.with_mut(|t| *t = Some(waker.into_waker())); in do_register()
206 let waker = self.waker.with_mut(|t| (*t).take()).unwrap(); in do_register()
261 let waker = unsafe { self.waker.with_mut(|t| (*t).take()) }; in take_waker()
|
| /external/rust/crates/bytes/src/ |
| D | loom.rs | 7 fn with_mut<F, R>(&mut self, f: F) -> R in with_mut() method
13 fn with_mut<F, R>(&mut self, f: F) -> R in with_mut() method
|
| D | bytes.rs | 889 data.with_mut(|shared| { in promotable_even_drop()
916 data.with_mut(|shared| { in promotable_odd_drop()
964 data.with_mut(|shared| { in shared_drop()
|
| D | bytes_mut.rs | 1511 data.with_mut(|shared| { in shared_v_drop()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | chan.rs | 201 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in close()
222 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in recv()
274 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in drop()
302 self.rx_fields.with_mut(|rx_fields_ptr| { in drop()
|
| D | block.rs | 148 self.values[slot_offset].with_mut(|ptr| { in write()
192 .with_mut(|ptr| *ptr = tail_position); in tx_release()
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 206 self.0.with_mut(|ptr| { in drop_task()
213 self.0.with_mut(|ptr| { in set_task()
313 inner.value.with_mut(|ptr| unsafe { in send()
801 self.value.with_mut(|ptr| (*ptr).take()) in consume_value()
809 this.with_mut(|v| *v) in mut_load()
|
| D | once_cell.rs | 74 .with_mut(|ptr| ptr::drop_in_place((&mut *ptr).as_mut_ptr())); in drop()
132 &mut *self.value.with_mut(|ptr| (*ptr).as_mut_ptr()) in get_unchecked_mut()
138 self.value.with_mut(|ptr| (*ptr).as_mut_ptr().write(value)); in set_value()
|
| D | broadcast.rs | 621 slot.rem.with_mut(|v| *v = rem); in send2()
628 slot.val.with_mut(|ptr| unsafe { *ptr = value }); in send2()
739 waiter.with_mut(|ptr| { in recv_ref()
1012 self.waiter.with_mut(|ptr| { in drop()
1066 self.slot.val.with_mut(|ptr| unsafe { *ptr = None }); in drop()
|
| D | batch_semaphore.rs | 192 let waker = unsafe { waiter.as_mut().waker.with_mut(|waker| (*waker).take()) }; in close()
263 *slot = unsafe { waiter.as_mut().waker.with_mut(|waker| (*waker).take()) }; in add_permits_locked()
371 node.waker.with_mut(|waker| { in poll_acquire()
|
| /external/rust/crates/plotters/benches/benches/ |
| D | parallel.rs | 77 let mut e = BitMapElement::with_mut((0, 0), (s / 2, s / 2), b).unwrap(); in draw_func_4x4()
107 BitMapElement::with_mut((0, 0), (s / 2, s / 2), b).unwrap(); in draw_func_4x4()
138 BitMapElement::with_mut((0, 0), (s, s / 2), buf).unwrap(); in draw_func_2x1()
|
| /external/rust/crates/tokio/src/loom/std/ |
| D | unsafe_cell.rs | 13 pub(crate) fn with_mut<R>(&self, f: impl FnOnce(*mut T) -> R) -> R { in with_mut() method
|
| D | atomic_usize.rs | 29 pub(crate) fn with_mut<R>(&mut self, f: impl FnOnce(&mut usize) -> R) -> R { in with_mut() method
|
| /external/rust/crates/tokio/src/runtime/ |
| D | queue.rs | 144 self.inner.buffer[idx].with_mut(|ptr| { in push_back()
236 self.inner.buffer[i_idx].with_mut(|ptr| unsafe { in push_overflow()
415 .with_mut(|ptr| unsafe { ptr::write((*ptr).as_mut_ptr(), task) }); in steal_into2()
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | internal.rs | 438 let bag = self.bag.with_mut(|b| &mut *b); in defer()
447 let bag = self.bag.with_mut(|b| unsafe { &mut *b }); in flush()
589 .push_bag(self.bag.with_mut(|b| &mut *b), guard); in finalize()
|
| D | lib.rs | 134 pub(crate) fn with_mut<R>(&self, f: impl FnOnce(*mut T) -> R) -> R { in with_mut() method
|
| /external/rust/crates/plotters/src/element/ |
| D | image.rs | 107 pub fn with_mut(pos: Coord, size: (u32, u32), buf: &'a mut [u8]) -> Option<Self> { in with_mut() method
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | entry.rs | 220 unsafe { self.result.with_mut(|p| *p = result) }; in fire()
|