iI SrSSKrSSKr"SS\5r"SS5rSS\S\S \S \ 4S jjr SS\S \ S \ 4S jjr S\S\S \ 4Sjr g)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\rSrSrSrSrg) ProtocolErrorzProtocol-level error.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rG/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/ctl/protocol.pyrrsr rc\rSrSrSrSr\S\S\4Sj5r \S\S\4Sj5r \S\4Sj5r \S\4S j5r \S\4S j5r \S\4S j5rS rg )ControlProtocolz{ Protocol implementation for control socket communication. Uses 4-byte big-endian length prefix followed by JSON payload. idatareturnc[R"U5RS5n[R"S[ U55nX!-$)zs Encode a message for transmission. Args: data: Dictionary to encode Returns: Length-prefixed JSON bytes utf-8>I)jsondumpsencodestructpacklen)rpayloadlengths rencode_messageControlProtocol.encode_message)s:**T"))'2T3w<0r c[U5S:a [S5e[R"SUSS5Sn[U5SU-:a [S5eUSSU-n[R "UR S55$)zy Decode a message from bytes. Args: data: Raw bytes (length prefix + JSON payload) Returns: Decoded dictionary zMessage too shortrNrzIncomplete messager)rrrunpackrloadsdecode)rrrs rdecode_messageControlProtocol.decode_message8sz t9q= 34 4tT"1X.q1 t9q6z ! 45 5qV$zz'..122r cSn[U5S:aVURS[U5- 5nU(dU(d [S5e[S5eX- n[U5S:aMV[R "SU5SnU[ R:a[SU35eSn[U5U:aNUR[U[U5- S55nU(d [S 5eXB- n[U5U:aMN[R"URS 55$![Ran[S U35eS nAff=f) 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 r"zConnection closedzIncomplete length prefixrrMessage too large: izIncomplete payloadrInvalid JSON: N) rrecvConnectionErrorrrr#rMAX_MESSAGE_SIZEminrr$r%JSONDecodeError)sock length_datachunkr payload_dataes r read_messageControlProtocol.read_messageMs;  +"IIa#k"223E")*=>>#$>??  K +"t[1!4 O44 4"5fX >? ? ,&(IIc&3|+<"? ?$//77  6::l11':; ;28## 6. 45 5 6sFCBAC,B-C2$BCCC/B==CCc# [RU5nURU5 UR5IShvN gN7f)zt Write one message to an async writer. Args: writer: asyncio StreamWriter data: Message dictionary to send N)rrwritedrain)writerrr9s rwrite_message_async#ControlProtocol.write_message_asyncs2"006 Wllns:AAArN)rrr r r r- staticmethoddictbytesrr&r5r:r?rEr rr rrrs(  T  e    3U3t33((6d(6(6T $  6D662   r r request_idcommandargsrc UUU=(d /S.$)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 )idrKrLr)rJrKrLs r make_requestrOs  r rc USU=(d 0S.$)z Create a success response message. Args: request_id: Request identifier being responded to data: Response data Returns: Response dictionary ok)rNstatusrr)rJrs r make_responserSs  r errorcUSUS.$)z Create an error response message. Args: request_id: Request identifier being responded to error: Error message Returns: Error response dictionary rT)rNrRrTr)rJrTs rmake_error_responserVs r )N) r rr ExceptionrrintstrlistrHrOrSrVrr rr[s $  I JJZS3dd&c$Cr