(self, new_socket)
| 932 | self._set_socket(new_socket) |
| 933 | |
| 934 | def _set_socket(self, new_socket): |
| 935 | curr_socket = getattr(self, "sock", None) |
| 936 | if curr_socket: |
| 937 | try: |
| 938 | curr_socket.shutdown(socket.SHUT_WR) |
| 939 | except: |
| 940 | pass |
| 941 | try: |
| 942 | curr_socket.close() |
| 943 | except: |
| 944 | pass |
| 945 | |
| 946 | reader_thread = self.reader_thread = ReaderThread(new_socket) |
| 947 | self.sock = new_socket |
| 948 | reader_thread.start() |
| 949 | |
| 950 | # initial command is always the version |
| 951 | self.write_version() |
| 952 | self.log.append("start_socket") |
| 953 | self.finished_initialization = True |
| 954 | |
| 955 | def start_socket_client(self, host, port): |
| 956 | self._sequence = -1 |
no test coverage detected