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

cluster: Fix use of stream timestamp in action

Browse source
This commit is contained in:
ppom 2025-12-24 12:00:00 +01:00
commit 7ede2fa79c
No known key found for this signature in database
1 changed files with 3 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -13,10 +13,7 @@ use iroh::{
use reaction_plugin::{Line, shutdown::ShutdownController};
use remoc::rch::mpsc as remocMpsc;
use tokio::sync::mpsc as tokioMpsc;
use treedb::{
Database,
time::{Time, now},
};
use treedb::{Database, time::Time};
use crate::{ActionInit, StreamInit, connection::ConnectionManager, endpoint::EndpointManager};
@ -135,14 +132,13 @@ impl ActionInit {
while let Ok(Some(m)) = self.rx.recv().await {
eprintln!("DEBUG action: received a message to send to connections");
let line = self.send.line(m.match_);
let now = now();
if self.self_
&& let Err(err) = own_stream_tx.send((line.clone(), now.into())).await
&& let Err(err) = own_stream_tx.send((line.clone(), m.time)).await
{
eprintln!("ERROR while queueing message to be sent to own cluster stream: {err}");
}
let line = (Arc::new(line), now);
let line = (Arc::new(line), m.time.into());
for result in join_all(nodes_tx.iter().map(|tx| tx.send(line.clone()))).await {
if let Err(err) = result {
eprintln!("ERROR while queueing message to be sent to cluster nodes: {err}");