projects
/
Portfolio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
+ setSite
[Portfolio.git]
/
manipulation.py
diff --git
a/manipulation.py
b/manipulation.py
index
a4623ba
..
44262dc
100755
(executable)
--- a/
manipulation.py
+++ b/
manipulation.py
@@
-18,6
+18,7
@@
from types import StringTypes
from math import ceil
import transaction
from ZODB.POSException import ConflictError
from math import ceil
import transaction
from ZODB.POSException import ConflictError
+from zope.site.hooks import setSite
from cStringIO import StringIO
console = logging.getLogger('[manipulation thread]')
from cStringIO import StringIO
console = logging.getLogger('[manipulation thread]')
@@
-50,6
+51,8
@@
class ImageQueueProcessorThread(threading.Thread) :
#atexit.register(self.stop)
import Zope2
app = Zope2.app()
#atexit.register(self.stop)
import Zope2
app = Zope2.app()
+ portal = app.unrestrictedTraverse(self.portal_path)
+ setSite(portal)
while not self.__stopped and self.queueSize :
self._process(app)
while not self.__stopped and self.queueSize :
self._process(app)
@@
-128,7
+131,7
@@
class ImageQueueProcessorThread(threading.Thread) :
except ConflictError :
console.warn('Resync after ZODB ConflicError')
transaction.abort()
except ConflictError :
console.warn('Resync after ZODB ConflicError')
transaction.abort()
- portal = app.unrestrictedTraverse(portal_path)
+ portal = app.unrestrictedTraverse(
self.
portal_path)
portal._p_jar.sync()
self.queueAdd(path)
return
portal._p_jar.sync()
self.queueAdd(path)
return