From 116974f8112f6ea11a893272f6a9d41efeaae2fd Mon Sep 17 00:00:00 2001 From: Kitaiti Makoto Date: Thu, 5 May 2022 16:29:52 +0900 Subject: [PATCH] Add comment about broadcast capacity --- plume-common/src/activity_pub/mod.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/plume-common/src/activity_pub/mod.rs b/plume-common/src/activity_pub/mod.rs index 68b98c83..50662d0c 100644 --- a/plume-common/src/activity_pub/mod.rs +++ b/plume-common/src/activity_pub/mod.rs @@ -146,6 +146,9 @@ where .build() .expect("Error while initializing tokio runtime for federation"); rt.block_on(async { + // TODO: should be determined dependent on database connections because + // after broadcasting, target instance sends request to this instance, + // and Plume accesses database at that time. let capacity = 6; let (tx, rx) = flume::bounded::(capacity); let mut handles = Vec::with_capacity(capacity);