fn poll_next(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
if let Some(Ok(conn)) = futures::executor::block_on(self.listener.incoming().next()) {
+ debug!(
+ "Received connection attempt from {}",
+ conn.peer_addr()
+ .expect("Peer address could not be retrieved")
+ );
Poll::Ready(Some(Connection::from(conn)))
} else {
+ debug!("Shutting TCP server down at {}", self.local_addrs);
Poll::Ready(None)
}
}
debug!("Received connection attempt from {}", peer_addr);
if let Ok(tls_stream) = futures::executor::block_on(self.acceptor.accept(tcp_stream)) {
- debug!("Established TLS connection from {}", peer_addr);
+ debug!("Completed TLS handshake with {}", peer_addr);
Poll::Ready(Some(Connection::from(TlsConnectionMetadata::Server {
local_addr,
peer_addr,