diff --git a/src/protocol/libp2p/kademlia/mod.rs b/src/protocol/libp2p/kademlia/mod.rs index b482f03a..680d601d 100644 --- a/src/protocol/libp2p/kademlia/mod.rs +++ b/src/protocol/libp2p/kademlia/mod.rs @@ -741,7 +741,6 @@ impl Kademlia { Some(KademliaCommand::PutRecord { record, query_id, peers }) => { tracing::debug!(target: LOG_TARGET, ?query_id, key = ?record.key, "store record to DHT"); - self.store.put(record.clone()); let key = Key::new(record.key.clone()); @@ -761,6 +760,8 @@ impl Kademlia { peers ); } else { + self.store.put(record.clone()); + self.engine.start_put_record( query_id, record,