-
Notifications
You must be signed in to change notification settings - Fork 271
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Annotate socket-level errors with a scope
We frequently encounter socket errors like:
Connection closed error=Transport endpoint is not connected (os error 107)
While the handler is generally scoped with tracing context to tell us
information about the server-side connection, we lack information about
which socket actually failed. For every "logical" TCP stream, we
generally have two concrete connections: One on the server-side of the
proxy and another on the client-side.
This change introduces a new `io::ScopedIo` wrapper type that annotates
all I/O error messages with a `client` or `server` prefix. Then, the
proxy's clients and servers are wrapped with this type so that all
socket-level error messages are disambiguated.- Loading branch information
Showing
9 changed files
with
175 additions
and
41 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,133 @@ | ||
| use crate as io; | ||
| use pin_project::pin_project; | ||
| use std::{pin::Pin, task::Context}; | ||
|
|
||
| /// An I/O stream where errors are annotated a scope. | ||
| #[pin_project] | ||
| #[derive(Debug)] | ||
| pub struct ScopedIo<I> { | ||
| scope: Scope, | ||
|
|
||
| #[pin] | ||
| io: I, | ||
| } | ||
|
|
||
| #[derive(Copy, Clone, Debug)] | ||
| enum Scope { | ||
| Client, | ||
| Server, | ||
| } | ||
|
|
||
| // === impl Scope === | ||
|
|
||
| impl Scope { | ||
| fn err(&self, err: io::Error) -> io::Error { | ||
| io::Error::new(err.kind(), format!("{}: {}", self, err.to_string())) | ||
| } | ||
| } | ||
|
|
||
| impl std::fmt::Display for Scope { | ||
| fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { | ||
| match self { | ||
| Self::Client => write!(f, "client"), | ||
| Self::Server => write!(f, "server"), | ||
| } | ||
| } | ||
| } | ||
|
|
||
| // === impl ScopedIo === | ||
|
|
||
| impl<I> ScopedIo<I> { | ||
| pub fn client(io: I) -> Self { | ||
| Self { | ||
| scope: Scope::Client, | ||
| io, | ||
| } | ||
| } | ||
|
|
||
| pub fn server(io: I) -> Self { | ||
| Self { | ||
| scope: Scope::Server, | ||
| io, | ||
| } | ||
| } | ||
| } | ||
|
|
||
| #[async_trait::async_trait] | ||
| impl<I: io::Peek + Send + Sync> io::Peek for ScopedIo<I> { | ||
| async fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { | ||
| self.io.peek(buf).await.map_err(|e| self.scope.err(e)) | ||
| } | ||
| } | ||
|
|
||
| impl<I: io::PeerAddr> io::PeerAddr for ScopedIo<I> { | ||
| #[inline] | ||
| fn peer_addr(&self) -> io::Result<std::net::SocketAddr> { | ||
| self.io.peer_addr().map_err(|e| self.scope.err(e)) | ||
| } | ||
| } | ||
|
|
||
| impl<I: io::AsyncRead> io::AsyncRead for ScopedIo<I> { | ||
| fn poll_read( | ||
| self: Pin<&mut Self>, | ||
| cx: &mut Context<'_>, | ||
| buf: &mut io::ReadBuf<'_>, | ||
| ) -> io::Poll<()> { | ||
| let this = self.project(); | ||
| let scope = this.scope; | ||
| this.io.poll_read(cx, buf).map_err(|e| scope.err(e)) | ||
| } | ||
| } | ||
|
|
||
| impl<I: io::Write> io::Write for ScopedIo<I> { | ||
| #[inline] | ||
| fn write(&mut self, buf: &[u8]) -> io::Result<usize> { | ||
| self.io.write(buf).map_err(|e| self.scope.err(e)) | ||
| } | ||
|
|
||
| #[inline] | ||
| fn flush(&mut self) -> io::Result<()> { | ||
| self.io.flush().map_err(|e| self.scope.err(e)) | ||
| } | ||
| } | ||
|
|
||
| impl<I: io::AsyncWrite> io::AsyncWrite for ScopedIo<I> { | ||
| #[inline] | ||
| fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> io::Poll<()> { | ||
| let this = self.project(); | ||
| let scope = this.scope; | ||
| this.io.poll_shutdown(cx).map_err(|e| scope.err(e)) | ||
| } | ||
|
|
||
| #[inline] | ||
| fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> io::Poll<()> { | ||
| let this = self.project(); | ||
| let scope = this.scope; | ||
| this.io.poll_flush(cx).map_err(|e| scope.err(e)) | ||
| } | ||
|
|
||
| #[inline] | ||
| fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8]) -> io::Poll<usize> { | ||
| let this = self.project(); | ||
| let scope = this.scope; | ||
| this.io.poll_write(cx, buf).map_err(|e| scope.err(e)) | ||
| } | ||
|
|
||
| #[inline] | ||
| fn poll_write_vectored( | ||
| self: Pin<&mut Self>, | ||
| cx: &mut Context<'_>, | ||
| bufs: &[io::IoSlice<'_>], | ||
| ) -> io::Poll<usize> { | ||
| let this = self.project(); | ||
| let scope = this.scope; | ||
| this.io | ||
| .poll_write_vectored(cx, bufs) | ||
| .map_err(|e| scope.err(e)) | ||
| } | ||
|
|
||
| #[inline] | ||
| fn is_write_vectored(&self) -> bool { | ||
| self.io.is_write_vectored() | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters