Searched refs:semaphore (Results 1 – 1 of 1) sorted by relevance
36 semaphore: Semaphore, field56 semaphore: Semaphore::new(QUEUE_BYTES_LIMIT), in new()72 let permits = self.semaphore.acquire_many(user_data_len as u32).await; in push()106 .semaphore in append()122 let permits = self.semaphore.acquire_many(user_data_len as u32).await; in append_large()244 self.semaphore.add_permits(user_data_len); in pop()