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.

\ 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 an error response on a stream.

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.

Arm keepalive timeout timer after response completion.

Async version of parse() - reads data then uses sync parsing.

Read exactly size bytes asynchronously.

Build minimal environ dict for access logging.

Build receive result after waiting for data.

Check whether calling a function raised a ``TypeError`` because the call failed or because something in the function raised the error. :p

Check if fast C parser is available and should be used. Returns False if: - http_parser='python' is explicitly set - gunicorn_h1c is not

Check if H1CProtocol is available (cached at class level).

Clean up resources on exit.

Establish connection to arbiter.

Establish SMTP connection (simulated for demo).

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.

Dispatch command to appropriate handler. Args: message: Request message dict Returns: Response dict

Execute a parsed command. Args: parts: Command parts (e.g., ["show", "workers"]) Returns: Handler r

Execute while holding the lock.

Feed data to callback parser, handling parse errors. Returns True if parsing should continue, False if connection was closed.

Called when all headers received. Validates headers for request smuggling vulnerabilities: - Rejects duplicate Content-Length headers

Get ALPN protocol list from configuration. Returns list of ALPN protocol identifiers based on http_protocols setting. Returns empty list if H

Get all buffered data and reset buffer.

Get cached Date header, updating once per second.

Get cached status line bytes.

Get the control socket path, making relative paths absolute.

Generate a unique request ID.

Match prompt to a canned response. Args: prompt: User's input prompt Returns: str: Matched response text

Get SSL context if configured.

Handle incoming close frame.

Main request handling loop using callback-based parser. Uses synchronous parsing in data_received(), avoiding the async overhead of p

Handle ConnectionTerminated event (GOAWAY frame). Args: event: ConnectionTerminated event

Handle ConnectionTerminated event.

Handle uWSGI protocol connections (legacy path).

Handle continuation frame (already processed in _read_frame).

Handle DataReceived event. Args: event: DataReceived event with body data Returns: None (request completion