| 40 | } |
| 41 | |
| 42 | pub fn register_client_session( |
| 43 | &mut self, |
| 44 | external_addr: SocketAddr, |
| 45 | local_addr: SocketAddr, |
| 46 | local_data: T, |
| 47 | ) { |
| 48 | let session = UdpSession { |
| 49 | external_addr, |
| 50 | local_data, |
| 51 | last_activity: Instant::now(), |
| 52 | }; |
| 53 | |
| 54 | self.external_to_session.insert(external_addr, session); |
| 55 | self.local_to_external.insert(local_addr, external_addr); |
| 56 | |
| 57 | debug!( |
| 58 | "Registered UDP client session: {} <-> {}", |
| 59 | external_addr, local_addr |
| 60 | ); |
| 61 | } |
| 62 | |
| 63 | pub fn update_activity(&mut self, addr: &SocketAddr, is_external: bool) { |
| 64 | if is_external { |