This commit is contained in:
jrandom
2004-06-27 21:20:31 +00:00
committed by zzz
parent 290a2f7ccd
commit cbc6aea8b4

View File

@ -257,8 +257,8 @@ public class ClientConnectionRunner {
} }
long afterLock = _context.clock().now(); long afterLock = _context.clock().now();
if (afterLock - beforeLock > 50) { if (_log.shouldLog(Log.DEBUG)) {
_log.warn("distributeMessage.locking took too long: " + (afterLock-beforeLock) _log.warn("distributeMessage.locking took: " + (afterLock-beforeLock)
+ " overall, synchronized took " + (inLock - beforeLock)); + " overall, synchronized took " + (inLock - beforeLock));
} }
@ -270,8 +270,8 @@ public class ClientConnectionRunner {
// the following blocks as described above // the following blocks as described above
_manager.distributeMessage(_config.getDestination(), message.getDestination(), message.getPayload(), id); _manager.distributeMessage(_config.getDestination(), message.getDestination(), message.getPayload(), id);
long timeToDistribute = _context.clock().now() - beforeDistribute; long timeToDistribute = _context.clock().now() - beforeDistribute;
if (timeToDistribute > 50) if (_log.shouldLog(Log.DEBUG))
_log.warn("Took too long to distribute in the manager to " _log.warn("Time to distribute in the manager to "
+ message.getDestination().calculateHash().toBase64() + ": " + message.getDestination().calculateHash().toBase64() + ": "
+ timeToDistribute); + timeToDistribute);
return id; return id;