Create WebSocketProtocol with mock transport.

Extract HTTP request info from uWSGI vars. Header Mapping (CGI/WSGI to HTTP): The uWSGI protocol passes HTTP headers using CGI-style

Handle SIGCHLD - reap dead workers.

Handle WebSocket upgrade request.

Check if IP address is in the allow list. Args: ip_str: The IP address string to check allow_list: The original allow list (strin

Check if data contains only RFC 9110 token characters.

Simulate loading a model (expensive operation).

Callback: received body data chunk.

Parse uWSGI vars block into key-value pairs. Format: key_size (2 bytes LE) + key + val_size (2 bytes LE) + value

Return the (secure_scheme_headers, forwarder_headers) the peer is allowed to set. When the peer's address is not in ``forwarded_allow_ips`` (

Pop a chunk and return the appropriate message.

Per RFC 9110 §6.4.2 a server MUST NOT send Content-Length on 1xx or 204 responses. HEAD and 304 are NOT covered: HEAD MAY include the

Restart server in parent after fork (called by fork handler).

Send a worker management message to the dirty arbiter. Args: operation: "add" or "remove" count: Number of w

Send HTTP response status and headers. Uses cached status lines and headers for common cases to avoid repeated string formatting and

Initiate async shutdown.

Start a consumer task for a worker's request queue.

Remove framing headers that must not appear on a no-body response. Transfer-Encoding is always stripped (chunked framing implies a body

Unregister a worker's apps when it exits. Removes the worker from all tracking maps. Args: worker_pid: The PID

Wait for gunicorn to be ready.

Benchmark arbiter message forwarding throughput.

Benchmark DirtyAsyncStreamIterator directly. Measures async iterator overhead vs raw message reading.

Compare stream() vs stream_async() performance with the same workload.

Benchmark time-to-first-chunk and time-to-last-chunk.

Benchmark worker streaming throughput with various chunk sizes.

A context manager that asserts post-conditions of ``listen_fds`` at exit. This helper is used to ease checking of the test post-conditions f

Close the client connection.

Called when a connection is established.

Create a test arbiter for benchmarks.

Create a worker instance for testing.

Create a worker instance for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a config for WSGI parsing.

Decode hex escape sequences like \\xAB in test data.

Decode hex escape sequences like \\xAB in test data.

Loads the configuration

Drain unread body data. Should be called before reusing connection for keepalive.

Encode a chunk message for streaming responses. Args: request_id: Request identifier this chunk belongs to d

Encode an end-of-stream message. Args: request_id: Request identifier this ends Returns: bytes: Com

Encode an error response message. Args: request_id: Request identifier this responds to error: DirtyError in

Encode a HyBi style WebSocket frame. Optional opcode: 0x0 - continuation 0x1 - text frame (base64 encode buf)

Encode a request message. Args: request_id: Unique request identifier (uint64) app_path: Import path of the

Execute a command in the container.

Return the readable file descriptor for selector registration.

Format response data based on command. Args: command: Original command string data: Response data dictionary Returns:

Get container logs.

Override this method to customize how the thread pool is created

\ Report the dirty arbiter exit status and forget the process. Called from both reaping paths: the targeted waitpid below, and

Return list of available commands. Returns: Dictionary with commands and descriptions

Initialize the application. Called once when the dirty worker starts, after the app instance is created. Use this for expens

Called once when dirty worker starts.

Set up signal handlers.

Set up signal handlers.

Check if docker compose is available.

Check if Docker is available.

Send a signal to a process in the container.

Log a given statistic if metric, value and type are present