cleanup any unfinished streams
(self)
| 104 | self.rip = False |
| 105 | |
| 106 | def postmodule(self): |
| 107 | "cleanup any unfinished streams" |
| 108 | self.logger.debug("Unset Read Streams: {!s}".format(self.unset_read_streams)) |
| 109 | self.logger.debug("Unset Write Streams: {!s}".format(self.unset_write_streams)) |
| 110 | while(len(self.open_streams) > 0): |
| 111 | k = list(self.open_streams)[0] |
| 112 | self.__closeStream(k, "POSSIBLY INCOMPLETE") |
| 113 | |
| 114 | def packet_handler(self, pkt): |
| 115 | """ |
nothing calls this directly
no test coverage detected