[Neo-report] r2795 jm - in /trunk/neo: master/ storage/ storage/handlers/
nobody at svn.erp5.org
nobody at svn.erp5.org
Tue Jun 21 19:31:12 CEST 2011
Author: jm
Date: Tue Jun 21 19:31:12 2011
New Revision: 2795
Log:
More logs
Modified:
trunk/neo/master/transactions.py
trunk/neo/storage/handlers/replication.py
trunk/neo/storage/transactions.py
Modified: trunk/neo/master/transactions.py
==============================================================================
--- trunk/neo/master/transactions.py [iso-8859-1] (original)
+++ trunk/neo/master/transactions.py [iso-8859-1] Tue Jun 21 19:31:12 2011
@@ -400,6 +400,7 @@ class TransactionManager(object):
"""
Remove a transaction, commited or aborted
"""
+ neo.lib.logging.debug('Remove TXN %s', dump(ttid))
try:
# only in case of an import:
self._queue.remove((uuid, ttid))
@@ -420,6 +421,7 @@ class TransactionManager(object):
If transaction is completely locked, calls function given at
instanciation time.
"""
+ neo.lib.logging.debug('Lock TXN %s for %s', dump(ttid), dump(uuid))
assert ttid in self._ttid_dict, "Transaction not started"
txn = self._ttid_dict[ttid]
if txn.lock(uuid) and self._queue[0][1] == ttid:
Modified: trunk/neo/storage/handlers/replication.py
==============================================================================
--- trunk/neo/storage/handlers/replication.py [iso-8859-1] (original)
+++ trunk/neo/storage/handlers/replication.py [iso-8859-1] Tue Jun 21 19:31:12 2011
@@ -183,6 +183,9 @@ class ReplicationHandler(EventHandler):
length=RANGE_LENGTH):
replicator = self.app.replicator
partition = replicator.getCurrentOffset()
+ neo.lib.logging.debug("Check serial range (offset=%s, min_oid=%x,"
+ " min_tid=%x, max_tid=%x, length=%s)", partition, u64(min_oid),
+ u64(min_tid), u64(max_tid), length)
check_args = (min_oid, min_tid, max_tid, length, partition)
replicator.checkSerialRange(*check_args)
return Packets.AskCheckSerialRange(*check_args)
@@ -190,6 +193,9 @@ class ReplicationHandler(EventHandler):
def _doAskCheckTIDRange(self, min_tid, max_tid, length=RANGE_LENGTH):
replicator = self.app.replicator
partition = replicator.getCurrentOffset()
+ neo.lib.logging.debug(
+ "Check TID range (offset=%s, min_tid=%x, max_tid=%x, length=%s)",
+ partition, u64(min_tid), u64(max_tid), length)
replicator.checkTIDRange(min_tid, max_tid, length, partition)
return Packets.AskCheckTIDRange(min_tid, max_tid, length, partition)
@@ -198,6 +204,8 @@ class ReplicationHandler(EventHandler):
partition_id = replicator.getCurrentOffset()
max_tid = replicator.getCurrentCriticalTID()
replicator.getTIDsFrom(min_tid, max_tid, length, partition_id)
+ neo.lib.logging.debug("Ask TIDs (offset=%s, min_tid=%x, max_tid=%x,"
+ "length=%s)", partition_id, u64(min_tid), u64(max_tid), length)
return Packets.AskTIDsFrom(min_tid, max_tid, length, [partition_id])
def _doAskObjectHistoryFrom(self, min_oid, min_serial, length):
Modified: trunk/neo/storage/transactions.py
==============================================================================
--- trunk/neo/storage/transactions.py [iso-8859-1] (original)
+++ trunk/neo/storage/transactions.py [iso-8859-1] Tue Jun 21 19:31:12 2011
@@ -150,6 +150,7 @@ class TransactionManager(object):
"""
Register a transaction, it may be already registered
"""
+ neo.lib.logging.debug('Register TXN %s for %s', dump(ttid), dump(uuid))
transaction = self._transaction_dict.get(ttid, None)
if transaction is None:
transaction = Transaction(uuid, ttid)
@@ -180,6 +181,7 @@ class TransactionManager(object):
"""
Lock a transaction
"""
+ neo.lib.logging.debug('Lock TXN %s (ttid=%s)', dump(tid), dump(ttid))
transaction = self._transaction_dict[ttid]
# remember that the transaction has been locked
transaction.lock()
@@ -208,6 +210,7 @@ class TransactionManager(object):
"""
Unlock transaction
"""
+ neo.lib.logging.debug('Unlock TXN %s', dump(ttid))
self._app.dm.finishTransaction(self.getTIDFromTTID(ttid))
self.abort(ttid, even_if_locked=True)
@@ -314,6 +317,7 @@ class TransactionManager(object):
# of the partition, even if no data was received (eg. conflict on
# another node)
return
+ neo.lib.logging.debug('Abort TXN %s', dump(ttid))
transaction = self._transaction_dict[ttid]
has_load_lock = transaction.isLocked()
# if the transaction is locked, ensure we can drop it
@@ -344,6 +348,7 @@ class TransactionManager(object):
"""
Abort any non-locked transaction of a node
"""
+ neo.lib.logging.debug('Abort for %s', dump(uuid))
# abort any non-locked transaction of this node
for ttid in [x.getTTID() for x in self._uuid_dict.get(uuid, [])]:
self.abort(ttid)
More information about the Neo-report
mailing list