linkerd
/
linkerd2-proxy
mirror of https://github.com/linkerd/linkerd2-proxy.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Prepare `BoundPort::listen_and_fold` for upcoming TLS work. (#1018) 

Refactor `listen_and_fold()` to make it possible to insert more futures
into the chain before the folding.

Signed-off-by: Brian Smith <brian@briansmith.org>
This commit is contained in:
Brian Smith 2018-05-25 09:59:05 -10:00 committed by GitHub
parent 0e6c4c1450
commit 7764e97a25
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
proxy/src/connection.rs
View File

@ -116,7 +116,7 @@ impl BoundPort {
TcpListener::from_std(self.inner, &Handle::current())
}).and_then(|listener|
listener.incoming()
.fold(initial, move |b, socket,| {
.and_then(move |socket| {
let remote_addr = socket.peer_addr()
.expect("couldn't get remote addr!");
// TODO: On Linux and most other platforms it would be better
@ -126,8 +126,10 @@ impl BoundPort {
// libraries don't have the necessary API for that, so just
// do it here.
set_nodelay_or_warn(&socket);
f(b, (Connection::plain(socket), remote_addr))
let connection = Connection::plain(socket);
future::ok((connection, remote_addr))
})
.fold(initial, f)
)
.map(|_| ())
}