echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Findbugs all over

Browse Source
This commit is contained in:
zzz
2018-08-26 13:50:40 +00:00
parent db54edc36d
commit 1f92232253
17 changed files with 56 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
apps/streaming/java/src/net/i2p/client/streaming/impl/MessageInputStream.java
View File

@ -288,12 +288,11 @@ class MessageInputStream extends InputStream {
buf.append(" not ready blocks: [");
long notAvailable = 0;
for (Long id : _notYetReadyBlocks.keySet()) {
ByteArray ba = _notYetReadyBlocks.get(id);
for (Map.Entry<Long, ByteArray> e : _notYetReadyBlocks.entrySet()) {
Long id = e.getKey();
ByteArray ba = e.getValue();
buf.append(id).append(" ");
if (ba != null)
notAvailable += ba.getValid();
notAvailable += ba.getValid();
}
buf.append("] not ready bytes: ").append(notAvailable);
@ -589,11 +588,11 @@ class MessageInputStream extends InputStream {
buf.append(" blocks: ").append(_readyDataBlocks.size());
buf.append(" not ready blocks: [");
long notAvailable = 0;
for (Long id : _notYetReadyBlocks.keySet()) {
ByteArray ba = _notYetReadyBlocks.get(id);
for (Map.Entry<Long, ByteArray> e : _notYetReadyBlocks.entrySet()) {
Long id = e.getKey();
ByteArray ba = e.getValue();
buf.append(id).append(" ");
if (ba != null)
notAvailable += ba.getValid();
notAvailable += ba.getValid();
}
buf.append("] not ready bytes: ").append(notAvailable);
buf.append(" highest ready block: ").append(_highestReadyBlockId);