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:

Return cached network objects for forwarded_allow_ips (internal use).

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

Switch this connection to HTTP/2 and serve the upgraded request. The client may already have sent HTTP/2 frames behind the upgrade re

Handle an HTTP/2 connection. Runs in a worker thread. HTTP/2 connections are persistent and multiplex multiple streams. We handle all

Handle an HTTP/2 connection. Processes multiplexed HTTP/2 streams until the connection closes. ``preface`` carries connection prefac

Handle a single HTTP/2 request/stream.

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

get list of all loggers

Create uWSGI packet with body for testing.

Close expired pending connections (waiting for initial data).

Kill workers that have timed out.

Whether this peer may negotiate cleartext HTTP/2. Reuses the ``forwarded_allow_ips`` trust list: h2c is only ever expected from the TLS-termi

\ Reap the dirty arbiter process if it has exited.

Reload workers (SIGHUP handling).

Trigger graceful reload (equivalent to SIGHUP). Returns: Dictionary with status

Reopen log files (equivalent to SIGUSR1). Returns: Dictionary with status

Resize an image. Equivalent to Celery: @app.task def resize_image(image_path, width, height):

\ The ``gunicorn`` command line runner for launching Gunicorn with generic WSGI applications.

\ This is the mainloop of a worker process. You should override this method in a subclass to provide the intended behaviour fo

Send an error response.

Send response headers on a stream without ending it. Returns False if the stream is already gone. Split out of send_response() so a r

Convert ASGI scope to JSON-serializable dict.

Convert ASGI scope to JSON-serializable dict.

Convert ASGI scope to JSON-serializable dict.

Convert ASGI scope to JSON-serializable dict.

Convert ASGI scope to JSON-serializable dict.

Check if connection should close after this request. HTTP/2 connections are persistent by design, but we may still need to close if e

Return current effective configuration. Returns: Dictionary of configuration values

Return dirty workers and apps information. Returns: Dictionary with: - enabled: Whether dirty arbiter is run

Return server statistics. Returns: Dictionary with: - uptime: Seconds since arbiter started - pi

Stream response lines from URL.

Return read-ahead already held, without touching the source. read() blocks on the source when the buffer is empty, which is wrong for