(&mut self, helper: &mut EpollHelper)
| 303 | } |
| 304 | |
| 305 | fn reconnect(&mut self, helper: &mut EpollHelper) -> std::result::Result<(), EpollHelperError> { |
| 306 | let result = self.reconnect_inner(helper); |
| 307 | if result.is_err() { |
| 308 | // If reconnect fails, mark disconnected to avoid repeated failed socket calls. |
| 309 | self.disconnected.store(true, Ordering::Relaxed); |
| 310 | } |
| 311 | result |
| 312 | } |
| 313 | |
| 314 | fn reconnect_inner( |
| 315 | &mut self, |
no test coverage detected