Searched refs:user_data_len (Results 1 – 1 of 1) sorted by relevance
68 let user_data_len = c.user_data.len(); in push() localVariable72 let permits = self.semaphore.acquire_many(user_data_len as u32).await; in push()85 self.n_bytes.fetch_add(user_data_len, Ordering::SeqCst); in push()121 let user_data_len = chunk.user_data.len(); in append_large() localVariable122 let permits = self.semaphore.acquire_many(user_data_len as u32).await; in append_large()133 self.n_bytes.fetch_add(user_data_len, Ordering::SeqCst); in append_large()241 let user_data_len = p.user_data.len(); in pop() localVariable242 self.n_bytes.fetch_sub(user_data_len, Ordering::SeqCst); in pop()244 self.semaphore.add_permits(user_data_len); in pop()