Abort the eventloop if the dialling fails

pull/243/head
Thomas Eizinger 3 years ago
parent 4e9e186462
commit b7c3524b4f
No known key found for this signature in database
GPG Key ID: 651AC83A6C6C8B96

@ -7,12 +7,12 @@ use crate::{
bob::{Behaviour, OutEvent, QuoteRequest, State0, State2}, bob::{Behaviour, OutEvent, QuoteRequest, State0, State2},
}, },
}; };
use anyhow::{anyhow, bail, Result}; use anyhow::{anyhow, bail, Context, Result};
use futures::FutureExt; use futures::FutureExt;
use libp2p::{core::Multiaddr, PeerId}; use libp2p::{core::Multiaddr, PeerId};
use std::{convert::Infallible, sync::Arc}; use std::{convert::Infallible, sync::Arc};
use tokio::sync::mpsc::{Receiver, Sender}; use tokio::sync::mpsc::{Receiver, Sender};
use tracing::{debug, error, info, trace}; use tracing::{debug, error, trace};
#[derive(Debug)] #[derive(Debug)]
pub struct Channels<T> { pub struct Channels<T> {
@ -203,12 +203,8 @@ impl EventLoop {
trace!("Already connected to Alice at {}", peer_id); trace!("Already connected to Alice at {}", peer_id);
let _ = self.conn_established.send(peer_id).await; let _ = self.conn_established.send(peer_id).await;
} else { } else {
info!("dialing alice: {}", peer_id); debug!("Dialing alice at {}", peer_id);
if let Err(err) = libp2p::Swarm::dial(&mut self.swarm, &peer_id) { libp2p::Swarm::dial(&mut self.swarm, &peer_id).context("failed to dial alice")?;
error!("Could not dial alice: {}", err);
// TODO(Franck): If Dial fails then we should report it.
}
} }
} }
}, },

Loading…
Cancel
Save