Searched refs:try_lock (Results 1 – 5 of 5) sorted by relevance
40 .try_lock() in alloc()49 .try_lock() in alloc_zeroed()58 .try_lock() in realloc()67 .try_lock() in dealloc()138 fn try_lock(&self) -> Option<impl DerefMut<Target = T> + '_> { in try_lock() method
82 match self.0.try_lock() { in read()88 match self.0.try_lock() { in skip()96 match mutex.try_lock() { in cancel()180 match self.0.try_lock() { in check_write()186 match self.0.try_lock() { in write()192 match self.0.try_lock() { in flush()202 match mutex.try_lock() { in cancel()
215 self.try_lock()?.close(); in close()223 fn try_lock(&self) -> Result<tokio::sync::MutexGuard<'_, WriteState<IO>>, StreamError> { in try_lock() function225 .try_lock() in try_lock()241 self.try_lock()?.write(bytes) in write()245 self.try_lock()?.flush() in flush()249 self.try_lock()?.check_write() in check_write()
348 .try_lock() in try_lock_for_stream()353 mutex.try_lock().map_err(|_| { in try_lock_for_socket()
2684 let (mine, buffer) = producer.try_lock().ok()?.take()?; in new_transmit()2688 *producer.try_lock().ok()? = Some((mine, buffer)); in new_transmit()4779 fn try_lock(&self) -> Result<MutexGuard<'_, Option<T>>> { in try_lock() method4780 match self.inner.try_lock() { in try_lock()4793 let result = self.try_lock()?.take(); in take()4812 let mut inner = self.try_lock()?; in with()4852 if let Ok(mut lock) = self.state.try_lock() { in drop()