X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;ds=sidebyside;f=lightning%2Fsrc%2Futil%2Fpersist.rs;h=849854a6a910b217b598e0067289bcc7497cb409;hb=66f2f2cf10217efef61a6cc1504c90f17120bf2e;hp=da55c38164516aa75468f7d841cdb720a61d9ac9;hpb=12fa0b11a669050bc3e0e081bea0523baa1598ff;p=rust-lightning diff --git a/lightning/src/util/persist.rs b/lightning/src/util/persist.rs index da55c381..849854a6 100644 --- a/lightning/src/util/persist.rs +++ b/lightning/src/util/persist.rs @@ -10,8 +10,8 @@ use core::ops::Deref; use bitcoin::hashes::hex::ToHex; -use io::{self}; -use routing::scoring::WriteableScore; +use crate::io::{self}; +use crate::routing::scoring::WriteableScore; use crate::{chain::{keysinterface::{Sign, KeysInterface}, self, transaction::{OutPoint}, chaininterface::{BroadcasterInterface, FeeEstimator}, chainmonitor::{Persist, MonitorUpdateId}, channelmonitor::{ChannelMonitor, ChannelMonitorUpdate}}, ln::channelmanager::ChannelManager, routing::gossip::NetworkGraph}; use super::{logger::Logger, ser::Writeable}; @@ -20,6 +20,7 @@ use super::{logger::Logger, ser::Writeable}; /// Implementing `KVStorePersister` provides auto-implementations for [`Persister`] /// and [`Persist`] traits. It uses "manager", "network_graph", /// and "monitors/{funding_txo_id}_{funding_txo_index}" for keys. +/// (C-not exported) pub trait KVStorePersister { /// Persist the given writeable using the provided key fn persist(&self, key: &str, object: &W) -> io::Result<()>; @@ -69,8 +70,8 @@ impl<'a, A: KVStorePersister, Signer: Sign, M: Deref, T: Deref, K: Deref, F: Der impl Persist for K { // TODO: We really need a way for the persister to inform the user that its time to crash/shut // down once these start returning failure. - // A PermanentFailure implies we need to shut down since we're force-closing channels without - // even broadcasting! + // A PermanentFailure implies we should probably just shut down the node since we're + // force-closing channels without even broadcasting! fn persist_new_channel(&self, funding_txo: OutPoint, monitor: &ChannelMonitor, _update_id: MonitorUpdateId) -> chain::ChannelMonitorUpdateStatus { let key = format!("monitors/{}_{}", funding_txo.txid.to_hex(), funding_txo.index);