(self, sock, terminate_on_socket_close=True)
| 1486 | return False |
| 1487 | |
| 1488 | def initialize_network(self, sock, terminate_on_socket_close=True): |
| 1489 | assert sock is not None |
| 1490 | try: |
| 1491 | sock.settimeout(None) # infinite, no timeouts from now on - jython does not have it |
| 1492 | except: |
| 1493 | pass |
| 1494 | curr_reader = getattr(self, "reader", None) |
| 1495 | curr_writer = getattr(self, "writer", None) |
| 1496 | if curr_reader: |
| 1497 | curr_reader.do_kill_pydev_thread() |
| 1498 | if curr_writer: |
| 1499 | curr_writer.do_kill_pydev_thread() |
| 1500 | |
| 1501 | self.writer = WriterThread(sock, self, terminate_on_socket_close=terminate_on_socket_close) |
| 1502 | self.reader = ReaderThread( |
| 1503 | sock, |
| 1504 | self, |
| 1505 | PyDevJsonCommandProcessor=PyDevJsonCommandProcessor, |
| 1506 | process_net_command=process_net_command, |
| 1507 | terminate_on_socket_close=terminate_on_socket_close, |
| 1508 | ) |
| 1509 | self.writer.start() |
| 1510 | self.reader.start() |
| 1511 | |
| 1512 | time.sleep(0.1) # give threads time to start |
| 1513 | |
| 1514 | def connect(self, host, port): |
| 1515 | if host: |
no test coverage detected