Better than monkeypatching for now; merge into Server ultimately
(self)
| 1401 | util.debug(f"{self.__class__.__name__}.__del__ by pid {getpid()}") |
| 1402 | |
| 1403 | def get_server(self): |
| 1404 | 'Better than monkeypatching for now; merge into Server ultimately' |
| 1405 | if self._state.value != State.INITIAL: |
| 1406 | if self._state.value == State.STARTED: |
| 1407 | raise ProcessError("Already started SharedMemoryServer") |
| 1408 | elif self._state.value == State.SHUTDOWN: |
| 1409 | raise ProcessError("SharedMemoryManager has shut down") |
| 1410 | else: |
| 1411 | raise ProcessError( |
| 1412 | "Unknown state {!r}".format(self._state.value)) |
| 1413 | return self._Server(self._registry, self._address, |
| 1414 | self._authkey, self._serializer) |
| 1415 | |
| 1416 | def SharedMemory(self, size): |
| 1417 | """Returns a new SharedMemory instance with the specified size in |
nothing calls this directly
no test coverage detected