Kaladaran/briar
0
0
Fork 0
mirror of https://code.briarproject.org/briar/briar.git synced 2026-02-20 14:49:53 +01:00
Code Issues Projects Releases Wiki Activity

Removed debug logging from message queue manager.

Browse Source
This commit is contained in:
akwizgran
2016-03-31 12:34:53 +01:00
parent 4393517f31
commit e44329a2b4
1 changed files with 3 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
briar-core/src/org/briarproject/clients/MessageQueueManagerImpl.java
View File

@@ -21,7 +21,6 @@ import org.briarproject.api.sync.ValidationManager.IncomingMessageHook;
import org.briarproject.util.ByteUtils; import org.briarproject.util.ByteUtils;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Map.Entry; import java.util.Map.Entry;
@@ -64,20 +63,11 @@ class MessageQueueManagerImpl implements MessageQueueManager {
QueueState queueState = loadQueueState(txn, queue.getId()); QueueState queueState = loadQueueState(txn, queue.getId());
long queuePosition = queueState.outgoingPosition; long queuePosition = queueState.outgoingPosition;
queueState.outgoingPosition++; queueState.outgoingPosition++;
if (LOG.isLoggable(INFO)) { if (LOG.isLoggable(INFO))
LOG.info("Sending message with position " + LOG.info("Sending message with position " + queuePosition);
queuePosition + " in group " +
queue.getId().hashCode() + " with transaction " +
txn.hashCode());
}
saveQueueState(txn, queue.getId(), queueState); saveQueueState(txn, queue.getId(), queueState);
QueueMessage q = queueMessageFactory.createMessage(queue.getId(), QueueMessage q = queueMessageFactory.createMessage(queue.getId(),
timestamp, queuePosition, body); timestamp, queuePosition, body);
if (LOG.isLoggable(INFO)) {
LOG.info("First bytes of message: " + Arrays.toString(
Arrays.copyOfRange(q.getRaw(), 0,
QUEUE_MESSAGE_HEADER_LENGTH)));
}
db.addLocalMessage(txn, q, queue.getClientId(), meta, true); db.addLocalMessage(txn, q, queue.getClientId(), meta, true);
return q; return q;
} }
@@ -208,12 +198,7 @@ class MessageQueueManagerImpl implements MessageQueueManager {
if (LOG.isLoggable(INFO)) { if (LOG.isLoggable(INFO)) {
LOG.info("Received message with position " LOG.info("Received message with position "
+ queuePosition + ", expecting " + queuePosition + ", expecting "
+ queueState.incomingPosition + ". Received in group " + + queueState.incomingPosition);
m.getGroupId().hashCode() + " with transaction " +
txn.hashCode());
LOG.info("First bytes of message: " + Arrays.toString(
Arrays.copyOfRange(m.getRaw(), 0,
QUEUE_MESSAGE_HEADER_LENGTH)));
} }
if (queuePosition < queueState.incomingPosition) { if (queuePosition < queueState.incomingPosition) {
// A message with this queue position has already been seen // A message with this queue position has already been seen