+ jaRt^RIt^RIt^RIt^RIHt^RIHtRt^t ^t ^t ^t ^t ^t^t^t^tRtRtRtRtR tR tR tR t] ]] ]] ]] ]]]]]]]]]/t]P74UUu/uFwrWbK uppt^t^t^t^t ^t!^t"^t#^t$^ t%^ t&^t'^t(R t)]PT!])4t+Rt,!RR4t-]-t.RRRllt/RRlt0RRlt1RRlt2RRlt3R RRllt4R!RRllt5R#uuppi)"a6 Dirty Worker Binary Protocol Binary message framing over Unix sockets, inspired by OpenBSD msgctl/msgsnd. Replaces JSON protocol for efficient binary data transfer. Header Format (16 bytes): +--------+--------+--------+--------+--------+--------+--------+--------+ | Magic (2B) | Ver(1) | MType | Payload Length (4B) | +--------+--------+--------+--------+--------+--------+--------+--------+ | Request ID (8 bytes) | +--------+--------+--------+--------+--------+--------+--------+--------+ - Magic: 0x47 0x44 ("GD" for Gunicorn Dirty) - Version: 0x01 - MType: Message type (REQUEST, RESPONSE, ERROR, CHUNK, END) - Length: Payload size (big-endian uint32, max 64MB) - Request ID: uint64 (replaces UUID string) Payload is TLV-encoded (see tlv.py). N)DirtyProtocolError) TLVEncodersGDrequestresponseerrorchunkendstashstatusmanagez>2sBBIQc4a]tRt^btoRt]t]t]t] t ] t ] t]t]t]t]t]V3RlRl4t]V3RlRl4t]R&V3RlRll4t]V3R lR l4t]V3R lR l4t]V3R lRl4t]V3RlRl4t]V3RlRl4t]R'V3RlRll4t ]R(V3RlRll4t!]V3RlRl4t"]V3RlRl4t#]V3RlRl4t$]V3RlRl4t%]V3RlR l4t&]V3R!lR"l4t']V3R#lR$l4t(R%t)Vt*R#))BinaryProtocolz-Binary message protocol for dirty worker IPC.c2<V^8dQhRS[RS[RS[RS[/#)msg_type request_idpayload_lengthreturnintbytes)format __classdict__s"L/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/dirty/protocol.py __annotate__BinaryProtocol.__annotate__ss) 7 7 7 7c 7e 7c N\P!\\\VW!4#)z Encode the 16-byte message header. Args: msg_type: Message type (MSG_TYPE_REQUEST, etc.) request_id: Unique request identifier (uint64) payload_length: Length of the TLV-encoded payload Returns: bytes: 16-byte header )structpack HEADER_FORMATMAGICVERSION)rrrs&&&r encode_headerBinaryProtocol.encode_headerrs {{=%()7 7rc&<V^8dQhRS[RS[/#rdatarrtuple)rrs"rrrs.,.,E.,e.,rc \V4\8d!\R\V4 R\ 2VR7h\P!\ VR\4wrr4pV\ 8wd!\RV: R\ : 2VR,R7hV\8wd\RV R\ 2VR,R7hV\9d\R VR 2VR,R7hV\8d\R V R \ R 24hW5V3#)z Decode the 16-byte message header. Args: data: 16 bytes of header data Returns: tuple: (msg_type, request_id, payload_length) Raises: DirtyProtocolError: If header is invalid zHeader too short:  bytes, expected raw_dataNzInvalid magic: z , expected :NNzUnsupported protocol version: zUnknown message type: 0x02xzMessage too large: z bytes (max: )) len HEADER_SIZErrunpackr r!r"MSG_TYPE_TO_STRMAX_MESSAGE_SIZE)r'magicversionrlengthrs& r decode_headerBinaryProtocol.decode_headers t9{ "$$SYK/@ N  8>}} 4 -8 4* E>$!%+eY?c  g $0 WINc  ? *$*8C.9c  $ $$%fX];K:LAN V++rNc ><V^8dQhRS[RS[RS[RS[RS[RS[/#)rrapp_pathactionargskwargsr)rstrr)dictr)rrs"rrrs:  3 # s " 37 CH rc  RTRTRV'd \V4M.RT;'g//p\P!V4p\P \ V\ V44pWv,#)a Encode a request message. Args: request_id: Unique request identifier (uint64) app_path: Import path of the dirty app action: Action to call on the app args: Positional arguments kwargs: Keyword arguments Returns: bytes: Complete message (header + payload) r<r=r>r?)listrencoder r#MSG_TYPE_REQUESTr1)rr<r=r>r? payload_dictpayloadheaders&&&&& rencode_requestBinaryProtocol.encode_requestsd"  f $DJB fll  ##L1--.> .1'l<rc&<V^8dQhRS[RS[/#rrrr)rrs"rrrs  C E rc RV/p\P!V4p\P\V\ V44pWC,#)z Encode a success response message. Args: request_id: Request identifier this responds to result: Result value (must be TLV-serializable) Returns: bytes: Complete message (header + payload) result)rrDr r#MSG_TYPE_RESPONSEr1)rrNrFrGrHs&& rencode_responseBinaryProtocol.encode_responsesC!&) ##L1--.?.1'l<rc&<V^8dQhRS[RS[/#rLr)rrs"rrrs    rc X^RIHp\W4'dVP4pM=\V\4'dTpM$R\ V4P R\V4R//pRV/p\P!V4p\P\V\V44pWe,#)z Encode an error response message. Args: request_id: Request identifier this responds to error: DirtyError instance, dict, or Exception Returns: bytes: Complete message (header + payload)  DirtyError error_typemessagedetailsr)errorsrU isinstanceto_dictrAtype__name__r@rrDr r#MSG_TYPE_ERRORr1)rrrU error_dictrFrGrHs&& r encode_errorBinaryProtocol.encode_errors ' e ( (J t $ $Jd5k223u:2J  , ##L1--nj.1'l<rc&<V^8dQhRS[RS[/#rLr)rrs"rrrs   u rc RV/p\P!V4p\P\V\ V44pWC,#)z Encode a chunk message for streaming responses. Args: request_id: Request identifier this chunk belongs to data: Chunk data (must be TLV-serializable) Returns: bytes: Complete message (header + payload) r')rrDr r#MSG_TYPE_CHUNKr1)rr'rFrGrHs&& r encode_chunkBinaryProtocol.encode_chunksA~ ##L1--nj.1'l<rc&<V^8dQhRS[RS[/#rLr)rrs"rrrs  s u rc <\P\V^4pV#)z Encode an end-of-stream message. Args: request_id: Request identifier this ends Returns: bytes: Complete message (header + empty payload) )r r# MSG_TYPE_ENDrrHs& r encode_endBinaryProtocol.encode_ends --lJJ rc&<V^8dQhRS[RS[/#rLr)rrs"rrr!s  # % rc <\P\V^4pV#)z Encode a status query message. Args: request_id: Request identifier Returns: bytes: Complete message (header + empty payload) )r r#MSG_TYPE_STATUSrjs& r encode_statusBinaryProtocol.encode_status s --oz1M rc2<V^8dQhRS[RS[RS[RS[/#)rropcountrr)rrs"rrr0s)  # 3 s 5 rc RVRV/p\P!V4p\P\V\ V44pWT,#)z Encode a worker management message. Args: request_id: Request identifier op: Management operation (MANAGE_OP_ADD or MANAGE_OP_REMOVE) count: Number of workers to add/remove Returns: bytes: Complete message (header + payload) rsrt)rrDr r#MSG_TYPE_MANAGEr1)rrsrtrFrGrHs&&& r encode_manageBinaryProtocol.encode_manage/sK " U ##L1--oz.1'l<rc2<V^8dQhRS[RS[RS[RS[/#)rrrstabler)rr@r)rrs"rrrFs*   # c CCc:<V^8dQhRS[PRS[/#)rreaderr)asyncio StreamReaderrA)rrs"rrrs!99)=)=9$9rc "VP\4GRjxL p\PT4wr4pT^8d3TPT4GRjxL p\P!T4pM/p\T,pRTR T/p T PT4T #L} \PdUp\ TP 4^8Xdh\ R\ TP 4 R\ 2TP R7hRp?ii;iL \Pd6p\ R\ TP 4 RT 2TP R7hRp?ii;i \ dh\dp\ RT 2TR,R7hRp?ii;i5i) a( Read a complete binary message from async stream. Args: reader: asyncio StreamReader Returns: dict: Message dict with 'type', 'id', and payload fields Raises: DirtyProtocolError: If read fails or message is malformed asyncio.IncompleteReadError: If connection closed mid-read NzIncomplete header: got r+r,zIncomplete payload: got rrr\id) readexactlyr2rIncompleteReadErrorr1partialrr r9rrrr4update) rrHrrrr8rrFrrNs & rread_message_async!BinaryProtocol.read_message_asyncs !--k::F(6'C'CF'K$f A: %+%7%7%??  )55lC L'x0 ,j9 l# S;** 199~"$)#aii.)9:'=*    @.. (.s199~.>? &x)YY &  (4QC8)#. sF BBBF D DD E1)F BD1ADDF D E0EEF F ,F -FF  F c><V^8dQhRS[PRS[RR/#)rwriterrWrN)r StreamWriterrA)rrs"rrrs*'*>*>+/48rc "\PV4pVPV4VP4GRjxL R#L5i)a Write a message to async stream. Accepts dict format for backwards compatibility. Args: writer: asyncio StreamWriter message: Message dict with 'type', 'id', and payload fields Raises: DirtyProtocolError: If encoding fails ConnectionError: If write fails N)r _encode_from_dictwritedrain)rrWr's&& rwrite_message_async"BinaryProtocol.write_message_asyncs2 //8 Tllns:AAAc@<V^8dQhRS[PRS[RS[/#)rsocknr)socketrr)rrs"rrrs&FMMcerc Rp\V4V8dkVPV\V4, 4pV'g8\V4^8Xd \R4h\R\V4 RV 2VR7hW#, pKzV#)z Receive exactly n bytes from a socket. Args: sock: Socket to read from n: Number of bytes to read Returns: bytes: Received data Raises: DirtyProtocolError: If read fails or connection closed rzConnection closedzConnection closed after r+r,)r1recvr)rrr'rs&& r _recv_exactlyBinaryProtocol._recv_exactlysw$i!mIIa#d)m,Et9>,-@AA(.s4yk9J1#N! MD rc:<V^8dQhRS[PRS[/#)rrrrrA)rrs"rrrs%%6==%T%rc \PV\4p\PV4wr#pV^8d.\PW4p\P !V4pM/p\V,pRVRV/p V PV4V # \ dh\dp\ RT 2TR,R7hRp?ii;i)z Read a complete message from socket (sync). Args: sock: Socket to read from Returns: dict: Message dict with 'type', 'id', and payload fields Raises: DirtyProtocolError: If read fails or message is malformed rrr,Nr\r) r rr2r9rrrrr4r) rrHrrr8rrFrrrNs & r read_messageBinaryProtocol.read_messages --dK@'5'C'CF'K$f A:)77EL )55lC L'x0 ,j9 l# &  (4QC8)#. sBC$C%B<<Cc><V^8dQhRS[PRS[RR/#)rrrWrNr)rrs"rrr0s&  FMM D T rc R\PV4pVPV4R#)z Write a message to socket (sync). Args: sock: Socket to write to message: Message dict with 'type', 'id', and payload fields Raises: DirtyProtocolError: If encoding fails OSError: If write fails N)r rsendall)rrWr's&& r write_messageBinaryProtocol.write_message/s //8 Trc&<V^8dQhRS[RS[/#)rrWr)rAr)rrs"rrr@s#CLCL4CLECLrc  VPR4pVPR^4p\V\4'd\V4R,p\PV4pVf\ RV 24hV\ 8XdX\PVVPRR4VPRR4VPR4VPR 44#V\8Xd&\PVVPR 44#V\8Xd'\PVVPR /44#V\8Xd&\PVVPR 44#V\8Xd\P!V4#V\"8Xdg\P%VVPR 4VPRR4VPR4VPR4VPR44#V\&8Xd\P)V4#V\*8Xd7\P-VVPR 4VPR^44#\ RV 24h)z Encode a message dict to binary format. Supports the old dict-based API for backwards compatibility. Args: message: Message dict with 'type', 'id', and payload fields Returns: bytes: Complete encoded message r\rlzUnknown message type: r<r=r>r?rNrr'rsrzr|r}r~rtzUnhandled message type: )getrZr@hashMSG_TYPE_FROM_STRrrEr rIrOrPr^r`rdrerirkrrrorprvrw)rWrrrs& rr BinaryProtocol._encode_from_dict?s#{{6* [[q)  j# & &j),>>J$((6  $'=l^%LM M ' '!00 J+ Hb) F# H%  * *!11 H%  '!.. GR(  '!.. F#  %!,,Z8 8  '!.. D! GR( E" G$ I&   (!// ; ;  (!// D! GQ'  %'?z%JK KrNNNNN)+r] __module__ __qualname____firstlineno____doc__r2r5MSG_TYPE_REQUEST_STRrEMSG_TYPE_RESPONSE_STRrOMSG_TYPE_ERROR_STRr^MSG_TYPE_CHUNK_STRrdMSG_TYPE_END_STRriMSG_TYPE_STASH_STRrMSG_TYPE_STATUS_STRroMSG_TYPE_MANAGE_STRrv staticmethodr#r9rIrPr`rerkrprwrrrrrrrr__static_attributes____classdictcell__)rs@rr r bs7K'+-'N'N#L'N)O)O 7 7.,.,`   4  "  <  "       *   @*6*6`99v.6%%N  CLCLrr c TV^8dQhR\R\R\R\R\/#)rr<r=r>r?r)r@r)rA)rs"rrrs2sC-1=Arc tR\PRTRTRTRV'd \V4M.RT;'g//#)a- Build a request message dict. Args: request_id: Unique request identifier (int or str) app_path: Import path of the dirty app (e.g., 'myapp.ml:MLApp') action: Action to call on the app args: Positional arguments kwargs: Keyword arguments Returns: dict: Request message dict r\rr<r=r>r?) DirtyProtocolrErC)rr<r=r>r?s&&&&&r make_requestrs@  .. jH&dT &,,B  rc$V^8dQhR\/#rrrA)rs"rrrsrc.R\PRVRV/#)z Build a success response message dict. Args: request_id: Request identifier this responds to result: Result value Returns: dict: Response message dict r\rrN)rrO)rrNs&&r make_responsers#  // j& rc$V^8dQhR\/#rr)rs"rrrsdrc^RIHp\W4'dVP4pM=\V\4'dTpM$R\ V4P R\V4R//pR\PRVRV/#)z Build an error response message dict. Args: request_id: Request identifier this responds to error: DirtyError instance or dict with error info Returns: dict: Error response message dict rTrVrWrXr\rr) rYrUrZr[rAr\r]r@rr^)rrrUr_s&& rmake_error_responsersv#%$$]]_ E4   $u+.. s5z r   ,, j rc$V^8dQhR\/#rr)rs"rrrsDrc.R\PRVRV/#)z Build a chunk message dict for streaming responses. Args: request_id: Request identifier this chunk belongs to data: Chunk data Returns: dict: Chunk message dict r\rr')rrd)rr's&&rmake_chunk_messagers#  ,, j rc$V^8dQhR\/#rr)rs"rrrs  D rc*R\PRV/#)z Build an end-of-stream message dict. Args: request_id: Request identifier this ends Returns: dict: End message dict r\r)rri)rs&rmake_end_messagers  ** j rc<V^8dQhR\R\R\/#)rrsrzr)rr@rA)rs"rrrs"s3>BrcfR\PRVRVRV/pVeW6R&VeWFR&VeWVR&V#)a] Build a stash operation message dict. Args: request_id: Unique request identifier (int or str) op: Stash operation code (STASH_OP_*) table: Table name key: Optional key for put/get/delete operations value: Optional value for put operation pattern: Optional pattern for keys operation Returns: dict: Stash message dict r\rrsrzr|r}r~)rr)rrsrzr|r}r~msgs&&&&&& rmake_stash_messagersR"  ,, j b  C  E  G  I Jrc<V^8dQhR\R\R\/#)rrsrtr)rrA)rs"rrrs!Crc2R\PRVRVRV/#)z Build a worker management message dict. Args: request_id: Unique request identifier (int or str) op: Management operation (MANAGE_OP_ADD or MANAGE_OP_REMOVE) count: Number of workers to add/remove Returns: dict: Manage message dict r\rrsrt)rrv)rrsrts&&&rmake_manage_messagers(  -- j b  rirrr)6rrrrrYrtlvrr!r"rErOr^rdrirrorvrrrrrrrrr4itemsr STASH_OP_PUT STASH_OP_GETSTASH_OP_DELETE STASH_OP_KEYSSTASH_OP_CLEAR STASH_OP_INFOSTASH_OP_ENSURESTASH_OP_DELETE_TABLESTASH_OP_TABLESSTASH_OP_EXISTS MANAGE_OP_ADDMANAGE_OP_REMOVEr calcsizer2r5r rrrrrrrr)kvs00rrs , &   !"*,&&"&(( '6&;&;&=>&=daQT&=>      oom, $aLaLR 2$<$  >c?s$ C!