From f8c97881036f0324e434f99a8664d25b50d29dbb Mon Sep 17 00:00:00 2001 From: Alexander Tesfamichael Date: Mon, 16 Oct 2023 14:38:45 +0200 Subject: [PATCH] feat(migrate-from-gcs): tune buffer sizes --- src/bin/migrate-from-gcs.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/bin/migrate-from-gcs.rs b/src/bin/migrate-from-gcs.rs index 1090678..b0bbae7 100644 --- a/src/bin/migrate-from-gcs.rs +++ b/src/bin/migrate-from-gcs.rs @@ -188,7 +188,7 @@ async fn main() -> anyhow::Result<()> { let payload_stream = gcs.get(&object_meta.location).await?.into_stream(); let reader = StreamReader::new(payload_stream); - const DECODED_BUFFER_SIZE: usize = 128; + const DECODED_BUFFER_SIZE: usize = 256; let (mut decoded_tx, mut decoded_rx) = channel(DECODED_BUFFER_SIZE); spawn_blocking(move || { @@ -229,7 +229,7 @@ async fn main() -> anyhow::Result<()> { } }); - const SLOT_BUNDLE_BUFFER_SIZE: usize = 32; + const SLOT_BUNDLE_BUFFER_SIZE: usize = 8; let (mut slot_bundle_tx, slot_bundle_rx) = channel(SLOT_BUNDLE_BUFFER_SIZE); spawn(async move {