1- use openssl:: ssl:: SslStream ;
1+ use openssl:: ssl;
22use std:: io:: net:: ip:: Port ;
3- use std:: io:: net:: tcp:: TcpStream ;
4- use std:: io:: net:: pipe:: UnixStream ;
3+ use std:: io:: net:: tcp;
4+ use std:: io:: net:: pipe;
55use std:: io:: { Stream , IoResult } ;
66
77use { PostgresConnectParams ,
@@ -22,7 +22,7 @@ use message::{SslRequest, WriteMessage};
2222static DEFAULT_PORT : Port = 5432 ;
2323
2424pub enum MaybeSslStream < S > {
25- SslStream ( SslStream < S > ) ,
25+ SslStream ( ssl :: SslStream < S > ) ,
2626 NormalStream ( S ) ,
2727}
2828
@@ -52,8 +52,8 @@ impl<S: Stream> Writer for MaybeSslStream<S> {
5252}
5353
5454pub enum InternalStream {
55- TcpStream ( TcpStream ) ,
56- UnixStream ( UnixStream ) ,
55+ TcpStream ( tcp :: TcpStream ) ,
56+ UnixStream ( pipe :: UnixStream ) ,
5757}
5858
5959impl Reader for InternalStream {
@@ -86,11 +86,11 @@ fn open_socket(params: &PostgresConnectParams)
8686 let port = params. port . unwrap_or ( DEFAULT_PORT ) ;
8787 let socket = match params. target {
8888 TargetTcp ( ref host) =>
89- TcpStream :: connect ( host. as_slice ( ) , port) . map ( |s| TcpStream ( s) ) ,
89+ tcp :: TcpStream :: connect ( host. as_slice ( ) , port) . map ( |s| TcpStream ( s) ) ,
9090 TargetUnix ( ref path) => {
9191 let mut path = path. clone ( ) ;
9292 path. push ( format ! ( ".s.PGSQL.{}" , port) ) ;
93- UnixStream :: connect ( & path) . map ( |s| UnixStream ( s) )
93+ pipe :: UnixStream :: connect ( & path) . map ( |s| UnixStream ( s) )
9494 }
9595 } ;
9696 socket. map_err ( |e| SocketError ( e) )
@@ -117,7 +117,7 @@ pub fn initialize_stream(params: &PostgresConnectParams, ssl: &SslMode)
117117 }
118118 }
119119
120- match SslStream :: new ( ctx, socket) {
120+ match ssl :: SslStream :: new ( ctx, socket) {
121121 Ok ( stream) => Ok ( SslStream ( stream) ) ,
122122 Err ( err) => Err ( SslError ( err) )
123123 }
0 commit comments