r"""Start python distributed server and multiple machine server. Args: py_server_port: python server port. mm_server_port: multiple machine server port. queue: server port will put in this queue, puts exception when process fails.
(py_server_port, queue)
| 154 | |
| 155 | |
| 156 | def _start_server(py_server_port, queue): |
| 157 | r"""Start python distributed server and multiple machine server. |
| 158 | |
| 159 | Args: |
| 160 | py_server_port: python server port. |
| 161 | mm_server_port: multiple machine server port. |
| 162 | queue: server port will put in this queue, puts exception when process fails. |
| 163 | """ |
| 164 | try: |
| 165 | mm_server_port = create_mm_server("0.0.0.0", 0) |
| 166 | server = ThreadXMLRPCServer( |
| 167 | ("0.0.0.0", py_server_port), logRequests=False, allow_none=True |
| 168 | ) |
| 169 | server.register_instance(Methods(mm_server_port)) |
| 170 | _, py_server_port = server.server_address |
| 171 | queue.put((py_server_port, mm_server_port)) |
| 172 | server.serve_forever() |
| 173 | except Exception as e: |
| 174 | queue.put(e) |
| 175 | |
| 176 | |
| 177 | class Server: |
nothing calls this directly
no test coverage detected