(self)
| 137 | FORCE_KILL_PROCESS_WHEN_FINISHED_OK = True |
| 138 | |
| 139 | def __init__(self): |
| 140 | AbstractWriterThread.__init__(self) |
| 141 | socket_name = get_socket_name(close=True) |
| 142 | server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
| 143 | server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) |
| 144 | server_socket.bind(socket_name) |
| 145 | server_socket.listen(1) |
| 146 | self.port = socket_name[1] |
| 147 | self.__server_socket = server_socket |
| 148 | |
| 149 | def run(self): |
| 150 | print("waiting for second process") |
nothing calls this directly
no test coverage detected