(self)
| 134 | self.queue = queue.Queue() # report connections and exceptions to client |
| 135 | |
| 136 | def run(self): |
| 137 | while self.running: |
| 138 | (sockconn, peer) = self.s.accept() |
| 139 | if self.running: |
| 140 | conn = Socks5Connection(self, sockconn, peer) |
| 141 | thread = threading.Thread(None, conn.handle) |
| 142 | thread.daemon = True |
| 143 | thread.start() |
| 144 | |
| 145 | def start(self): |
| 146 | assert(not self.running) |
no test coverage detected