| /external/rust/crates/tokio/src/runtime/task/ |
| D | core.rs | 171 pub(super) fn with_mut<R>(&self, f: impl FnOnce(*mut Stage<T>) -> R) -> R { in with_mut() method
172 self.stage.with_mut(f) in with_mut()
212 self.stage.stage.with_mut(|ptr| { in poll()
266 self.stage.stage.with_mut(|ptr| { in take_output()
277 self.stage.stage.with_mut(|ptr| *ptr = stage) in set_stage()
284 self.queue_next.with_mut(|ptr| *ptr = next);
294 self.owner_id.with_mut(|ptr| *ptr = owner); in set_owner_id()
362 self.waker.with_mut(|ptr| { in set_waker()
|
| D | harness.rs | 247 self.trailer().waker.with_mut(drop); in dealloc()
250 self.core().stage.with_mut(drop); in dealloc()
|
| D | list.rs | 269 self.inner.with_mut(|ptr| unsafe { f(&mut *ptr) }) in with_inner()
|
| /external/rust/crates/tokio/src/util/ |
| D | idle_notified_set.rs | 196 entry.my_list.with_mut(|ptr| unsafe { in pop_notified()
212 ptrs.push(entry.value.with_mut(|ptr| { in for_each()
277 .with_mut(|ptr| unsafe { (self.func)(ManuallyDrop::take(&mut *ptr)) }); in drain()
323 entry.my_list.with_mut(|ptr| { in move_to_new_list()
344 let old_my_list = self.entry.my_list.with_mut(|ptr| unsafe { in remove()
371 .with_mut(|ptr| unsafe { ManuallyDrop::take(&mut *ptr) }) in remove()
388 .with_mut(|ptr| unsafe { func(&mut *ptr, &mut context) }) in with_value_and_context()
412 let old_my_list = me.my_list.with_mut(|ptr| unsafe { in wake_by_ref()
|
| D | rc_cell.rs | 38 self.inner.with_mut(|ptr| f(&mut *ptr)) in with_inner()
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 203 old_waker = self.waker.with_mut(|t| (*t).take()); in do_register()
204 self.waker.with_mut(|t| *t = Some(new_waker)); in do_register()
237 let mut waker = self.waker.with_mut(|t| (*t).take()); in do_register()
320 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 | 980 data.with_mut(|shared| { in promotable_even_drop()
1011 data.with_mut(|shared| { in promotable_odd_drop()
1100 data.with_mut(|shared| { in shared_drop()
|
| D | bytes_mut.rs | 1742 data.with_mut(|shared| { in shared_v_drop()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | chan.rs | 227 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in close()
248 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in recv()
297 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in try_recv()
345 self.inner.rx_fields.with_mut(|rx_fields_ptr| { in drop()
373 self.rx_fields.with_mut(|rx_fields_ptr| { in drop()
|
| D | block.rs | 183 self.values[slot_offset].with_mut(|ptr| { in write()
228 .with_mut(|ptr| *ptr = tail_position); in tx_release()
|
| /external/rust/crates/tokio/src/sync/ |
| D | once_cell.rs | 109 .with_mut(|ptr| ptr::drop_in_place((*ptr).as_mut_ptr())); in drop()
205 &mut *self.value.with_mut(|ptr| (*ptr).as_mut_ptr()) in get_unchecked_mut()
211 self.value.with_mut(|ptr| (*ptr).as_mut_ptr().write(value)); in set_value()
|
| D | oneshot.rs | 418 self.0.with_mut(|ptr| { in drop_task()
425 self.0.with_mut(|ptr| { in set_task()
593 inner.value.with_mut(|ptr| unsafe { in send()
1216 self.value.with_mut(|ptr| (*ptr).take()) in consume_value()
1224 this.with_mut(|v| *v) in mut_load()
|
| D | broadcast.rs | 560 slot.rem.with_mut(|v| *v = rem); in send()
907 waiter.with_mut(|ptr| { in recv_ref()
1195 self.waiter.with_mut(|ptr| { in drop()
1249 self.slot.val.with_mut(|ptr| unsafe { *ptr = None }); in drop()
|
| D | batch_semaphore.rs | 232 let waker = unsafe { waiter.as_mut().waker.with_mut(|waker| (*waker).take()) }; in close()
307 unsafe { waiter.as_mut().waker.with_mut(|waker| (*waker).take()) } in add_permits_locked()
449 node.waker.with_mut(|waker| { in poll_acquire()
|
| /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/crossbeam-epoch/src/ |
| D | internal.rs | 362 let bag = self.bag.with_mut(|b| &mut *b); in defer()
371 let bag = self.bag.with_mut(|b| unsafe { &mut *b }); in flush()
516 .push_bag(self.bag.with_mut(|b| &mut *b), guard); in finalize()
|
| D | lib.rs | 120 pub(crate) fn with_mut<R>(&self, f: impl FnOnce(*mut T) -> R) -> R { in with_mut() method
|
| /external/rust/crates/tokio/src/task/ |
| D | local.rs | 1031 self.local_queue.with_mut(|ptr| (*ptr).pop_front()) in task_pop_front()
1039 self.local_queue.with_mut(|ptr| (*ptr).push_back(task)) in task_push_back()
1047 self.local_queue.with_mut(|ptr| std::mem::take(&mut (*ptr))) in take_local_queue()
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | queue.rs | 159 self.inner.buffer[idx].with_mut(|ptr| { in push_back()
451 .with_mut(|ptr| unsafe { ptr::write((*ptr).as_mut_ptr(), task) }); in steal_into2()
|
| /external/rust/crates/plotters/src/element/ |
| D | image.rs | 113 pub fn with_mut(pos: Coord, size: (u32, u32), buf: &'a mut [u8]) -> Option<Self> { in with_mut() method
|
| /external/rust/crates/tokio/src/runtime/time/ |
| D | entry.rs | 226 unsafe { self.result.with_mut(|p| *p = result) }; in fire()
|