We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 39be8c3 commit f7f4162Copy full SHA for f7f4162
crates/syn2mas/src/migration.rs
@@ -251,7 +251,8 @@ async fn migrate_users(
251
let start = Instant::now();
252
let otel_kv = [KeyValue::new(K_ENTITY, V_ENTITY_USERS)];
253
254
- let (tx, mut rx) = tokio::sync::mpsc::channel::<SynapseUser>(10 * 1024 * 1024);
+ // HACK(matrix.org): allocate a large buffer
255
+ let (tx, mut rx) = tokio::sync::mpsc::channel::<SynapseUser>(50 * 1024 * 1024);
256
257
// create a new RNG seeded from the passed RNG so that we can move it into the
258
// spawned task
0 commit comments