Initialize control socket server. Args: arbiter: The Gunicorn arbiter instance socket_path: Path for the Unix socket socket_mode: Permission mode for socket (default 0o600)
(self, arbiter, socket_path, socket_mode=0o600)
| 78 | """ |
| 79 | |
| 80 | def __init__(self, arbiter, socket_path, socket_mode=0o600): |
| 81 | """ |
| 82 | Initialize control socket server. |
| 83 | |
| 84 | Args: |
| 85 | arbiter: The Gunicorn arbiter instance |
| 86 | socket_path: Path for the Unix socket |
| 87 | socket_mode: Permission mode for socket (default 0o600) |
| 88 | """ |
| 89 | self.arbiter = arbiter |
| 90 | self.socket_path = socket_path |
| 91 | self.socket_mode = socket_mode |
| 92 | |
| 93 | self.handlers = CommandHandlers(arbiter) |
| 94 | self._server = None |
| 95 | self._loop = None |
| 96 | self._thread = None |
| 97 | self._running = False |
| 98 | self._was_running_before_fork = False |
| 99 | |
| 100 | # Ensure fork handlers are registered |
| 101 | _register_fork_handlers() |
| 102 | |
| 103 | def start(self): |
| 104 | """Start server in background thread with asyncio event loop.""" |
nothing calls this directly
no test coverage detected