^jUddlZddlZddlmZmZddlmZmZedZdZ e e d<dgZ dZ Gd d ZGd d ZGd deeZy)N)CallableIterable)GenericTypeVarT_ENCODING_VERSIONAppendingByteSerializercPeZdZd dZdeddfdZdeddfdZdeddfd Z defd Z y) BytesWriterreturnNc,tt|_yN) bytearrayCHECKSUM_DIGEST_SIZE_dataselfs q/var/www/ramen.bs-engineer-server.com/venv/lib/python3.12/site-packages/torch/utils/_appending_byte_serializer.py__init__zBytesWriter.__init__s34 ic^|jj|jdddyNbigF byteordersigned)rextendto_bytes)rrs r write_uint64zBytesWriter.write_uint64s# !**Q%*FGrscntj|jd}|j|yNzutf-8)base64 b64encodeencode write_bytes)rr$payloads r write_strzBytesWriter.write_strs)""188G#45 !rbcn|jt||jj|yr)r#lenrr!)rr-s rr*zBytesWriter.write_bytes!s& #a&! !rctj|jtdj ddd}t |tk7r t d||jdtt|jS)Nr rFr,Computed checksum digest has unexpected sizer)zlibcrc32rrr"r/AssertionErrorbytes)rdigests rr"zBytesWriter.to_bytes%spDJJ';'<=>GG uH  v;. . !OP P-3 1)*TZZ  rrN) __name__ __module__ __qualname__rintr#strr,r5r*r"rrr r sO5HcHdH"3"4"Ut!%!rr cLeZdZdeddfdZdefdZdefdZde fdZ defdZ y) BytesReaderdatarNc@t|tkr tdtj|tdj ddd}t|tk7r td|dt|k7rt d|dtd |||_t|_y) Nz+Input data is too short to contain checksumr rFrr1rz>Bytes object is corrupted, checksum does not match. Expected: z, Got: ) r/rr4r2r3r" RuntimeErrorr_i)rr@r6s rrzBytesReader.__init__0s t9+ + !NO OD!5!678AA uB  v;. . !OP P & '6 1!!$89!DGGdggn5 4 r) r8r9r:r5rboolrEr;rIr<rNrLr=rrr?r?/sG'U't'$*T*SC#CErr?ceZdZUdZeeegdfed<eed<deeegdfddfdZddZ d eddfd Z d e eddfd Z de fd Zed e deegefdeefdZy)r z Provides efficient serialization and deserialization of list of bytes Note that this does not provide any guarantees around byte order N _serialize_fn_writer serialize_fnrc2||_|jyr)rSclear)rrUs rrz AppendingByteSerializer.__init__ds * rc`t|_|jjtyr)r rTr#r rs rrWzAppendingByteSerializer.clearls"}  !!"34rr@c<|j|j|yr)rSrT)rr@s rappendzAppendingByteSerializer.appendqs 4<<.relemsc4|D]}|j|yr)rZ)rr[elems rr!zAppendingByteSerializer.extendts D KK  rc6|jjSr)rTr"rs rr"z AppendingByteSerializer.to_bytesxs||$$&&rdeserialize_fnct|}|jtk7rtd|jg}|j s(|j |||j s(|S)NzVEncoding version mismatch in AppendingByteSerializer.to_list, got )r?rIr r4rErZ)r@r_readerrHs rto_listzAppendingByteSerializer.to_list{s{T"    #4 4 ++-.0  $$& MM.0 1$$& rr7)r8r9r:__doc__rr r__annotations__rrWrZrr!r5r" staticmethodr?listrbr=rrr r [s [!,d233  Q/56  5 /1//HQKD'%' e +9I0J tTUw  r)r'r2collections.abcrrtypingrrrr r;rd__all__rr r?r r=rrrjs\ .# CL3 $ %!!4$$X,gaj,r