Commit3390cf3

authored

Merge pull request#777 from petrosagg/buffered-io

tokio-postgres: buffer sockets to avoid excessive syscalls

2 parents52de269 +ca6d4b8 commit3390cf3Copy full SHA for 3390cf3

File tree

-4

lines changed

-4

lines changed

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,7 @@ use std::future::Future;`
`51`	`51`	`use std::io;`
`52`	`52`	`use std::pin::Pin;`
`53`	`53`	`use std::task::{Context,Poll};`
`54`		`-use tokio::io::{AsyncRead,AsyncWrite,ReadBuf};`
	`54`	`+use tokio::io::{AsyncRead,AsyncWrite,BufReader,ReadBuf};`
`55`	`55`	`use tokio_postgres::tls;`
`56`	`56`	`#[cfg(feature ="runtime")]`
`57`	`57`	`use tokio_postgres::tls::MakeTlsConnect;`
`@@ -115,6 +115,7 @@ where`
`115`	`115`	`typeFuture =Pin<Box<dynFuture<Output =Result<TlsStream<S>, native_tls::Error>> +Send>>;`
`116`	`116`
`117`	`117`	`fnconnect(self,stream:S) ->Self::Future{`
	`118`	`+let stream =BufReader::with_capacity(8192, stream);`
`118`	`119`	`let future =asyncmove{`
`119`	`120`	`let stream =self.connector.connect(&self.domain, stream).await?;`
`120`	`121`
`@@ -126,7 +127,7 @@ where`
`126`	`127`	`}`
`127`	`128`
`128`	`129`	/// The stream returned by `TlsConnector`.
`129`		`-pubstructTlsStream<S>(tokio_native_tls::TlsStream<S>);`
	`130`	`+pubstructTlsStream<S>(tokio_native_tls::TlsStream<BufReader<S>>);`
`130`	`131`
`131`	`132`	`impl<S>AsyncReadforTlsStream<S>`
`132`	`133`	`where`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,7 @@ use std::pin::Pin;`
`57`	`57`	`#[cfg(feature ="runtime")]`
`58`	`58`	`use std::sync::Arc;`
`59`	`59`	`use std::task::{Context,Poll};`
`60`		`-use tokio::io::{AsyncRead,AsyncWrite,ReadBuf};`
	`60`	`+use tokio::io::{AsyncRead,AsyncWrite,BufReader,ReadBuf};`
`61`	`61`	`use tokio_openssl::SslStream;`
`62`	`62`	`use tokio_postgres::tls;`
`63`	`63`	`#[cfg(feature ="runtime")]`
`@@ -140,6 +140,7 @@ where`
`140`	`140`	`typeFuture =Pin<Box<dynFuture<Output =Result<TlsStream<S>,Self::Error>> +Send>>;`
`141`	`141`
`142`	`142`	`fnconnect(self,stream:S) ->Self::Future{`
	`143`	`+let stream =BufReader::with_capacity(8192, stream);`
`143`	`144`	`let future =asyncmove{`
`144`	`145`	`let ssl =self.ssl.into_ssl(&self.domain)?;`
`145`	`146`	`letmut stream =SslStream::new(ssl, stream)?;`
`@@ -182,7 +183,7 @@ impl Error for ConnectError {`
`182`	`183`	`}`
`183`	`184`
`184`	`185`	/// The stream returned by `TlsConnector`.
`185`		`-pubstructTlsStream<S>(SslStream<S>);`
	`186`	`+pubstructTlsStream<S>(SslStream<BufReader<S>>);`
`186`	`187`
`187`	`188`	`impl<S>AsyncReadforTlsStream<S>`
`188`	`189`	`where`

Comments

(0)