Home
last modified time | relevance | path

Searched refs:new_block (Results 1 – 1 of 1) sorted by relevance

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dqueue.rs130 new_block: Option<Box<Block<T>>>, in send_inner()
135 let new_block_ptr = Box::into_raw(new_block.unwrap()); in send_inner()
154 let mut new_block = None; in send() localVariable
165 if index + 1 == CAPACITY && new_block.is_none() { in send()
166 new_block = Some(Box::new(Block::<T>::new())); in send()
174 self.send_inner(index, block, new_block, value); in send()