diff --git a/coordinator/Cargo.toml b/coordinator/Cargo.toml index b5bda710b..8d65ca8f6 100644 --- a/coordinator/Cargo.toml +++ b/coordinator/Cargo.toml @@ -50,7 +50,7 @@ env_logger = { version = "0.10", default-features = false, features = ["humantim futures = { version = "0.3", default-features = false, features = ["std"] } tokio = { version = "1", default-features = false, features = ["rt-multi-thread", "sync", "time", "macros"] } -libp2p = { version = "0.52", default-features = false, features = ["tokio", "tcp", "noise", "yamux", "gossipsub", "mdns", "macros"] } +libp2p = { version = "0.52", default-features = false, features = ["tokio", "quic", "gossipsub", "mdns", "macros"] } [dev-dependencies] futures = { version = "0.3", default-features = false, features = ["std"] } diff --git a/coordinator/src/p2p.rs b/coordinator/src/p2p.rs index aa392c52b..62e541097 100644 --- a/coordinator/src/p2p.rs +++ b/coordinator/src/p2p.rs @@ -22,8 +22,6 @@ use libp2p::{ futures::StreamExt, identity::Keypair, PeerId, - tcp::Config as TcpConfig, - noise, yamux, gossipsub::{ IdentTopic, FastMessageId, MessageId, MessageAuthenticity, ValidationMode, ConfigBuilder, IdentityTransform, AllowAllSubscriptionFilter, Event as GsEvent, PublishError, @@ -276,16 +274,7 @@ impl LibP2p { // TODO: Relay client? let mut swarm = SwarmBuilder::with_existing_identity(throwaway_key_pair) .with_tokio() - .with_tcp(TcpConfig::default().nodelay(true), noise::Config::new, || { - let mut config = yamux::Config::default(); - // 1 MiB default + max message size - config.set_max_buffer_size((1024 * 1024) + MAX_LIBP2P_MESSAGE_SIZE); - // 256 KiB default + max message size - config - .set_receive_window_size(((256 * 1024) + MAX_LIBP2P_MESSAGE_SIZE).try_into().unwrap()); - config - }) - .unwrap() + .with_quic() .with_behaviour(|_| behavior) .unwrap() .build();