Commit d963d0ba authored by Tom Gross's avatar Tom Gross

Python 3 compatibility

parent f24a97cb
...@@ -3,8 +3,10 @@ build ...@@ -3,8 +3,10 @@ build
dist dist
lib lib
parts parts
develop-eggs
*.dll *.dll
*.pyc *.pyc
*.pyo *.pyo
*.so *.so
.installed.cfg
This diff is collapsed.
...@@ -5,3 +5,4 @@ parts = test ...@@ -5,3 +5,4 @@ parts = test
[test] [test]
recipe = zc.recipe.testrunner recipe = zc.recipe.testrunner
eggs = tempstorage eggs = tempstorage
...@@ -16,11 +16,11 @@ ...@@ -16,11 +16,11 @@
from setuptools import setup, find_packages from setuptools import setup, find_packages
long_description = file("README.txt").read() + "\n" + \ long_description = open("README.txt").read() + "\n" + \
file("CHANGES.txt").read() open("CHANGES.txt").read()
setup(name='tempstorage', setup(name='tempstorage',
version = '2.12.3dev', version = '2.13.dev0',
url='http://pypi.python.org/pypi/tempstorage', url='http://pypi.python.org/pypi/tempstorage',
license='ZPL 2.1', license='ZPL 2.1',
description='A RAM-based storage for ZODB', description='A RAM-based storage for ZODB',
...@@ -31,7 +31,7 @@ setup(name='tempstorage', ...@@ -31,7 +31,7 @@ setup(name='tempstorage',
package_dir={'': 'src'}, package_dir={'': 'src'},
install_requires=[ install_requires=[
'setuptools', 'setuptools',
'ZODB3 >= 3.9.0', 'ZODB',
'zope.testing', 'zope.testing',
], ],
include_package_data=True, include_package_data=True,
......
...@@ -116,7 +116,8 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage): ...@@ -116,7 +116,8 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage):
def _clear_temp(self): def _clear_temp(self):
now = time.time() now = time.time()
if now > (self._last_cache_gc + self._conflict_cache_gcevery): if now > (self._last_cache_gc + self._conflict_cache_gcevery):
for k, v in self._conflict_cache.items(): temp_cc = self._conflict_cache.copy()
for k, v in temp_cc.items():
data, t = v data, t = v
if now > (t + self._conflict_cache_maxage): if now > (t + self._conflict_cache_maxage):
del self._conflict_cache[k] del self._conflict_cache[k]
...@@ -253,7 +254,6 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage): ...@@ -253,7 +254,6 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage):
references = {} references = {}
for roid in referencesl: for roid in referencesl:
references[roid] = 1 references[roid] = 1
referenced = references.has_key
# Create a reference count for this object if one # Create a reference count for this object if one
# doesn't already exist # doesn't already exist
...@@ -265,7 +265,7 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage): ...@@ -265,7 +265,7 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage):
# object # object
roids = oreferences.get(oid, []) roids = oreferences.get(oid, [])
for roid in roids: for roid in roids:
if referenced(roid): if roid in references:
# still referenced, so no need to update # still referenced, so no need to update
# remove it from the references dict so it doesn't # remove it from the references dict so it doesn't
# get "added" in the next clause # get "added" in the next clause
...@@ -368,13 +368,12 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage): ...@@ -368,13 +368,12 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage):
self._lock_acquire() self._lock_acquire()
try: try:
rindex = {} rindex = {}
referenced = rindex.has_key
rootl = ['\0\0\0\0\0\0\0\0'] rootl = ['\0\0\0\0\0\0\0\0']
# mark referenced objects # mark referenced objects
while rootl: while rootl:
oid = rootl.pop() oid = rootl.pop()
if referenced(oid): if oid in rindex:
continue continue
p = self._opickle[oid] p = self._opickle[oid]
referencesf(p, rootl) referencesf(p, rootl)
...@@ -382,7 +381,7 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage): ...@@ -382,7 +381,7 @@ class TemporaryStorage(BaseStorage, ConflictResolvingStorage):
# sweep unreferenced objects # sweep unreferenced objects
for oid in self._index.keys(): for oid in self._index.keys():
if not referenced(oid): if not oid in rindex:
self._takeOutGarbage(oid) self._takeOutGarbage(oid)
finally: finally:
self._lock_release() self._lock_release()
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment