Home
last modified time | relevance | path

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

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dsemaphore_inner.rs45 pub enum SemaphoreError { enum
54 impl Display for SemaphoreError { implementation
64 impl Error for SemaphoreError {} implementation
69 return Err(SemaphoreError::Overflow); in new()
121 return Err(SemaphoreError::Closed); in try_acquire()
125 return Err(SemaphoreError::Empty); in try_acquire()
162 ) -> Option<Poll<Result<(), SemaphoreError>>> { in update_permit() argument
184 ) -> Poll<Result<(), SemaphoreError>> { in poll_acquire() argument
187 return Ready(Err(SemaphoreError::Closed)); in poll_acquire()
195 return Ready(Err(SemaphoreError::Closed)); in poll_acquire()
[all …]
H A Dsemaphore.rs16 use crate::sync::semaphore_inner::{SemaphoreError, SemaphoreInner};
104 pub fn new(permits: usize) -> Result<Semaphore, SemaphoreError> { in new() argument
160 pub fn try_acquire(&self) -> Result<SemaphorePermit, SemaphoreError> { in try_acquire() argument
185 pub async fn acquire(&self) -> Result<SemaphorePermit, SemaphoreError> { in acquire() argument
235 pub fn new(number: usize) -> Result<AutoRelSemaphore, SemaphoreError> { in new() argument
275 pub fn try_acquire(&self) -> Result<AutoRelSemaphorePermit<'_>, SemaphoreError> { in try_acquire() argument
301 pub async fn acquire(&self) -> Result<AutoRelSemaphorePermit<'_>, SemaphoreError> { in acquire() argument
H A Dmod.rs31 pub use semaphore_inner::SemaphoreError;