+ jIpRt^RIt^RIt!RR]4t!RR4tR RRlltR RR lltR R ltR#) a Control Socket Protocol JSON-based protocol with length-prefixed framing for the control interface. Message Format: +----------------+------------------+ | Length (4B BE) | JSON Payload | +----------------+------------------+ Request Format: {"id": 1, "command": "show", "args": ["workers"]} Response Format: {"id": 1, "status": "ok", "data": {...}} {"id": 1, "status": "error", "error": "message"} Nc]tRt^tRtRtR#) ProtocolErrorzProtocol-level error.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rJ/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/ctl/protocol.pyrrsr rca]tRt^toRtRt]V3RlRl4t]V3RlRl4t]V3RlRl4t ]V3RlR l4t ]V3R lR l4t ]V3R lR l4t Rt VtR#)ControlProtocolz{ Protocol implementation for control socket communication. Uses 4-byte big-endian length prefix followed by JSON payload. c&<V^8dQhRS[RS[/#datareturn)dictbytes)format __classdict__s"r __annotate__ControlProtocol.__annotate__*s   T  e  r c \P!V4PR4p\P!R\ V44pW!,#)zs Encode a message for transmission. Args: data: Dictionary to encode Returns: Length-prefixed JSON bytes utf-8>I)jsondumpsencodestructpacklen)rpayloadlengths& r encode_messageControlProtocol.encode_message)s:**T"))'2T3w<0r c&<V^8dQhRS[RS[/#r)rr)rrs"r rr9s33U3t3r c (\V4^8d \R4h\P!RVR,4^,p\V4^V,8d \R4hV^^V,p\P !VP R44#)zy Decode a message from bytes. Args: data: Raw bytes (length prefix + JSON payload) Returns: Decoded dictionary zMessage too shortr:NNzIncomplete messager)r"rr unpackrloadsdecode)rr$r#s& r decode_messageControlProtocol.decode_message8sx t9q= 34 4tT"X.q1 t9q6z ! 45 5qV$zz'..122r c <V^8dQhRS[/#rrr)rrs"r rrNs(6(6d(6r c Rp\V4^8dRVP^\V4, 4pV'gV'g \R4h\R4hW, pKa\P !RV4^,pV\ P8d\RV 24hRp\V4V8dIVP\V\V4, R44pV'g \R4hWB, pKX\P!VPR44# \Pdp\R T 24hR p?ii;i) z Read one message from a socket. Args: sock: Socket to read from Returns: Decoded message dictionary Raises: ProtocolError: If message is malformed ConnectionError: If connection is closed r zConnection closedzIncomplete length prefixrMessage too large: izIncomplete payloadrInvalid JSON: N) r"recvConnectionErrorrr r*rMAX_MESSAGE_SIZEminrr+r,JSONDecodeError)sock length_datachunkr$ payload_dataes& r read_messageControlProtocol.read_messageMs  +"IIa#k"223E")*=>>#$>??  Kt[1!4 O44 4"5fX >? ? ,&(IIc&3|+<"s& r read_message_async"ControlProtocol.read_message_asyncs#..q11 t[1!4 O44 4"5fX >? ?$//77  6::l11':; ;28## 6. 45 5 6sFC BAC 1B2C 7$B C C  C5CCC c <V^8dQhRS[/#rBr1)rrs"r rrs   r c "\PV4pVPV4VP4GRjxL R#L5i)zt Write one message to an async writer. Args: writer: asyncio StreamWriter data: Message dictionary to send N)rr%writedrain)writerrrEs&& r write_message_async#ControlProtocol.write_message_asyncs2"006 Wllns:AAArNi)rrrrr r7 staticmethodr%r-r?rFrLrSr __classdictcell__)rs@r rrs(    33((6(6T  662  r rcHV^8dQhR\R\R\R\/#)r request_idcommandargsr)intstrlistr)rs"r rrs(S3ddr c&RTRTRT;'g./#)z Create a request message. Args: request_id: Unique request identifier command: Command name (e.g., "show workers") args: Optional list of arguments Returns: Request dictionary idrYrZr)rXrYrZs&&&r make_requestr`s# j7  r c<V^8dQhR\R\R\/#)rrXrr)r[r)rs"r rrs!cr c&RTRRRT;'g//#)z Create a success response message. Args: request_id: Request identifier being responded to data: Response data Returns: Response dictionary r_statusokrr)rXrs&&r make_responseres# j$  r c<V^8dQhR\R\R\/#)rrXerrorr)r[r\r)rs"r rrs!Cr cRVRRRV/#)z Create an error response message. Args: request_id: Request identifier being responded to error: Error message Returns: Error response dictionary r_rcrgr)rXrgs&&r make_error_responseris j' r )N) r rr Exceptionrrr`rerirr r rks: $  I JJZ&$r