Create a WebSocketProtocol instance.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Create an ASGIProtocol instance for testing.

Lazily import gunicorn_h1c if available.

Reset buffer for reuse instead of creating new BytesIO.

Send an error response.

Send a WebSocket frame. Server frames are not masked (RFC 6455).

Initiate async shutdown.

Stop server before fork (called by fork handler).

Wake up any pending receive() call.

Periodically check worker health and manage pool.

WSGI application that demonstrates dirty worker integration.

Validate configuration for ASGI worker.

Close the async connection.

Create a test worker for benchmarks.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Create a worker for testing.

Spawn additional dirty workers. Sends a MANAGE message to the dirty arbiter to spawn workers. Args: count: Numb

Remove dirty workers. Sends a MANAGE message to the dirty arbiter to remove workers. Args: count: Number of dir

Drain the request body.

Get PIDs of gunicorn processes.

Extract a header value from h2 headers list. h2 library may return headers as bytes or strings depending on version.

Extract HTTP/2 pseudo-headers from request headers. Returns: dict: Mapping of pseudo-header names to values (e.

Get regular (non-pseudo) headers from request. Returns: list: List of (name, value) tuples for regular headers

Initialize database connection and cache.

\ Initialize master signal handling. Most of the signals are queued. Child signals only wake up the master.

\ Send a signal to the dirty arbiter. :attr sig: `signal.SIG*` value

\ Kill all workers with the signal `sig` :attr sig: `signal.SIG*` value

Close expired keepalive connections.

\ Kill unused/idle workers

Return cached network objects for proxy_allow_ips (internal use).

Read a complete message from socket (sync). Args: sock: Socket to read from Returns: dict: Message

Read SSE events from a streaming response. Stops when receiving a 'complete' or 'error' event, or max_events reached.

Read all lines from the body. Args: hint: Approximate byte count hint Returns: list: List of lines

Reap dead worker processes.

Reset for next request (keepalive).

Run the dirty arbiter (blocking call).

Run the main asyncio event loop.

Run queued callbacks. Called when the pipe is readable. Drains all available wake-up bytes and runs corresponding callbacks. The max_

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

Enable or disable accepting new connections.

Return overview of all processes (arbiter, web workers, dirty arbiter, dirty workers). Returns: Dictionary with complete

Return bound socket information. Returns: Dictionary with listeners list

Return list of HTTP workers. Returns: Dictionary with workers list containing: - pid: Worker process ID

Signal shutdown and wait for completion. This should be called during graceful shutdown.

Spawn a new dirty worker. Worker app assignment follows these priorities: 1. If there are pending respawns (from dead worker

\ Wait for signals with timeout. Returns a list of signals that were received.

Wake up the arbiter's main loop.

Increase worker count. Args: count: Number of workers to add (default 1) Returns: Dictionary with a

Gracefully terminate a specific worker. Args: pid: Worker process ID Returns: Dictionary with kille

Decrease worker count. Args: count: Number of workers to remove (default 1) Returns: Dictionary wit

Write a message to socket (sync). Args: sock: Socket to write to message: Message dict with 'type', 'id', an

Echo text messages.

Apply per-header policy shared between Python and fast parsers. Mutates ``self._expected_100_continue`` and ``self.scheme`` as needed.

Get size of buffered data.

Cancel the task if it's still pending after grace period.

Verify source IP is in the allowed list.

Check if peer address is in the trusted proxy list. Cached at connection start to avoid repeated IP parsing per request.

Close the connection.

Convert ASGI headers to HTTP/2 format (lowercase string names).

Create a LifespanManager with specific app.

Create a masked WebSocket frame. Args: fin: FIN bit (1 for final, 0 for continuation) opcode: Frame opcode

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request.

Create a mock HTTP request.

Create a WebSocketProtocol instance.

Create a WebSocketProtocol instance for testing.

Create a WebSocketProtocol instance.

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 an ASGIProtocol with worker state.