DGNum/rust-irc
6
0
Fork 0
Code Issues 1 Pull requests 3 Projects Releases Packages Wiki Activity Actions

Avoid synchronously resolving server address

Browse source
This commit is contained in:
John-John Tedro 2019-12-29 19:08:31 +01:00
parent 71a703c762
commit b08e2a89ae
2 changed files with 8 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/client/conn.rs
View file

@ -103,7 +103,7 @@ impl Connection {
} }
let connector: tokio_tls::TlsConnector = builder.build()?.into(); let connector: tokio_tls::TlsConnector = builder.build()?.into();
let socket = TcpStream::connect(&config.socket_addr()?).await?; let socket = TcpStream::connect(config.to_socket_addrs()?).await?;
let stream = connector.connect(&domain, socket).await?; let stream = connector.connect(&domain, socket).await?;
let framed = IrcCodec::new(config.encoding())?.framed(stream); let framed = IrcCodec::new(config.encoding())?.framed(stream);
let transport = Transport::new(&config, framed, tx); let transport = Transport::new(&config, framed, tx);
@ -111,8 +111,7 @@ impl Connection {
Ok(Connection::Secured(transport)) Ok(Connection::Secured(transport))
} else { } else {
log::info!("Connecting to {}.", config.server()?); log::info!("Connecting to {}.", config.server()?);
let addr = config.socket_addr()?; let stream = TcpStream::connect(config.to_socket_addrs()?).await?;
let stream = TcpStream::connect(&addr).await?;
let framed = IrcCodec::new(config.encoding())?.framed(stream); let framed = IrcCodec::new(config.encoding())?.framed(stream);
let transport = Transport::new(&config, framed, tx); let transport = Transport::new(&config, framed, tx);

14
src/client/data/config.rs
View file

@ -4,9 +4,9 @@ use std::{
collections::HashMap, collections::HashMap,
fs::File, fs::File,
io::prelude::*, io::prelude::*,
net::{SocketAddr, ToSocketAddrs},
path::{Path, PathBuf}, path::{Path, PathBuf},
}; };
use tokio::net::ToSocketAddrs;
#[cfg(feature = "json")] #[cfg(feature = "json")]
use serde_json; use serde_json;
@ -420,13 +420,11 @@ impl Config {
.unwrap_or(if self.use_ssl() { 6697 } else { 6667 }) .unwrap_or(if self.use_ssl() { 6697 } else { 6667 })
} }
/// Gets the server and port as a `SocketAddr`. /// Return something that can be converted into a socket address by tokio.
/// This panics when server is not specified or the address is malformed. pub(crate) fn to_socket_addrs(&self) -> Result<impl ToSocketAddrs + '_> {
pub fn socket_addr(&self) -> Result<SocketAddr> { let server = self.server()?;
format!("{}:{}", self.server()?, self.port()) let port = self.port();
.to_socket_addrs() Ok((server, port))
.map(|mut i| i.next().unwrap())
.map_err(|e| e.into())
} }
/// Gets the server password specified in the configuration. /// Gets the server password specified in the configuration.