revert

network/src/services/dump_peer_store.rs

@@ -1,13 +1,13 @@
 use crate::NetworkState;
 use ckb_logger::{debug, warn};
-use futures::{Future, StreamExt};
-use p2p::runtime::{Interval, MissedTickBehavior};
+use futures::Future;
 use std::{
     pin::Pin,
     sync::Arc,
     task::{Context, Poll},
     time::Duration,
 };
+use tokio::time::{Instant, Interval, MissedTickBehavior};
 
 const DEFAULT_DUMP_INTERVAL: Duration = Duration::from_secs(3600); // 1 hour
 
@@ -51,20 +51,17 @@ impl Future for DumpPeerStoreService {
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         if self.interval.is_none() {
             self.interval = {
-                let mut interval = Interval::new(DEFAULT_DUMP_INTERVAL);
+                let mut interval = tokio::time::interval_at(
+                    Instant::now() + DEFAULT_DUMP_INTERVAL,
+                    DEFAULT_DUMP_INTERVAL,
+                );
                 // The dump peer store service does not need to urgently compensate for the missed wake,
                 // just delay behavior is enough
                 interval.set_missed_tick_behavior(MissedTickBehavior::Delay);
                 Some(interval)
             }
         }
-        while self
-            .interval
-            .as_mut()
-            .unwrap()
-            .poll_next_unpin(cx)
-            .is_ready()
-        {
+        while self.interval.as_mut().unwrap().poll_tick(cx).is_ready() {
             self.dump_peer_store()
         }
         Poll::Pending