deblan-mirror/reaction
1
0
Fork 0
mirror of https://framagit.org/ppom/reaction synced 2026-03-14 12:45:47 +01:00
Code Issues Projects Releases Packages Wiki Activity

WIP

Browse source
This commit is contained in:
ppom 2026-01-23 12:00:00 +01:00
commit b606d34e26
No known key found for this signature in database
3 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
plugins/reaction-plugin-cluster/src/cluster.rs
View file

@ -25,7 +25,7 @@ pub fn transport_config() -> TransportConfig {
// FIXME higher timeouts and keep alive
let mut transport = TransportConfig::default();
transport
.max_idle_timeout(Some(Duration::from_millis(2000).try_into().unwrap()))
.max_idle_timeout(Some(Duration::from_millis(5000).try_into().unwrap()))
.keep_alive_interval(Some(Duration::from_millis(200)));
transport
}

1
plugins/reaction-plugin-cluster/src/connection.rs
View file

@ -332,6 +332,7 @@ impl ConnectionManager {
let _ = cancel.send(()).await;
}
// Why is at zero sometimes?
let last_connection_id = self.last_connection_id;
let mut insert_connection = |own_connection: OwnConnection| {
if self

7
plugins/reaction-plugin-cluster/src/tests/e2e.rs
View file

@ -3,7 +3,10 @@ use std::{env::set_current_dir, time::Duration};
use assert_fs::TempDir;
use reaction_plugin::{ActionImpl, Exec, PluginInfo, StreamImpl};
use serde_json::json;
use tokio::{fs, time::timeout};
use tokio::{
fs,
time::{sleep, timeout},
};
use treedb::time::now;
use crate::{
@ -258,6 +261,8 @@ async fn n_nodes_simultaneous_startup() {
actions.push((action, name));
}
sleep(Duration::from_millis(100 * n as u64)).await;
for m in ["test1", "test2", "test3", "test4", "test5"] {
let time = now().into();
for (i, (action, from)) in actions.iter().enumerate() {