³ò œ›\Kc@sîdZySedjo&ddkZeZddklZnddkZddklZWn,ej o ddk Z e i e=‚nXeZ Z e i Z e iZddk Z ddkZe idjo(ddkZddklZddUnddd „ƒYZd efd „ƒYZd d ddddddd„Zd d ddddddd„Zd d ddddddddd„ Zd„Zd„Zy3ddkZ[e iƒdjo de _nWnej ode _nXdS(s¾Support for BerkeleyDB 3.3 through 4.4 with a simple interface. For the full featured object oriented interface use the bsddb.db module instead. It mirrors the Sleepycat BerkeleyDB C API. tbsddb3iÿÿÿÿN(t DeadlockWraps2.3(trefs& class _iter_mixin(UserDict.DictMixin): def _make_iter_cursor(self): cur = _DeadlockWrap(self.db.cursor) key = id(cur) self._cursor_refs[key] = ref(cur, self._gen_cref_cleaner(key)) return cur def _gen_cref_cleaner(self, key): # use generate the function for the weakref callback here # to ensure that we do not hold a strict reference to cur # in the callback. return lambda ref: self._cursor_refs.pop(key, None) def __iter__(self): try: cur = self._make_iter_cursor() # FIXME-20031102-greg: race condition. cursor could # be closed by another thread before this call. # since we're only returning keys, we call the cursor # methods with flags=0, dlen=0, dofs=0 key = _DeadlockWrap(cur.first, 0,0,0)[0] yield key next = cur.next while 1: try: key = _DeadlockWrap(next, 0,0,0)[0] yield key except _bsddb.DBCursorClosedError: cur = self._make_iter_cursor() # FIXME-20031101-greg: race condition. cursor could # be closed by another thread before this call. _DeadlockWrap(cur.set, key,0,0,0) next = cur.next except _bsddb.DBNotFoundError: return except _bsddb.DBCursorClosedError: # the database was modified during iteration. abort. return def iteritems(self): if not self.db: return try: cur = self._make_iter_cursor() # FIXME-20031102-greg: race condition. cursor could # be closed by another thread before this call. kv = _DeadlockWrap(cur.first) key = kv[0] yield kv next = cur.next while 1: try: kv = _DeadlockWrap(next) key = kv[0] yield kv except _bsddb.DBCursorClosedError: cur = self._make_iter_cursor() # FIXME-20031101-greg: race condition. cursor could # be closed by another thread before this call. _DeadlockWrap(cur.set, key,0,0,0) next = cur.next except _bsddb.DBNotFoundError: return except _bsddb.DBCursorClosedError: # the database was modified during iteration. abort. return t _iter_mixincBseZRS((t__name__t __module__(((s$/usr/lib/python2.5/bsddb/__init__.pyR–st _DBWithCursorcBs¼eZdZd„Zd„Zd„Zdd„Zd„Zd„Zd„Z d „Z d „Z d „Z d „Z d „Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(s˜ A simple wrapper around DB that makes it look like the bsddbobject in the old module. It uses a cursor as needed to provide DB traversal. cCs8||_|iidƒd|_d|_h|_dS(Ni(tdbtset_get_returns_nonetNonetdbct saved_dbc_keyt _cursor_refs(tselfR((s$/usr/lib/python2.5/bsddb/__init__.pyt__init__žs    cCs|iƒdS(N(tclose(R ((s$/usr/lib/python2.5/bsddb/__init__.pyt__del__´scCs`|idjoLt|iiƒ|_|idj o#t|ii|iƒd|_q\ndS(N(R R t _DeadlockWrapRtcursorR tset(R ((s$/usr/lib/python2.5/bsddb/__init__.pyt _checkCursor·s icCs¼|iom|i}d|_|o@y#t|idddƒd|_Wqctij oqcXnt|iƒ~nx>|ii ƒD]-}|ƒ}|dj ot|iƒq‡q‡WdS(Ni( R R RtcurrentR RtDBErrorRR tvalues(R tsavetctcref((s$/usr/lib/python2.5/bsddb/__init__.pyt _closeCursorsÂs   #    cCs!|idjo td‚ndS(Ns$BSDDB object has already been closed(RR terror(R ((s$/usr/lib/python2.5/bsddb/__init__.pyt _checkOpenÒscCs |idj S(N(RR (R ((s$/usr/lib/python2.5/bsddb/__init__.pytisOpenÖscsˆiƒt‡fd†ƒS(Ncs tˆiƒS((tlenR((R (s$/usr/lib/python2.5/bsddb/__init__.pytÛs(RR(R ((R s$/usr/lib/python2.5/bsddb/__init__.pyt__len__Ùs cs ˆiƒt‡‡fd†ƒS(Ncs ˆiˆS((R((R tkey(s$/usr/lib/python2.5/bsddb/__init__.pyR ßs(RR(R R"((R R"s$/usr/lib/python2.5/bsddb/__init__.pyt __getitem__Ýs cs7ˆiƒˆiƒ‡‡‡fd†}t|ƒdS(Ncsˆˆiˆ= 20480t.( RtDBEnvR t set_cachesizeRt set_lk_detecttDB_LOCK_DEFAULTR=t DB_PRIVATEt DB_CREATEt DB_THREADt DB_INIT_LOCKt DB_INIT_MPOOL(RERI((s$/usr/lib/python2.5/bsddb/__init__.pyR6`s    /cCsÄ|djo ti}n |djo d}n‰|djo ti}no|djo ti}nU|djo>ti}|dj o$tii|ƒoti|ƒq¹n td‚|ti BS(NtrtrwitwRtns+flags should be one of 'r', 'w', 'c' or 'n'( Rt DB_RDONLYRdR tostpathtisfiletunlinkRRe(R@R?RH((s$/usr/lib/python2.5/bsddb/__init__.pyR5ks            i((iii(R4Rt_pybsddbt_bsddbtbsddb3.dbutilsRRt bsddb.dbutilst ImportErrortsystmodulesRt_dbt __version__RRRmtversiontUserDicttweakrefRRRR RKRRR]R6R5tthreadRe(((s$/usr/lib/python2.5/bsddb/__init__.pys(sL         J ’