diff --git a/src/runtime/endpoints.rs b/src/runtime/endpoints.rs index 3118126f12f8118c6e8219beda332e544c883cc8..0fd9398b3bc6f8fa76658af6e9a49fc1f9b450d2 100644 --- a/src/runtime/endpoints.rs +++ b/src/runtime/endpoints.rs @@ -75,9 +75,14 @@ impl EndpointManager { pub(super) fn num_endpoints(&self) -> usize { self.endpoint_exts.len() } - pub(super) fn send_to_comms(&mut self, index: usize, msg: &Msg) -> Result<(), SyncError> { + pub(super) fn send_to_comms( + &mut self, + index: usize, + msg: &Msg, + ) -> Result<(), UnrecoverableSyncError> { + use UnrecoverableSyncError as Use; let endpoint = &mut self.endpoint_exts[index].endpoint; - endpoint.send(msg).map_err(|_| SyncError::BrokenEndpoint(index)) + endpoint.send(msg).map_err(|_| Use::BrokenEndpoint(index)) } pub(super) fn send_to_setup(&mut self, index: usize, msg: &Msg) -> Result<(), ConnectError> { let endpoint = &mut self.endpoint_exts[index].endpoint; @@ -89,13 +94,13 @@ impl EndpointManager { &mut self, logger: &mut dyn Logger, deadline: Option, - ) -> Result, SyncError> { - use {SyncError as Se, TryRecyAnyError as Trae}; + ) -> Result, UnrecoverableSyncError> { + use {TryRecyAnyError as Trae, UnrecoverableSyncError as Use}; match self.try_recv_any(logger, deadline) { Ok(tup) => Ok(Some(tup)), Err(Trae::Timeout) => Ok(None), - Err(Trae::PollFailed) => Err(Se::PollFailed), - Err(Trae::EndpointError { error: _, index }) => Err(Se::BrokenEndpoint(index)), + Err(Trae::PollFailed) => Err(Use::PollFailed), + Err(Trae::EndpointError { error: _, index }) => Err(Use::BrokenEndpoint(index)), } } pub(super) fn try_recv_any_setup(