+ ^|i{"RtRt^RIHt^RIt^RIt^RIt^RIHt ^RI t ^RIt^RItRt]!4t!RR] P&4t!RR4tR# ] d^RI t LEi;i ] d^RI t LQi;i) a] Vendoring of pickleshare, reduced to used functionalities. --- PickleShare - a small 'shelve' like datastore with concurrency support Like shelve, a PickleShareDB object acts like a normal dictionary. Unlike shelve, many processes can access the database simultaneously. Changing a value in database is immediately visible to other processes accessing the same database. Concurrency is possible because the values are stored in separate files. Hence the "database" is a directory where *all* files are governed by PickleShare. Example usage:: from pickleshare import * db = PickleShareDB('~/testpickleshare') db.clear() print "Should be empty:",db.items() db['hello'] = 15 db['aku ankka'] = [1,2,313] db['paths/are/ok/key'] = [1,(5,46)] print db.keys() del db['aku ankka'] This module is certainly not ZODB, but can be used for low-load (non-mission-critical) situations where tiny code size trumps the advanced features of a "real" object database. Installation guide: pip install pickleshare Author: Ville Vainio License: MIT open source license. z0.7.5)PathNcLR\\V4R,4,RR#)z%02xN)abshash)keys&>/usr/lib/python3/dist-packages/IPython/external/pickleshare.py gethashfiler :s! ScS) )23 //ca]tRt^AtoRtRtRtRtRt] R3Rlt Rt R t R t R tRR ltRtRtRtRRltRtRtRtVtR #) PickleShareDBz5The main 'connection' object for PickleShare databasec \V\4'g \V4p\PP \PP V44p\ V4VnVPP4'gVPPRR7/Vn R# \d+pTP\P8wdhRp?L9Rp?ii;i)z9Return a db object that will manage the specied directoryTparentsN) isinstancestrospathabspath expanduserrrootis_dirmkdirOSErrorerrnoEEXISTcache)selfres&& r __init__PickleShareDB.__init__Ds$$$t9Dwwrww11$78J yy!!  -   77ell*+ sB44 C)? C$$C)c 2VPV, pVP4\P,pY P 9d9Y0P T,^,8XdTP T,^,#TP R4;_uu_4p\P!TP44pRRR4XT3TP T&T# \d \ T4hi;i +'giL=;i \ T4h;i)zdb['key'] readingrbN) rstatST_MTIMErKeyErrorropenpickleloadsread)rrfilmtimefobjs&& r __getitem__PickleShareDB.__getitem__Usii#o HHJt}}-E ** **S/!* C99C>c VPV, pVP4'gVP4V\V4, pVP V/4pVP W#/4W`V&R#)z hashed setN)rrrr getupdate)rhashrootrr8hroothfileds&&&& r hsetPickleShareDB.hsetysX H$||~~ KKM C(( HHUB  #U r Tc VPV, pV\V4, pVPV\4pV\Jd1V'dV\Jd \ V4hV#VP V4pVPW#4#)z hashed get)rr r< _sentinelr&hdict)rr>rdefault fast_onlyr?r@rAs&&&&& r hgetPickleShareDB.hgetso H$ C(( HHUI & >i'"3-' 8$AuuS""r c VPVR,4pVP4\V4;'dVR,;'gRpVPR4'dV.VRR,p/pVF,pVP W,4VPV4K. V# \ d\ RTR4YL3i;i)zhfileslastallr-s&& r rFPickleShareDB.hdicts8d?+ 6{))vbz//R ==  VfSbk)FA  47# LLO  i$GHG s;B))CCc 0VPVR,4p/pVF+pVPW,4VPV4K- W0VR,&VF9pVPV, pVPR8XdK)VP 4K; R#)zCompress category 'hashroot', so hset is fast again hget will fail if fast_only is True for compressed items (that were hset before hcompress). rLz/xxrNN)rQr=rVrnameunlink)rr>rWrYr-ps&& r hcompressPickleShareDB.hcompresss{8d?+A JJtw  LLO "%X A A Avv~ HHJ r c VPV, pVPPVR4VP4R# \dR#i;i)z del db["key"]N)rrpopr]r)rrr+s&& r __delitem__PickleShareDB.__delitem__sCii#o sD!  JJL   sA AAc j\VPVP44PRR4#)z#Make a key suitable for user's eyes\/)r relative_torreplace)rr^s&&r _normalizedPickleShareDB._normalizeds'1==+,44T3??r Nc VfVPPR4pMVPPV4pVUu.uF+q3P4'gKVP V4NK- up#uupi)z+All keys in DB, or all keys matching a glob*)rrglobglobis_filerj)rglobpatfilesr^s&& r rQPickleShareDB.keyssY ?IIOOC(EIINN7+E-2BUiik#  #UBBBs A4A4c4\VP44#N)iterrQrs&r __iter__PickleShareDB.__iter__sDIIK  r c4\VP44#ru)rSrQrws&r __len__PickleShareDB.__len__s499;r c nV'g/VnVFpVPPVR4K! R#)zRemoves all, or specified items from cache Use this after reading a large amount of large objects to free up memory, when you won't be needing the objects for a while. N)rrb)ritemsits&* r rVPickleShareDB.uncaches*DJB JJNN2t $r c FR.^,R.^,,^.,p^p^pW,pV# \dMi;iYR8d \T4h\P!Y4,4YST,, pT\T4^, 8gKrT^, pK})aWait (poll) for a key to get a value Will wait for `maxwaittime` seconds before raising a KeyError. The call exits normally if the `key` field in db gets a value within the timeout period. Use this for synchronizing different processes or for ensuring that an unfortunately timed "db['key'] = newvalue" operation in another process (which causes all 'get' operation to cause a KeyError for the duration of pickling) won't screw up your program logic. g?g?)r&timesleeprS)rr maxwaittimewtimestrieswaitedvals&&& r waitgetPickleShareDB.waitgetscUQY&!, i   #sm# JJv} % Um #Fs6{Q& s 2 AAc \W4#)z)Get a convenient link for accessing items)PickleShareLink)rfolders&&r getlinkPickleShareDB.getlink s t,,r c(RVP,#)zPickleShareDB('%s'))rrws&r __repr__PickleShareDB.__repr__s$tyy00r )rrru)<)__name__ __module__ __qualname____firstlineno____doc__r r/r9rBrErIrFr_rcrjrQrxr{rVrrr__static_attributes____classdictcell__ __classdict__s@r r r Asg?"( +4t#&.* @C!  %@-11r r c<a]tRtRtoRtRtRtRtRtRt Vt R#) rizA shortdand for accessing nested PickleShare data conveniently. Created through PickleShareDB.getlink(), example:: lnk = db.getlink('myobjects/test') lnk.foo = 2 lnk.bar = lnk.foo + 5 cLVPP\44R#ru)__dict__r=locals)rdbkeydirs&&&r r PickleShareLink.__init__ s VX&r ctVPR,VPR,R,V,,#)rrrg)r)rrs&&r __getattr__PickleShareLink.__getattr__#s)}}T"4==#:S#@3#FGGr cRW PVPR,V,&R#)rgN)rr)rrrs&&&r __setattr__PickleShareLink.__setattr__&s+. c!C'(r c (VPR,pVPVPR,R,4pRVPR,: RRPVUu.uFp\V4P 4NK up4: R2#uupi)rrrLz)rrQjoinrbasename)rrrQks& r rPickleShareLink.__repr__)sp ]]4 wwt}}X.56 MM( # # HH$7$Qd1g&&($7 8  7s""BN) rrrrrr rrrrrrs@r rrs$'H/  r r)r __version__pathlibrrr$rcollections.abcabccollections_abc ImportError collectionscPickler(rsysr objectrEMutableMappingr rrr r rs$L *- 0 H Q1O22Q1h  K*)*s"AA' A$#A$' A54A5