(self)
| 229 | return self._unpack(entry) |
| 230 | |
| 231 | def dump(self): |
| 232 | for entry in self.shm_list: |
| 233 | if not entry: |
| 234 | continue |
| 235 | conn = self._unpack(entry) |
| 236 | proto, ip_version, src_addr, src_port, dst_addr, dst_port, state_epoch, state = conn |
| 237 | log(f"{proto.name}/{ip_version} {src_addr}:{src_port} -> {dst_addr}:{dst_port} {state.name}@{state_epoch}") |
| 238 | |
| 239 | @synchronized_method("rlock") |
| 240 | def gc(self, connection_timeout_sec=15): |