Method sync_loop

src/app.rs:179–207

Start a sync loop blocking the current thread

(&self, shutdown_rx: Option<mpsc::Receiver<()>>)

    /// Start a sync loop blocking the current thread
    pub fn sync_loop(&self, shutdown_rx: Option<mpsc::Receiver<()>>) {
        const RETRY_DUR: Duration = Duration::from_secs(3);

        let shutdown_rx = shutdown_rx
            .map(|rx| self.bind_shutdown(rx))
            .or_else(|| self.default_shutdown_signal());

        debug!(target: LT, "starting sync loop");
        loop {
            if let Some(shutdown_rx) = &shutdown_rx {
                if shutdown_rx.try_recv() != Err(mpsc::TryRecvError::Empty) {
                    break;
                }
            }

            let mut wait_time = self.config.poll_interval;

            if let Err(e) = self.sync() {
                // Report the error and try again on the next run, this might be
                // a temporary connectivity issue.
                warn!(target: LT, "failed syncing with bitcoind: {:?}", e);
                wait_time = RETRY_DUR;
            }

            // wait for poll_interval seconds or until we receive a sync notification message
            // (which can also get triggered through the shutdown signal)
            self.sync_chan.1.recv_timeout(wait_time).ok();
        }
    }

    /// Start a sync loop in a new background thread.
    /// Takes ownership over the app. You can retain a Query instance before calling this.