mirrors/Plume
1
0
Fork 0
mirror of https://git.joinplu.me/Plume/Plume.git synced 2024-11-25 13:01:08 +00:00
Code Issues Projects Releases Packages Wiki Activity

Add comment about broadcast capacity

Browse source
This commit is contained in:
Kitaiti Makoto 2022-05-05 16:29:52 +09:00
parent 9def0355aa
commit 116974f811
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
plume-common/src/activity_pub/mod.rs
View file

@ -146,6 +146,9 @@ where
.build() .build()
.expect("Error while initializing tokio runtime for federation"); .expect("Error while initializing tokio runtime for federation");
rt.block_on(async { 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 capacity = 6;
let (tx, rx) = flume::bounded::<RequestBuilder>(capacity); let (tx, rx) = flume::bounded::<RequestBuilder>(capacity);
let mut handles = Vec::with_capacity(capacity); let mut handles = Vec::with_capacity(capacity);