use lightning::routing::gossip::NetworkGraph;
use lightning::util::logger::Logger;
use lightning::util::ser::Writeable;
+use tokio::runtime::Runtime;
use tokio::sync::{mpsc, Mutex, Semaphore};
use crate::config;
pub(crate) struct GossipPersister<L: Deref> where L::Target: Logger {
gossip_persistence_receiver: mpsc::Receiver<GossipMessage>,
network_graph: Arc<NetworkGraph<L>>,
+ tokio_runtime: Runtime,
logger: L
}
pub fn new(network_graph: Arc<NetworkGraph<L>>, logger: L) -> (Self, mpsc::Sender<GossipMessage>) {
let (gossip_persistence_sender, gossip_persistence_receiver) =
mpsc::channel::<GossipMessage>(100);
+ let runtime = Runtime::new().unwrap();
(GossipPersister {
gossip_persistence_receiver,
network_graph,
+ tokio_runtime: runtime,
logger
}, gossip_persistence_sender)
}
let mut announcement_signed = Vec::new();
announcement.write(&mut announcement_signed).unwrap();
- let _task = tokio::spawn(async move {
+ let _task = self.tokio_runtime.spawn(async move {
let client;
{
let mut connections_set = connections_cache_ref.lock().await;
// this may not be used outside test cfg
let _seen_timestamp = seen_override.unwrap_or(timestamp as u32) as f64;
- let _task = tokio::spawn(async move {
+ let _task = self.tokio_runtime.spawn(async move {
let client;
{
let mut connections_set = connections_cache_ref.lock().await;