How to keep my connection alive all the time?

[whyubel1eve]

Hi, I'm a beginner at rust-libp2p.
I used hole-punching to get my two nodes connected and they can chat through gossipsub. But both of them disconnect from each other after 2 minutes when I didn't send messages anymore. I tried to set PingConfig: PingConfig::new().with_keep_alive(true) but it didn't work. So I want to know how to keep my connection forever if I'm not intended to end it. Thanks.

[dariusc93]

Could you provide some code and show the logs using RUST_LOG=debug? So far with my use case and testing i havent seen the peers disconnect after 2 mins with the Ping behaviour.

[whyubel1eve]

em...I just tried to force-shutdown my server and it did close my communication. So actually I didn't hole-punch successfully. I followed the example code but I don't know why this happened...

[thomaseizinger]

You can't hole-punch every connection. What kind of NAT are you behind?

[whyubel1eve]

The test result shows FullCone NAT type.

[thomaseizinger]

Hmm, that should work though!

Well, in any case, the issue seems to be that the hole-punch is not successful. Can you share some more details about your setup and some logs of the actual hole-punch attempt?

[whyubel1eve]

relay setup

async fn main() -> Result<(), Box> {
env_logger::init();
let opt = Opt::parse();
println!("opt: {:?}", opt);


let local_key: identity::Keypair = generate_ed25519(opt.secret_key_seed);
let local_peer_id = PeerId::from(local_key.public());


let noise_keys = noise::Keypair::<noise::X25519Spec>::new()
    .into_authentic(&local_key)
    .expect("Signing libp2p-noise static DH keypair failed.");

let transport = TokioTcpTransport::new(GenTcpConfig::default())
    .upgrade(upgrade::Version::V1)
    .authenticate(noise::NoiseConfig::xx(noise_keys).into_authenticated())
    .multiplex(libp2p::yamux::YamuxConfig::default())
    .boxed();

let mut relay_config = Config::default();
relay_config.max_circuit_duration = Duration::from_secs(60 * 60);

let behaviour = Behaviour {
    relay: Relay::new(local_peer_id, relay_config),
    ping: Ping::new(PingConfig::new().with_keep_alive(true)),
    identify: Identify::new(IdentifyConfig::new(
        "/TODO/0.0.1".to_string(),
        local_key.public(),
    )),
};

let mut swarm =  SwarmBuilder::new(transport, behaviour, local_peer_id).executor(Box::new(|fut| {
    tokio::spawn(fut);
}))
.build();

let listen_addr = Multiaddr::empty()
    .with(match opt.use_ipv6 {
        Some(true) => Protocol::from(Ipv6Addr::UNSPECIFIED),
        _ => Protocol::from(Ipv4Addr::UNSPECIFIED),
    })
    .with(Protocol::Tcp(opt.port));
swarm.listen_on(listen_addr)?;

***

}

client setup

