Commit a8b79d83 authored by Vincent Pelletier's avatar Vincent Pelletier

Cleanup: remove disabled logs.


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@25525 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 049cde25
...@@ -633,7 +633,6 @@ class SQLDict(RAMDict, SQLBase): ...@@ -633,7 +633,6 @@ class SQLDict(RAMDict, SQLBase):
result = readMessageList(path=None, method_id=None, processing_node=-1, result = readMessageList(path=None, method_id=None, processing_node=-1,
to_date=now_date, include_processing=0, offset=offset, count=READ_MESSAGE_LIMIT) to_date=now_date, include_processing=0, offset=offset, count=READ_MESSAGE_LIMIT)
validated_count = 0 validated_count = 0
#TIME_begin = time()
while len(result) and validated_count < MAX_VALIDATED_LIMIT: while len(result) and validated_count < MAX_VALIDATED_LIMIT:
get_transaction().commit() get_transaction().commit()
...@@ -652,8 +651,6 @@ class SQLDict(RAMDict, SQLBase): ...@@ -652,8 +651,6 @@ class SQLDict(RAMDict, SQLBase):
offset += READ_MESSAGE_LIMIT offset += READ_MESSAGE_LIMIT
result = readMessageList(path=None, method_id=None, processing_node=-1, result = readMessageList(path=None, method_id=None, processing_node=-1,
to_date=now_date, include_processing=0, offset=offset, count=READ_MESSAGE_LIMIT) to_date=now_date, include_processing=0, offset=offset, count=READ_MESSAGE_LIMIT)
#TIME_end = time()
#LOG('SQLDict.distribute', INFO, '%0.4fs : %i messages => %i distributables' % (TIME_end - TIME_begin, offset - READ_MESSAGE_LIMIT + len(result), validated_count))
# Validation private methods # Validation private methods
def _validate(self, activity_tool, method_id=None, message_uid=None, path=None, tag=None, def _validate(self, activity_tool, method_id=None, message_uid=None, path=None, tag=None,
......
...@@ -477,7 +477,6 @@ class SQLQueue(RAMQueue, SQLBase): ...@@ -477,7 +477,6 @@ class SQLQueue(RAMQueue, SQLBase):
to_date=now_date, include_processing=0, to_date=now_date, include_processing=0,
offset=offset, count=READ_MESSAGE_LIMIT) offset=offset, count=READ_MESSAGE_LIMIT)
validated_count = 0 validated_count = 0
#TIME_begin = time()
while len(result) and validated_count < MAX_VALIDATED_LIMIT: while len(result) and validated_count < MAX_VALIDATED_LIMIT:
get_transaction().commit() get_transaction().commit()
...@@ -497,8 +496,6 @@ class SQLQueue(RAMQueue, SQLBase): ...@@ -497,8 +496,6 @@ class SQLQueue(RAMQueue, SQLBase):
result = readMessageList(path=None, method_id=None, processing_node=-1, result = readMessageList(path=None, method_id=None, processing_node=-1,
to_date=now_date, include_processing=0, to_date=now_date, include_processing=0,
offset=offset, count=READ_MESSAGE_LIMIT) offset=offset, count=READ_MESSAGE_LIMIT)
#TIME_end = time()
#LOG('SQLQueue.distribute', INFO, '%0.4fs : %i messages => %i distributables' % (TIME_end - TIME_begin, offset + len(result), validated_count))
# Validation private methods # Validation private methods
def _validate(self, activity_tool, method_id=None, message_uid=None, path=None, tag=None, def _validate(self, activity_tool, method_id=None, message_uid=None, path=None, tag=None,
......
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