\ Your worker subclass must arrange to have this method called once every ``self.timeout`` seconds. If you fail in accomplishing

Read data from unreader and append to bytearray buffer.

Drive AsyncWorker.handle() over a socketpair. Returns the worker. ``close_client`` gives the HTTP/1 path an EOF to stop on. An upgrade needs

Stream response chunks from URL.

An Upgrade: h2c request, optionally carrying a payload.

Close connection to a worker.

Create a LifespanManager instance.

Create a mock WebSocket upgrade request.

Create a mock HTTP request.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Handle a single HTTP request.

Normalize socket address to ASGI-compatible (host, port) tuple. ASGI spec requires server/client to be (host, port) tuples. IPv6 sockets retu

Handle signals.

Unmask WebSocket payload data.

Simplest possible application object

Clean up a gunicorn process.

Find a free port to bind to.

Handle completion of a request (called via method_queue on main thread).

Deserialize error from protocol transmission. Creates an error instance from a serialized dict. The returned error will be an instanc

Get the workers class attribute from a dirty app without instantiating it. This is used by the arbiter to determine how many workers should

Get or create a thread-local sync client. This is the recommended way to get a client in sync HTTP workers. Args: timeout: Time

Build an error response message dict. Args: request_id: Request identifier this responds to error: DirtyError instance or di

Make a simple HTTP request and return the response body.

Make a simple HTTP request and return the response body.

Parse a command line into command and args. Args: line: Command line string Returns: Tuple of (command_string, args_lis

Reset this stream with RST_STREAM. Args: error_code: HTTP/2 error code (default: CANCEL)

Send an error response on a stream. Args: stream_id: The stream ID status_code: HTTP status code message:

Set the global dirty socket path (called during initialization).

Wait until server is accepting connections.

Kill any orphaned dirty arbiter from a previous crash. Only runs on fresh start (master_pid == 0), not during USR2.

Create a mock HTTP request.

Create an ASGIProtocol instance for testing.

Create a WebSocketProtocol instance.

Create a WebSocketProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Get default control socket path based on available directories. Prefers XDG_RUNTIME_DIR if available (standard on Linux, sometimes BSD), fall

Transition to half-closed (local) state.

Transition to half-closed (remote) state.

Read a single WebSocket frame. Returns: tuple: (opcode, payload) or None if connection closed

Send an error response.

Close the pipe file descriptors.

Close the connection gracefully with GOAWAY.

Create a mock SSL socket for testing ALPN negotiation.

Create a worker for testing.

Helper to create a ThreadWorker for testing.

Drain the request body.

Encode a message for transmission. Args: data: Dictionary to encode Returns: Length-prefixed JSON b

Get a short socket path that won't exceed Unix socket path limits. macOS limits Unix socket paths to ~104 characters, so we use /tmp directly.

Initialize the pipe and queue.

\ If you override this method in a subclass, the last statement in the function should be to call this method with super().ini

Send a signal to a process in the container.

Kill a worker by PID.

Update heartbeat timestamp.

Read data from the stream, using buffered data first. Args: size: Number of bytes to read. If None, returns all buffered

Read a line from the body. Args: size: Maximum bytes to read Returns: bytes: A line of data

Make HTTP request and return JSON response.

Reset a stream with RST_STREAM. Args: stream_id: The stream ID to reset error_code: HTTP/2 error code (default: CANCE

Send a response on a stream. Args: stream_id: The stream ID to respond on status: HTTP status code (int)

Send a signal to the dirty arbiter.

Start a gunicorn server with specified worker class and control socket.

Stop all workers.

Validate pidfile and make it stale if needed

Write one message to an async writer. Args: writer: asyncio StreamWriter data: Message dictionary to send

Construct a RequestParser that drains the given bytes.

Create a LifespanManager instance.

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.