Return server object with serve_forever() method and address attribute
(self)
| 513 | self._shutdown_timeout = shutdown_timeout |
| 514 | |
| 515 | def get_server(self): |
| 516 | ''' |
| 517 | Return server object with serve_forever() method and address attribute |
| 518 | ''' |
| 519 | if self._state.value != State.INITIAL: |
| 520 | if self._state.value == State.STARTED: |
| 521 | raise ProcessError("Already started server") |
| 522 | elif self._state.value == State.SHUTDOWN: |
| 523 | raise ProcessError("Manager has shut down") |
| 524 | else: |
| 525 | raise ProcessError( |
| 526 | "Unknown state {!r}".format(self._state.value)) |
| 527 | return Server(self._registry, self._address, |
| 528 | self._authkey, self._serializer) |
| 529 | |
| 530 | def connect(self): |
| 531 | ''' |