9iSrSSKJrJrJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKJr \R "\5rSrSR)S\55r\ R,SS:r\(a \r\r\r\r\rO)\R@"5 \!r\"r\!r\\#4r\\ RH4r\ RJr&\ RNr(S r)S r*S r+S r,"S S\-5r."SS\-5r/"SS\/5r0"SS\-5r1S Sjr2S Sjr3S Sjr4S Sjr5\4r6\2r7"SS\-5r8"SS\85r9"SS\85r:\9\:/r;\S:XaSSKr0s/w!s1vvwsc@US::a [SU5$[SSU5$)z?Encode an unsigned integer into a variable sized blob of bytes. compression use_checksumfloat64load_streaming lazy_blobms rr=BsdfSerializer._parse_optionss k< 0 0!A.A%% 1 1 3[AK i 'TU U'",/W   $N3y/rc[U[5(a[U[5(d [ S5eU"5nUR n[U[ 5(d [ S5e[U5S:Xd[U5S:a [S5eX0R;a[RSU-5 URnU(d/nO![U[[45(aUnOU/nUH#n[U[5(aM[ S5e UHnX2R 4UR"U'M X RU'U$)zqAdd an extension to this serializer instance, which must be a subclass of Extension. Can be used as a decorator. z*add_extension() expects a Extension class.Extension name must be str.rrzextension_classrAr]raclsss rr<BsdfSerializer.add_extensions-  - -*_i2X2XHI I#% ~~$$$9: : t9>SY_Q  ## # NN*,01  mmD eT] + +D5DCc:.. BCC C+/1A1A+AD # #C (!*rcR[U[5(d [S5eXR;aURR U5 [ UR R55H6nUR USU:XdMUR R U5 M8 g)z&Remove a converted by its unique name.rYrN)r-r rJr9poprcr:keys)r>r]ras rremove_extensionBsdfSerializer.remove_extensions$$$9: : ## #     &//4467C&&s+A.$6''++C08rcD [nUcURU"SU55 gUSLaURU"SU55 gUSLaURU"SU55 g[U[5(a\SUs=::aS::a)O O&URU"S U5[ S U5-5 gURU"S U5[ S U5-5 g[U[ 5(a]UR (a&URU"S U5[ SU5-5 gURU"SU5[ SU5-5 g[U[5(aPURS5nURU"SU5[[U55-5 URU5 g[U[[45(aJURU"SU5[[U55-5 UHnURXUS5 M g[U[5(aURU"SU5[[U55-5 UR5Hup[ (aUR#5(deO[%U5(deURS5n UR[[U 555 URU 5 URXUS5 M g[U[&5(aHURU"SU55 [)X R*UR,S9n U R/U5 g[U[(5(a*URU"SU55 UR/U5 g[U[05(aUR2S:wa [5S5e[U[65(a'URU"SU5[ SSS5-5 O [9S5e[U5S:a [5S5eUR;U5 UR=XRUR>5 gUb[5SU-5eUR@RCURDS5n U cJURFR5H*upU RIX5(dMXR4n O Sn U bU upURX"X5X>5 gSn[9UURDRJ-5e) zMain encoder function.NvTyFniihhir valuestreamsr)rr*vkeyname_bblobexr]cext_id2extension_encodets rrBsdfSerializer._encodes   = GGAdFO $ d] GGAdFO $ e^ GGAdFO $ } - -'%'$%U*;;<$%e*<<= u % %}}$%e*<<=$%e*<<= } - -g&B GGAdFOgc"g&66 7 GGBK e} - - GGAdFOgc%j&99 : Q7D1 t $ $ GGAdFOgc%j&99 :++-3++----(----G,F ,- Q7D1(u % % GGAdFO $#4#44CUCUD MM!  t $ $ GGAdFO $ NN1  z * *zzS  !GHHE:..$%sA*>>? >??7|a !EFF NN5 ! OOA||T\\ :! >@FG ((,,U__dCBz#//557GDwwt++!88^ 8 B~,.) Q 0 =wP/ EOO$<$< <==rcURS5nUR5nU(d [5eX#:wa?[SURS55SnURU5R S5nOSnUS:XaSnGOUS:XaSnGOUS :XaS nGOwUS :Xa [S URS 55SnGOQUS:Xa [SURS55SnGO+US:Xa [SURS55SnGOUS:Xa [SURS55SnGOUS:Xad[SURS55SnUS:Xa[SURS55SnURU5R S5nGOuUS:XGa;[SURS55SnUS:aUS:Hn[SURS55SnUR (a<[ U(aUOS5nURXRUR5 GOU(a+[U5V s/sHoRU5PM nn GO/nURURU55 M"US:Xa[SURS55Sn[U5V s/sHoRU5PM nn GO3US:Xa[5n[SURS55SnUS:Xa[SURS55Sn[U5Hn [SURS55Sn U S:Xa[SURS55Sn U S:deURU 5R S5n URU5Xk'M OQUS:Xa=UR(a[US45nO,[US 45n U R5nO[!SU-5eUbJUR"R%US5n U bU R X5nU$[&R)SU-5 U$s sn f![a N`f=fs sn f) zMain decoder function.rrrr$NrnroTrpFrqzr charrr!r)rn_sclosedrn_namer]rrAs rrBsdfSerializer._decodeDsvvay JJL*  Y$q *1-AVVAY%%g.FF 9E $YE $YE $YdAFF1I.q1E $YdAFF1I.q1E $YdAFF1I.q1E $YdAFF1I.q1E $YD!&&),Q/CczaffQi03FF3K&&w/E $Y$q *1-ACxcdAFF1I.q1''&Fqobr s rr%BsdfSerializer.encodes! I !zz|rcURS5 UR[R"S[S55 UR[R"S[S55 /nUR XUS5 [ U5S:a/USnUR UR5:wa [S5egg)z0Write the given object to the given file object.BSDFrrrNz8The stream object must be the last object to be encoded.) rstructpackVERSIONrr' _start_postellr)r>r rrstreams rrBsdfSerializer.saves   D'!*-.  D'!*-. QGT* wr*r s rrBsdfSerializer.decodes BKyy|rcURS5nUS:wa[SU-5e[SURS55Sn[SURS55SnSX44-nU[S:waSn[U[U4-5eU[S:a S n[ R U[U4-5 URU5$) z6Load a BSDF-encoded object from the given file object.rrz'This does not look like a BSDF file: %rrrrz%i.%izLReading file with different major version (%s) from the implementation (%s).zWBSDF warning: reading file with higher minor version (%s) than the implementation (%s).)rrrr __version__r_r`r)r>r f4 major_version minor_version file_versionrs rrBsdfSerializer.loadsVVAY =H2MN N!$q 215 !$q 215 -!?? GAJ &0 qK#>>? ? 71: %0  NN1 \:: ;||Ar)rKr9r:rNrPrOrMr )rFTFF)r __module__ __qualname____firstlineno____doc__rBr=r<rkrrr%rrr__static_attributes__r8rrr5r5tsO<' *0)V1Y>vXt & rr5c8\rSrSrSrSSjrSr\S5rSr g) rizBase class for streams.cSUlSUl[U[5(a XlSnO US:XaSUlUS;deXlSUlSUlg)Nrrr})rr})_i_countr-int_mode_fr)r>rs rrBBaseStream.__init__sV dC KD S[DKz!!! rcURb [S5eXlURR5UlX lX0lg)Nz(Stream object cannot be activated twice?)rIOErrorrrrr)r>file encode_func decode_funcs rrBaseStream._activates8 77 DE E'',,." " rcUR$)z$The mode of this stream: 'r' or 'w'.)rr>s rrBaseStream.modeszzr)rrrrrrrN)r}) rrrrrrBrpropertyrrr8rrrrs#! #rrcZ\rSrSrSr\S5r\S5rSrS Sjr Sr Sr S r S r g ) rizbA streamable list object used for writing or reading. In read mode, it can also be iterated over. cUR$)zTThe number of elements in the stream (can be -1 for unclosed streams in read-mode). rrs rcountListStream.counts {{rcUR$)z/The current index of the element to read/write.)rrs rindexListStream.indexs wwrcZURUR:wa [S5eURc [S5eURR(a [S5eUR URX/S5 U=RS- slU=RS- slg)zoAppend an item to the streaming list. The object is immediately serialized and written to the underlying file. z/Can only append items to the end of the stream.Nz.List stream is not associated with a file yet.zCannot stream to a close file.r)rrrrrr)r>items rrListStream.appends} ;;$'' !KL L 77?JK K 77>>:; ; TWWdFD1 1  q rcDURUR:wa [S5eURc [S5eURR(a [S5eURR 5nURR URS- S- 5 URR[SU(aSOS 55 URR[S UR55 URR U5 g) zClose the stream, marking the number of written elements. New elements may still be appended, but they won't be read during decoding. If ``unstream`` is False, the stream is turned into a regular list (not streaming). z-Can only close when at the end of the stream.N-ListStream is not associated with a file yet.z&Cannot close a stream on a close file.rrrrrr) rrrrrrseekrrr)r>unstreamrs rcloseListStream.closes ;;$'' !IJ J 77?IJ J 77>>BC C GGLLN  T__q(1,-  eD#s;<  eD$++./  Qrc6URS:wa [S5eURc [S5e[URSS5(a [S5eURS:aTUR UR:a [ 5eU=R S- slURUR5$URUR5nU=R S- slU$![a UR Ul[ 5ef=f) ziRead and return the next element in the streaming list. Raises StopIteration if the stream is exhausted. rz$This ListStream in not in read mode.Nrrz'Cannot read a stream from a close file.rr) rrrgetattrrr StopIterationrr)r>ress rnextListStream.next,s :: @A A 77?IJ J 477Hd + +CD D ;;! ww$++%#o% GGqLG<<( ( &ll477+1   &"gg #o% &s 1C22&Dc<URS:wa [S5eU$)Nrz/Cannot iterate: ListStream in not in read mode.)rrrs r__iter__ListStream.__iter__Es :: KL L rc"UR5$r )rrs r__next__ListStream.__next__Jsyy{rrN)F)rrrrrrrrrrrrrrr8rrrrsH  (&2 rrcX\rSrSrSrSSjrSrSrSrSr Sr S r S r S r S rS rg)riNa(Object to represent a blob of bytes. When used to write a BSDF file, it's a wrapper for bytes plus properties such as what compression to apply. When used to read a BSDF file, it can be used to read the data lazily, and also modify the data if reading in 'r+' mode and the blob isn't compressed. c[U[5(a>SUlURX5UlX lUR U-UlX@lg[U[5(aX[U5S:XaI[USS5(a5UuUlnSUlURURU5 SUl g[S5e)NrrrFzWrong argument to create Blob.)r-rr _from_bytes compressedrQ used_sizeallocated_sizerRrbr'hasattr _from_file _modifiedrJ)r>r*rQ extra_sizerR allow_seeks rrB Blob.__init__Xs b% DG"..r?DO* "&..:"=D  ,  E " "s2w!|1v8N8N"$ DGZ"DO OODGGZ 0"DN<= =rcUS:XaUnOCUS:Xa[R"US5nO%US:Xa[R"US5nOS5e[U5Ul[U5UlU$)z"When used to wrap bytes in a blob.rr rzUnknown compression identifier)rFcompressrGr' data_sizer)r>rrQrs rrBlob._from_bytesgsf ! J A ua0J A eQ/J :: :5UZrcURS::aURS:XaoUR[SUR55 UR[SUR55 UR[ UR 55 OrUR[SSUR55 UR[SSUR55 UR[SSUR 55 UR[SUR55 UR(aAURS[R"UR5R5-5 OURS5 URS:XaIS UR5S -S -- nUR[SU55 URSU-5 OUR[SS55 URUR5 URSURUR- -5 g ) zBPrivate friend method called by encoder to write a blob to a file.rrrrrBrrN) rrQrrrrr rRhashlibmd5rdigestr)r>r alignments rr Blob._to_filevs   # %$*:*:a*? GGE$ 3 34 5 GGE$/ 0 GGGDNN+ , GGE%d&9&9: ; GGE%dnn5 6 GGE%dnn5 6 c4++,-    GGGgkk$//:AACC D GGG    q QVVX\Q..I GGE$ * + GGGi' ( GGE$N #   4..?@Arc[SURS55SnUS:Xa[SURS55Sn[SURS55SnUS:Xa[SURS55Sn[SURS55SnUS:Xa[SURS55Sn[SURS55Sn[SURS55SnU(aURS5n[SURS55Sn URU 5 U(aHUR5UlURU-UlUR URU-5 O7SUlSUlURU5UlURX4- 5 XlX`lU(aWOSUl X@l X0l XPl g) z(Used when a blob is read by the decoder.rrrrrrN) rrr start_posend_posrrrrQrRrrr ) r>r rrrr rQ has_checksumchecksumrs rrBlob._from_files#43A6 S &tQVVAY7:NdAFF1I.q1  !$q 215IdAFF1I.q1  !$q 215IaffQi03  qvvay1!4 vvbzHdAFF1I.q1  y VVXDN>>I5DL FF4>>N2 3!DNDLffY/DO FF>- ."&(4H$","rcURc [S5eUS:aURU-nUS:dXR:a [S5eURR UR U-5 g)z8Seek to the given position (relative to the blob start).Nz>Cannot seek in a blob that is not created by the BSDF decoder.rzSeek beyond blob boundaries.)rrrrrr)r>ps rr Blob.seeksk 77?S  q5##a'A q5A+++89 9  T^^a'(rcURc [S5eURR5UR- $)zCGet the current file pointer position (relative to the blob start).z>Cannot tell in a blob that is not created by the BSDF decoder.)rrrrrs rr Blob.tells6 77?S ww||~..rc,URc [S5eUR(a [S5eURR 5[ U5-UR :a [S5eSUlURRU5$)zWrite bytes to the blob.z?Cannot write in a blob that is not created by the BSDF decoder.z,Cannot arbitrarily write in compressed blob.zWrite beyond blob boundaries.T) rrrQrrr'rrr)r>r*s rr Blob.writesw 77?T    HI I 77<<>CG #dll 29: :ww}}R  rc URc [S5eUR(a [S5eURR 5U-UR :a [S5eURR U5$)zRead n bytes from the blob.z>Cannot read in a blob that is not created by the BSDF decoder.z+Cannot arbitrarily read in compressed blob.zRead beyond blob boundaries.)rrrQrrrr)r>r!s rr Blob.readsk 77?S    GH H 77<<>A  ,89 9ww||ArcURb URnOkURR5nURS5 URR UR 5nURRU5 UR S:XaUnU$UR S:Xa[R"U5nU$UR S:Xa[R"U5nU$[SUR -5e)z&Get the contents of the blob as bytes.rrrzInvalid compression %i) rrrrrrrQrF decompressrGr)r>rrrs rrBlob.get_bytess ?? &J A IIaLdnn5J GGLLO   q E    "OOJ/E     "NN:.E 7$:J:JJK KrcUR(aUR(aURS5 URR UR 5nURRUR UR- S- S- 5 URR[R"U5R55 ggg)zJReset the blob's checksum if present. Call this after modifying the data. rrrN) rRrrrrrrrrrrr)r>rs rupdate_checksumBlob.update_checksums    IIaLdnn5J GGLL$..81 B8%#N )/ ! & ]vva}]s A A(c <[U40UD6nURU5$)zhLoad a (BSDF-encoded) structure from bytes. See `BSDFSerializer` for details on extensions and options. )r5r)r*r?r@r2s rrrr,rc @[U40UD6n[U[5(a\URS5(a[R R U5n[US5nURU5sSSS5 $URU5$!,(df  g=f)zLoad a (BSDF-encoded) structure from the given filename or file object. See `BSDFSerializer` for details on extensions and options. )z~/z~\rbN) r5r-r. startswithospath expanduserr/r)r r?r@r2r0s rrr$sx z-W-A!\"" << & &""1%A !T]b66":]vvay]s #B Bc8\rSrSrSrSrSrSrSrSr Sr Sr g ) r\i>aBase class to implement BSDF extensions for special data types. Extension classes are provided to the BSDF serializer, which instantiates the class. That way, the extension can be somewhat dynamic: e.g. the NDArrayExtension exposes the ndarray class only when numpy is imported. A extension instance must have two attributes. These can be attributes of the class, or of the instance set in ``__init__()``: * name (str): the name by which encoded values will be identified. * cls (type): the type (or list of types) to match values with. This is optional, but it makes the encoder select extensions faster. Further, it needs 3 methods: * `match(serializer, value) -> bool`: return whether the extension can convert the given value. The default is ``isinstance(value, self.cls)``. * `encode(serializer, value) -> encoded_value`: the function to encode a value to more basic data types. * `decode(serializer, encoded_value) -> value`: the function to decode an encoded value back to its intended representation. r8cPSUR<S[[U55<S3$)Nz)r]hexidrs r__repr__Extension.__repr__[s04 3r$x=IIrc,[X R5$r )r-rar>r2rs rr0Extension.match^s!XX&&rc[5er NotImplementedErrorrAs rr%Extension.encodea !##rc[5er rDrAs rrExtension.decodedrGrN) rrrrrr]rar>r0r%rrr8rrr\r\>s(2 D CJ'$$rr\c(\rSrSrSr\rSrSrSr g)ComplexExtensionihrc2URUR4$r )realimagrAs rr%ComplexExtension.encodelsrc&[USUS5$)Nrr)complexrAs rrComplexExtension.decodeosqtQqT""rr8N) rrrrr]rQrar%rrr8rrrKrKhs D C #rrKc0\rSrSrSrSrSrSrSrSr g) NDArrayExtensionisndarraycXS[R;aSSKnURUlgg)Nnumpyr)sysmodulesrWrUra)r>nps rrBNDArrayExtension.__init__vs! ckk ! zzDH "rcf[US5=(a [US5=(a [US5$)Nshapedtypetobytes)rrAs rr0NDArrayExtension.match|s'q'"Twq'':Twq)?TTrcn[UR[UR5UR 5S9$)N)r]r^data)rr] text_typer^r_rAs rr%NDArrayExtension.encodes$!''177);!))+NNrctSSKnURUSUSS9nUSUlU$![a Us$f=f)Nrrbr^)r^r])rW ImportError frombufferr])r>r2rrZas rrNDArrayExtension.decodesL   MM!F)1W:M 6G*  H s ( 77)raN) rrrrr]rBr0r%rrr8rrrTrTss D" UOrrT__main__r )>r __future__rrrrGrloggingr5r/rrXtypesrFior getLoggerrr_rjoinr version_inforr rcr.rrrrZrd basicConfigunicode basestringlong ClassTyperrunpackrrr"r+r3objectr5rrrr%rrrloadsdumpsr\rKrTr;bsdf_climainr8rrr}s &A@     8 $ hh/w//  qQILMMJ ILM$KMu&J   MM  $ _V_J