10x the channel sizes

Author: sandhose

crates/syn2mas/src/migration.rs

@@ -255,7 +255,7 @@ async fn migrate_users(
 ) -> Result<(MasWriter, MigrationMaps), Error> {
     let start = Instant::now();
 
-    let (tx, mut rx) = tokio::sync::mpsc::channel(1024 * 1024);
+    let (tx, mut rx) = tokio::sync::mpsc::channel(10 * 1024 * 1024);
 
     let mut rng = rand_chacha::ChaCha8Rng::from_rng(rng).expect("failed to seed rng");
     let server_name = server_name.to_owned();
@@ -527,7 +527,7 @@ async fn migrate_devices(
 ) -> Result<(MasWriter, MigrationMaps), Error> {
     let start = Instant::now();
 
-    let (tx, mut rx) = tokio::sync::mpsc::channel(1024 * 1024);
+    let (tx, mut rx) = tokio::sync::mpsc::channel(10 * 1024 * 1024);
 
     let server_name = server_name.to_owned();
     let mut rng = rand_chacha::ChaChaRng::from_rng(rng).expect("failed to seed rng");
@@ -653,7 +653,7 @@ async fn migrate_unrefreshable_access_tokens(
 ) -> Result<(MasWriter, MigrationMaps), Error> {
     let start = Instant::now();
 
-    let (tx, mut rx) = tokio::sync::mpsc::channel(1024 * 1024);
+    let (tx, mut rx) = tokio::sync::mpsc::channel(10 * 1024 * 1024);
 
     let now = clock.now();
     let server_name = server_name.to_owned();