Unmask WebSocket payload data.

Simplest possible application object

Clean up a gunicorn process.

Remove a stream after processing is complete. Args: stream_id: The stream ID to clean up

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)

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

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 an error response on a stream. Args: stream_id: The stream ID status_code: HTTP status code message:

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.

Mark trailers as sent and close the stream. Args: trailers: List of (name, value) trailer tuples Raises: HTT

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.

Create WebSocketProtocol with mock transport.

Return the client address advertised via PROXY protocol if any. Falls back to the transport peername when PROXY protocol is disabled,

Extract close code from WebSocket close frame.

Get the well-known PID file path for orphan detection. Uses self.proc_name (not self.cfg.proc_name) so that during USR2 the new maste

Handle response message, extracting result or raising error.

Send response body chunk. Combines buffered headers with first body chunk for efficient write batching.

Setup the asyncio event loop.

Gets atoms for log formatting.

Remove a stream after processing is complete.

Create an HTTP/2 connection using the h2 library.

Create a worker for testing.

Decode a complete TLV-encoded value, ensuring all data is consumed. Args: data: Binary data to decode Returns:

Queue a callback to be run on the main thread. The callback is added to the queue first, then a wake-up byte is written to the pipe.

Feed a body chunk directly (called by parser callback).

Calculate statistics from list of latency samples.