Get the dirty socket path.

Get container logs.

Get the complete request body. Returns: bytes: The request body data

Make an HTTP/2 request and return the response.

\ Kill a worker :attr pid: int, worker pid :attr sig: `signal.SIG*` value

Maintain the number of dirty workers.

Normalize headers to lowercase names for comparison. H1CProtocol preserves original case, PythonProtocol lowercases.

Read body chunk asynchronously. Args: size: Maximum bytes to read Returns: bytes: Body data, empty bytes whe

Read a complete binary message from async stream. Args: reader: asyncio StreamReader Returns: dict:

\ Relaunch the master and workers.

Run a benchmark with specified parameters. Each concurrent worker maintains a persistent connection to the arbiter and makes

Send an informational response (1xx) on a stream. This is used for 103 Early Hints and other 1xx responses. Informational responses a

Send a simple HTTP response.

Serialize error for protocol transmission.

Wait until Unix socket exists.

Warm up the pool with a few requests.

Close the socket connection.

Create mock config for HTTP/2.

Create a mock HTTP/2 request.

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request with headers.

Create mock socket for HTTP/2.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create a WebSocketProtocol instance for testing.

Create a WebSocketProtocol instance.

Create an ASGIProtocol instance for testing.

Get or create connection to a worker.

Increment global request counter.

Callback: request is fully received.

ASGI receive callable for lifespan.

Write data to transport, handling connection errors gracefully. Catches exceptions that occur when the client has disconnected: - OSE

Send a close frame.

Send an informational response (1xx) such as 103 Early Hints. Args: status: HTTP status code (100-199) headers: List

Wait for server to become available.

Close the thread-local client (call on worker exit).

Establish async connection to arbiter. Raises: DirtyConnectionError: If connection fails

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Delete a key from a table. Args: table: Table name key: Key to delete Returns: True if

Wait until transport is writable.

Encode a success response message. Args: request_id: Request identifier this responds to result: Result valu

Submit connection to thread pool for processing.

Execute a command in the container.

Get the current number of dirty workers.

SIGQUIT handling

Check if HTTP/2 support is available. Returns: bool: True if the h2 library is installed with minimum required version.

Load multiple dirty apps from a list of import paths. Args: import_paths: List of import path strings Returns: dict: Ma

Build a request message dict. Args: request_id: Unique request identifier (int or str) app_path: Import path of the dirty ap

Build a success response message dict. Args: request_id: Request identifier this responds to result: Result value Retur

\ Maintain the number of workers by spawning or killing as required.

Read next body chunk asynchronously for streaming. Returns: bytes: Next chunk of body data, or None if body is complete.

Process received trailing headers. Args: trailers: List of (name, value) tuples

Send data on a stream. Args: stream_id: The stream ID data: Body data bytes end_stream: Whether this ends

Send data on a stream. Args: stream_id: The stream ID data: Body data bytes end_stream: Whether this ends

Send trailing headers on a stream. Trailers are headers sent after the response body, commonly used for gRPC status codes, checksums,

Determine if the connection should be closed after this request.

\ Spawn the dirty arbiter process. The dirty arbiter manages a separate pool of workers for long-running, blocking operations

Wait for events and dispatch callbacks.

Wait for data to be available on the socket. Uses selectors to wait for the socket to become readable within the given timeout. This

Wait until no gunicorn processes are running.

Build a client-to-server masked WebSocket frame.

Cancel keepalive timer when new request arrives.

Close the async connection.

Create a mock HTTP/2 request with priority.

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request.

Create an ASGIProtocol instance for testing.

Create WebSocketProtocol with mock transport.

Create WebSocketProtocol with mock transport.

Create an ASGIProtocol instance for testing.

Create a WebSocketProtocol instance.

Create a WebSocketProtocol with optional subprotocols.