fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-30 03:01:21 +00:00
Code Issues Projects Releases Wiki Activity

fix(examples/kv-store): set kademlia mode to Server

Browse Source 
Pull-Request: #4195.
This commit is contained in:
Dmitry 2023-07-16 08:08:34 +06:00 committed by GitHub
parent 4c889fd6d5
commit a3efb40892
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/distributed-key-value-store/src/main.rs
View File

@ -24,6 +24,7 @@ use async_std::io;
use futures::{prelude::*, select}; use futures::{prelude::*, select};
use libp2p::core::upgrade::Version; use libp2p::core::upgrade::Version;
use libp2p::kad::record::store::MemoryStore; use libp2p::kad::record::store::MemoryStore;
use libp2p::kad::Mode;
use libp2p::kad::{ use libp2p::kad::{
record::Key, AddProviderOk, GetProvidersOk, GetRecordOk, Kademlia, KademliaEvent, PeerRecord, record::Key, AddProviderOk, GetProvidersOk, GetRecordOk, Kademlia, KademliaEvent, PeerRecord,
PutRecordOk, QueryResult, Quorum, Record, PutRecordOk, QueryResult, Quorum, Record,
@ -85,6 +86,8 @@ async fn main() -> Result<(), Box<dyn Error>> {
SwarmBuilder::with_async_std_executor(transport, behaviour, local_peer_id).build() SwarmBuilder::with_async_std_executor(transport, behaviour, local_peer_id).build()
}; };
swarm.behaviour_mut().kademlia.set_mode(Some(Mode::Server));
// Read full lines from stdin // Read full lines from stdin
let mut stdin = io::BufReader::new(io::stdin()).lines().fuse(); let mut stdin = io::BufReader::new(io::stdin()).lines().fuse();