X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fpersistence.rs;h=e2d9eb0dd170ab44b0849cf5e9af80f97e16d781;hb=cf326fd7a9f42c58a24788943745f066ecb5f641;hp=22abf0216d8575692a1e3e7f9b7d4ce66844df66;hpb=2cf9129a187a66cfed10f9583c14fc8ee7339a18;p=rapid-gossip-sync-server diff --git a/src/persistence.rs b/src/persistence.rs index 22abf02..e2d9eb0 100644 --- a/src/persistence.rs +++ b/src/persistence.rs @@ -1,5 +1,6 @@ use std::fs::OpenOptions; use std::io::{BufWriter, Write}; +use std::ops::Deref; use std::sync::Arc; use std::time::{Duration, Instant}; use lightning::routing::gossip::NetworkGraph; @@ -13,13 +14,13 @@ use crate::types::GossipMessage; const POSTGRES_INSERT_TIMEOUT: Duration = Duration::from_secs(15); -pub(crate) struct GossipPersister { +pub(crate) struct GossipPersister where L::Target: Logger { gossip_persistence_receiver: mpsc::Receiver, - network_graph: Arc>>, + network_graph: Arc>, } -impl GossipPersister { - pub fn new(network_graph: Arc>>) -> (Self, mpsc::Sender) { +impl GossipPersister where L::Target: Logger { + pub fn new(network_graph: Arc>) -> (Self, mpsc::Sender) { let (gossip_persistence_sender, gossip_persistence_receiver) = mpsc::channel::(100); (GossipPersister {