pub async fn establish_connection(

key: &String,

topic: &String,

relay_address: &Multiaddr,

remote_id: &Option,

) -> Swarm {
let local_key = generate_ed25519(key);
let local_peer_id = PeerId::from(local_key.public());
info!("Local peer id: {:?}", local_peer_id);
println!("Local peer id: {:?}", local_peer_id);

let (relay_transport, client) = Client::new_transport_and_behaviour(local_peer_id);

let noise_keys = noise::Keypair::<noise::X25519Spec>::new()
    .into_authentic(&local_key)
    .expect("Signing libp2p-noise static DH keypair failed.");

let transport = OrTransport::new(
    relay_transport,
    TokioDnsConfig::system(TokioTcpTransport::new(
        GenTcpConfig::default().port_reuse(true),
    ))
    .unwrap(),
)
.upgrade(upgrade::Version::V1)
.authenticate(noise::NoiseConfig::xx(noise_keys).into_authenticated())
.multiplex(yamux::YamuxConfig::default())
.boxed();

let topic = Topic::new(topic);

let mut swarm = {
    // set a custom gossipsub
    let gossipsub_config = gossipsub::GossipsubConfigBuilder::default()
        .mesh_n_low(1)
        .mesh_n(2)
        .mesh_outbound_min(1)
        .build()
        .expect("Valid config");
    let mut gossip = gossipsub::Gossipsub::new(
        MessageAuthenticity::Signed(local_key.clone()),
        gossipsub_config,
    )
    .expect("configuration error");

    gossip.subscribe(&topic).unwrap();

    let behaviour = Behaviour {
        relay_client: client,
        ping: Ping::new(PingConfig::new().with_keep_alive(true)),
        identify: Identify::new(IdentifyConfig::new(
            "/TODO/0.0.1".to_string(),
            local_key.public(),
        )),
        dcutr: dcutr::behaviour::Behaviour::new(),
        gossip,
    };
    SwarmBuilder::new(transport, behaviour, local_peer_id)
        .dial_concurrency_factor(10_u8.try_into().unwrap())
        .executor(Box::new(|fut| {
            tokio::spawn(fut);
        }))
        .build()
};

swarm
    .listen_on(
        Multiaddr::empty()
            .with("0.0.0.0".parse::<Ipv4Addr>().unwrap().into())
            .with(Protocol::Tcp(0)),
    )
    .unwrap();

*** ignore...

swarm.dial(relay_address.clone()).unwrap();

***

swarm
    .listen_on(relay_address.clone().with(Protocol::P2pCircuit))
    .unwrap();

if *remote_id != None {
    swarm
        .dial(
            relay_address
                .clone()
                .with(Protocol::P2pCircuit)
                .with(Protocol::P2p(PeerId::from((*remote_id).unwrap()).into())),
        )
        .unwrap();
}

}

some logs where I see dcutr

[2022-09-30T05:52:44Z INFO  tochat::network::connection_dm] Established connection to PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK") via Dialer { address: "/ip4/1.12.76.121/tcp/4001/p2p/12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN/p2p-circuit/p2p/12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK", role_override: Dialer }
[2022-09-30T05:52:44Z DEBUG multistream_select::listener_select] Listener: confirming protocol: /libp2p/dcutr

[2022-09-30T05:52:44Z DEBUG multistream_select::listener_select] Listener: sent confirmed protocol: /libp2p/dcutr

[2022-09-30T05:52:44Z DEBUG multistream_select::listener_select] Listener: confirming protocol: /meshsub/1.1.0

[2022-09-30T05:52:44Z DEBUG multistream_select::listener_select] Listener: sent confirmed protocol: /meshsub/1.1.0

[2022-09-30T05:52:44Z DEBUG libp2p_core::upgrade::apply] Successfully applied negotiated protocol

[2022-09-30T05:52:44Z DEBUG yamux::connection] aef7f69a: new outbound (Stream aef7f69a/3) of (Connection aef7f69a Client (streams 4))

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] New peer type found: Gossipsub v1.1 for peer: 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK

[2022-09-30T05:52:44Z DEBUG multistream_select::dialer_select] Dialer: Proposed protocol: /meshsub/1.1.0

[2022-09-30T05:52:44Z DEBUG multistream_select::dialer_select] Dialer: Received confirmation for protocol: /ipfs/ping/1.0.0

[2022-09-30T05:52:44Z DEBUG libp2p_ping] Ping received from PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK")

[2022-09-30T05:52:44Z DEBUG libp2p_core::upgrade::apply] Successfully applied negotiated protocol

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] Handling subscriptions: [GossipsubSubscription { action: Subscribe, topic_hash: TopicHash { hash: "666" } }], from source: 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK

[2022-09-30T05:52:44Z DEBUG multistream_select::dialer_select] Dialer: Received confirmation for protocol: /meshsub/1.1.0

[2022-09-30T05:52:44Z DEBUG libp2p_core::upgrade::apply] Successfully applied negotiated protocol

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] SUBSCRIPTION: Adding gossip peer: 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK to topic: TopicHash { hash: "666" }

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] SUBSCRIPTION: Adding peer 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK to the mesh for topic TopicHash { hash: "666" }

[2022-09-30T05:52:44Z DEBUG libp2p_core::upgrade::apply] Successfully applied negotiated protocol

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] Sending GRAFT to peer 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK for topic TopicHash { hash: "666" }

[2022-09-30T05:52:44Z INFO  tochat::network::connection_dm] RemoteInitiatedDirectConnectionUpgrade { remote_peer_id: PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK"), remote_relayed_addr: "/ip4/1.12.76.121/tcp/4001/p2p/12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN/p2p-circuit/p2p/12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK" }

[2022-09-30T05:52:44Z DEBUG multistream_select::listener_select] Listener: confirming protocol: /ipfs/id/1.0.0

[2022-09-30T05:52:44Z DEBUG multistream_select::listener_select] Listener: sent confirmed protocol: /ipfs/id/1.0.0

[2022-09-30T05:52:44Z DEBUG libp2p_core::upgrade::apply] Successfully applied negotiated protocol

[2022-09-30T05:52:44Z INFO  tochat::network::connection_dm] Sent { peer_id: PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK") }

[2022-09-30T05:52:44Z DEBUG yamux::connection] aef7f69a: new outbound (Stream aef7f69a/5) of (Connection aef7f69a Client (streams 5))

[2022-09-30T05:52:44Z DEBUG multistream_select::dialer_select] Dialer: Proposed protocol: /ipfs/id/1.0.0

[2022-09-30T05:52:44Z DEBUG libp2p_ping] Ping sent to PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK")

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] Handling GRAFT message for peer: 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] GRAFT: Received graft for peer PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK") that is already in topic TopicHash { hash: "666" }

[2022-09-30T05:52:44Z DEBUG libp2p_dns] Dialing /ip4/182.150.123.92/tcp/2541/p2p/12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK

[2022-09-30T05:52:44Z DEBUG libp2p_gossipsub::behaviour] Completed GRAFT handling for peer: 12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK

[2022-09-30T05:52:44Z DEBUG libp2p_tcp] dialing 182.150.123.92:2541

[2022-09-30T05:52:45Z DEBUG multistream_select::dialer_select] Dialer: Received confirmation for protocol: /ipfs/id/1.0.0

[2022-09-30T05:52:45Z DEBUG libp2p_core::upgrade::apply] Successfully applied negotiated protocol

[2022-09-30T05:52:45Z INFO  tochat::network::connection_dm] Received { peer_id: PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK"), info: IdentifyInfo { public_key: Ed25519(PublicKey(compressed): ec2264fb3dcba7fce7a1c6645791f0f32ffc7313192446e4375d337f7a5956), protocol_version: "/TODO/0.0.1", agent_version: "rust-libp2p/0.39.0", listen_addrs: ["/ip4/182.150.123.92/tcp/2541", "/ip4/1.12.76.121/tcp/4001/p2p/12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN/p2p-circuit/p2p/12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK", "/ip4/127.0.0.1/tcp/42443", "/ip4/172.29.191.159/tcp/42443", "/ip4/1.12.76.121/tcp/4001/p2p/12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN/p2p-circuit/p2p/12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK"], protocols: ["/libp2p/circuit/relay/0.2.0/stop", "/ipfs/ping/1.0.0", "/ipfs/id/1.0.0", "/ipfs/id/push/1.0.0", "/libp2p/dcutr", "/meshsub/1.1.0", "/meshsub/1.0.0"], observed_addr: "/p2p/12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN" } }
then repeat ：

[2022-09-30T05:52:55Z DEBUG libp2p_gossipsub::behaviour] Starting heartbeat

[2022-09-30T05:52:55Z DEBUG libp2p_gossipsub::behaviour] Completed Heartbeat

[2022-09-30T05:52:57Z DEBUG libp2p_ping] Ping received from PeerId("12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN")

[2022-09-30T05:52:57Z DEBUG libp2p_ping] Ping sent to PeerId("12D3KooWDpJ7As7BWAwRMfu1VU2WCqNjvq387JEYKDBj4kx6nXTN")

[2022-09-30T05:52:59Z DEBUG libp2p_ping] Ping received from PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK")

[2022-09-30T05:53:00Z DEBUG libp2p_ping] Ping sent to PeerId("12D3KooWRi8obJFr9EoU3BcfWsQRq3NDTusiE2cb8iCnotWZbqsK")