Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2024-12-23 03:59:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix typos
Some checks failed
Audit / audit (push) Has been cancelled
Details
Deny / audit (push) Has been cancelled
Details

Browse source
This commit is contained in:
Boog900 2024-06-21 02:40:14 +01:00
parent f4f1dc29e5
commit 0b7fcc19b8
No known key found for this signature in database
GPG key ID: 42AB1287CB0041C2
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
p2p/cuprate-p2p/src/block_downloader/block_queue.rs
View file

@ -68,7 +68,7 @@ impl BlockQueue {
self.ready_batches.peek().map(|batch| batch.start_height) self.ready_batches.peek().map(|batch| batch.start_height)
} }
/// Returns the size of all the batches that hav not been put into the [`async_buffer`] yet. /// Returns the size of all the batches that have not been put into the [`async_buffer`] yet.
pub fn size(&self) -> usize { pub fn size(&self) -> usize {
self.ready_batches_size self.ready_batches_size
} }
@ -125,7 +125,7 @@ mod tests {
use super::*; use super::*;
prop_compose! { prop_compose! {
fn read_batch_stratergy()(start_height in 0_u64..500_000_000) -> ReadyQueueBatch { fn ready_batch_strategy()(start_height in 0_u64..500_000_000) -> ReadyQueueBatch {
// TODO: The permit will not be needed here when // TODO: The permit will not be needed here when
let (_, peer_handle) = HandleBuilder::new().with_permit(Arc::new(Semaphore::new(1)).try_acquire_owned().unwrap()).build(); let (_, peer_handle) = HandleBuilder::new().with_permit(Arc::new(Semaphore::new(1)).try_acquire_owned().unwrap()).build();
@ -142,7 +142,7 @@ mod tests {
proptest! { proptest! {
#[test] #[test]
fn block_queue_returns_items_in_order(batches in vec(read_batch_stratergy(), 0..10_000)) { fn block_queue_returns_items_in_order(batches in vec(ready_batch_strategy(), 0..10_000)) {
block_on(async move { block_on(async move {
let (buffer_tx, mut buffer_rx) = async_buffer::new_buffer(usize::MAX); let (buffer_tx, mut buffer_rx) = async_buffer::new_buffer(usize::MAX);