Commit 0ca8ca7d authored by Jean-Paul Smets's avatar Jean-Paul Smets

Global Udate to Latest Coramy Optimizations


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@444 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 85d2b4ca
...@@ -80,7 +80,7 @@ class ActiveProcess(Base): ...@@ -80,7 +80,7 @@ class ActiveProcess(Base):
# Base methods # Base methods
security.declareProtected(CMFCorePermissions.ManagePortal, 'postError') security.declareProtected(CMFCorePermissions.ManagePortal, 'postError')
def postError(self, error): def postError(self, error):
self.error_list = self.get('error_list', []) + [error] self.error_list = getattr(self, 'error_list', []) + [error]
security.declareProtected(CMFCorePermissions.ManagePortal, 'getErrorList') security.declareProtected(CMFCorePermissions.ManagePortal, 'getErrorList')
def getErrorList(self): def getErrorList(self):
...@@ -99,7 +99,9 @@ class ActiveProcess(Base): ...@@ -99,7 +99,9 @@ class ActiveProcess(Base):
security.declareProtected(CMFCorePermissions.ManagePortal, 'activateResult') security.declareProtected(CMFCorePermissions.ManagePortal, 'activateResult')
def activateResult(self, result): def activateResult(self, result):
if result not in (None, 0, '', (), []): if result not in (None, 0, '', (), []):
self.activate().postError(result) #self.activate().postError(result)
self.postError(result) # Until we get SQLQueue
InitializeClass( ActiveProcess ) InitializeClass( ActiveProcess )
...@@ -174,7 +174,7 @@ class ActivityTool (Folder, UniqueObject): ...@@ -174,7 +174,7 @@ class ActivityTool (Folder, UniqueObject):
def initialize(self): def initialize(self):
global is_initialized global is_initialized
from Activity import RAMQueue, RAMDict, SQLDict from Activity import RAMQueue, RAMDict, SQLDict, SQLQueue
# Initialize each queue # Initialize each queue
for activity in activity_list: for activity in activity_list:
activity.initialize(self) activity.initialize(self)
......
#!/bin/bash #!/bin/bash
while true; do while true; do
wget -O /tmp/zope_distribute.out http://jp:jp@localhost:9573/coramy/portal_activities/distribute?node_count:int=1 wget -O /tmp/zope_distribute.out http://jp:jp@localhost:9573/coramy/portal_activities/distribute?node_count:int=3 &
#wget -O /tmp/zope_distribute.out http://jp:jp@localhost:9573/coramy/portal_activities/distribute?node_count:int=1 &
wget -O /tmp/zope_tic1.out http://jp:jp@localhost:9573/coramy/portal_activities/tic?processing_node:int=1 &
wget -O /tmp/zope_tic2.out http://jp:jp@192.1.2.150:9473/coramy/portal_activities/tic?processing_node:int=2 &
wget -O /tmp/zope_tic3.out http://jp:jp@192.1.2.150:9573/coramy/portal_activities/tic?processing_node:int=3 &
sleep 5 sleep 5
done done
#!/bin/bash #!/bin/bash
while true; do while true; do
wget -O /tmp/zope_tic1.out http://jp:jp@localhost:9573/coramy/portal_activities/tic?processing_node:int=1 wget -O /tmp/zope_tic1.out http://jp:jp@localhost:9573/coramy/portal_activities/tic?processing_node:int=1 &
sleep 5 sleep 5
done done
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