Create WebSocketProtocol with mock transport.

Return the client address advertised via PROXY protocol if any. Falls back to the transport peername when PROXY protocol is disabled,

Extract close code from WebSocket close frame.

Get the well-known PID file path for orphan detection. Uses self.proc_name (not self.cfg.proc_name) so that during USR2 the new maste

Handle response message, extracting result or raising error.

Send response body chunk. Combines buffered headers with first body chunk for efficient write batching.

Setup the asyncio event loop.

Gets atoms for log formatting.

Create an HTTP/2 connection using the h2 library.

Create a worker for testing.

Decode a complete TLV-encoded value, ensuring all data is consumed. Args: data: Binary data to decode Returns:

Queue a callback to be run on the main thread. The callback is added to the queue first, then a wake-up byte is written to the pipe.

Cancel a protocol task and let the loop deliver the cancellation. Closing the loop on a task suspended mid-await leaves the coroutine to be c

Feed a body chunk directly (called by parser callback).

Calculate statistics from list of latency samples.

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.

Drive _handle_http2_request and report what reached the wire.

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

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

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.

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

Mark trailers as sent and close the stream. Args: trailers: List of (name, value) trailer tuples Raises: HTT

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.

Nothing conclusive arrived in time. With prior knowledge alone the peer is expected to speak HTTP/2, so stalling mid-preface is refus

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.

Remove a stream after processing is complete.

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

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

Called when a connection is established.

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

Close the sending half of a stream, with trailers if given.

Submit connection to thread pool for processing.

Execute a command in the container.

Get the current number of dirty workers.

SIGQUIT handling

Switch a connection to HTTP/2 after an Upgrade: h2c request. The upgraded request becomes stream 1 (RFC 7540 section 3.2). h2 opens i

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