| 3243 | |
| 3244 | |
| 3245 | class Dispatcher(object): |
| 3246 | def __init__(self): |
| 3247 | self.port = None |
| 3248 | |
| 3249 | def connect(self, host, port): |
| 3250 | self.host = host |
| 3251 | self.port = port |
| 3252 | self.client = start_client(self.host, self.port) |
| 3253 | self.reader = DispatchReader(self) |
| 3254 | self.reader.pydev_do_not_trace = False # we run reader in the same thread so we don't want to loose tracing |
| 3255 | self.reader.run() |
| 3256 | |
| 3257 | def close(self): |
| 3258 | try: |
| 3259 | self.reader.do_kill_pydev_thread() |
| 3260 | except: |
| 3261 | pass |
| 3262 | |
| 3263 | |
| 3264 | class DispatchReader(ReaderThread): |