Skip to content

Commit d5104bc

Browse files
committed
Turn on TCP nodelay in socket
1 parent be022b5 commit d5104bc

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

tokio-postgres/src/proto/connect_once.rs

+5-2
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ where
117117
return Err(Error::connect(io::Error::new(
118118
io::ErrorKind::InvalidData,
119119
"resolved 0 addresses",
120-
)))
120+
)));
121121
}
122122
};
123123

@@ -134,7 +134,7 @@ where
134134
) -> Poll<AfterConnectingTcp<T>, Error> {
135135
let stream = loop {
136136
match state.future.poll() {
137-
Ok(Async::Ready(stream)) => break Socket::new_tcp(stream),
137+
Ok(Async::Ready(stream)) => break stream,
138138
Ok(Async::NotReady) => return Ok(Async::NotReady),
139139
Err(e) => {
140140
let addr = match state.addrs.next() {
@@ -147,6 +147,9 @@ where
147147
};
148148
let state = state.take();
149149

150+
stream.set_nodelay(true).map_err(Error::connect)?;
151+
let stream = Socket::new_tcp(stream);
152+
150153
transition!(Handshaking {
151154
future: HandshakeFuture::new(stream, state.tls_mode, state.params),
152155
})

0 commit comments

Comments
 (0)