Ecosystem/serai
Ecosystem/serai
1
0
Fork 0
mirror of https://github.com/serai-dex/serai.git synced 2025-01-22 10:44:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Move where we create the readers to prevent only creating readers for present-at-boot tributaries

Browse source 
Also renames publish_transaction to publish_signed_transaction.
This commit is contained in:
Luke Parker 2023-09-25 18:07:26 -04:00
parent 0440e60645
commit 62a1a45135
No known key found for this signature in database
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
coordinator/src/main.rs
View file

@ -300,12 +300,12 @@ pub async fn heartbeat_tributaries<D: Db, P: P2p>(
let ten_blocks_of_time =
Duration::from_secs((10 * Tributary::<D, Transaction, P>::block_time()).into());
let mut readers = vec![];
for tributary in tributaries.read().await.values() {
readers.push(tributary.tributary.read().await.reader());
}
loop {
let mut readers = vec![];
for tributary in tributaries.read().await.values() {
readers.push(tributary.tributary.read().await.reader());
}
for tributary in &readers {
let tip = tributary.tip();
let block_time =
@ -454,7 +454,7 @@ pub async fn handle_p2p<D: Db, P: P2p>(
}
}
pub async fn publish_transaction<D: Db, P: P2p>(
pub async fn publish_signed_transaction<D: Db, P: P2p>(
tributary: &Tributary<D, Transaction, P>,
tx: Transaction,
) {
@ -473,7 +473,7 @@ pub async fn publish_transaction<D: Db, P: P2p>(
assert!(tributary.add_transaction(tx).await, "created an invalid transaction");
}
} else {
panic!("non-signed transaction passed to publish_transaction");
panic!("non-signed transaction passed to publish_signed_transaction");
}
}
@ -781,7 +781,7 @@ pub async fn handle_processors<D: Db, Pro: Processors, P: P2p>(
};
tx.sign(&mut OsRng, genesis, &key, nonce);
publish_transaction(&tributary, tx).await;
publish_signed_transaction(&tributary, tx).await;
}
}
}
@ -867,7 +867,7 @@ pub async fn run<D: Db, Pro: Processors, P: P2p>(
panic!("tributary we don't have came to consensus on an Batch");
};
let tributary = tributary.tributary.read().await;
publish_transaction(&tributary, tx).await;
publish_signed_transaction(&tributary, tx).await;
}
}
};