(self, f: flow.Flow)
| 87 | self.flt = flt |
| 88 | |
| 89 | def add(self, f: flow.Flow) -> None: |
| 90 | if self.flt and not flowfilter.match(self.flt, f): |
| 91 | return |
| 92 | d = f.get_state() |
| 93 | tnetstring.dump(d, self.fo) |
| 94 | self.fo.flush() |
| 95 | |
| 96 | |
| 97 | def read_flows_from_paths(paths) -> list[flow.Flow]: |