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

More logging for MessageQueueManagerImpl. #272

Browse Source
This commit is contained in:
akwizgran
2016-03-22 13:46:27 +00:00
parent f20a1e8dfe
commit 31f6c0bf50
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -135,9 +135,20 @@ class MessageQueueManagerImpl implements MessageQueueManager {
MessageId popIncomingMessageId() { MessageId popIncomingMessageId() {
Iterator<Entry<Long, MessageId>> it = pending.entrySet().iterator(); Iterator<Entry<Long, MessageId>> it = pending.entrySet().iterator();
if (!it.hasNext()) return null; if (!it.hasNext()) {
LOG.info("No pending messages");
return null;
}
Entry<Long, MessageId> e = it.next(); Entry<Long, MessageId> e = it.next();
if (!e.getKey().equals(incomingPosition)) return null; if (!e.getKey().equals(incomingPosition)) {
if (LOG.isLoggable(INFO)) {
LOG.info("First pending message is " + e.getKey() + ", "
+ " expecting " + incomingPosition);
}
return null;
}
if (LOG.isLoggable(INFO))
LOG.info("Removing pending message " + e.getKey());
it.remove(); it.remove();
incomingPosition++; incomingPosition++;
return e.getValue(); return e.getValue();