()
| 832 | |
| 833 | # Run briefly and stop |
| 834 | async def run_briefly(): |
| 835 | arbiter._loop = asyncio.get_running_loop() |
| 836 | |
| 837 | if os.path.exists(socket_path): |
| 838 | os.unlink(socket_path) |
| 839 | |
| 840 | arbiter._server = await asyncio.start_unix_server( |
| 841 | arbiter.handle_client, |
| 842 | path=socket_path |
| 843 | ) |
| 844 | os.chmod(socket_path, 0o600) |
| 845 | |
| 846 | # Verify socket exists |
| 847 | assert os.path.exists(socket_path) |
| 848 | |
| 849 | # Shutdown |
| 850 | arbiter._server.close() |
| 851 | await arbiter._server.wait_closed() |
| 852 | |
| 853 | await run_briefly() |
| 854 |
nothing calls this directly
no test coverage detected