forked from I2P_Developers/i2p.i2p
SSU: Pull call out of loop for efficiency
This commit is contained in:
@ -1927,8 +1927,9 @@ public class PeerState {
|
|||||||
if (_dead)
|
if (_dead)
|
||||||
return false;
|
return false;
|
||||||
|
|
||||||
|
final long messageId = bitfield.getMessageId();
|
||||||
if (bitfield.receivedComplete()) {
|
if (bitfield.receivedComplete()) {
|
||||||
return acked(bitfield.getMessageId());
|
return acked(messageId);
|
||||||
}
|
}
|
||||||
|
|
||||||
OutboundMessageState state = null;
|
OutboundMessageState state = null;
|
||||||
@ -1936,7 +1937,7 @@ public class PeerState {
|
|||||||
synchronized (_outboundMessages) {
|
synchronized (_outboundMessages) {
|
||||||
for (Iterator<OutboundMessageState> iter = _outboundMessages.iterator(); iter.hasNext(); ) {
|
for (Iterator<OutboundMessageState> iter = _outboundMessages.iterator(); iter.hasNext(); ) {
|
||||||
state = iter.next();
|
state = iter.next();
|
||||||
if (state.getMessageId() == bitfield.getMessageId()) {
|
if (state.getMessageId() == messageId) {
|
||||||
boolean complete = state.acked(bitfield);
|
boolean complete = state.acked(bitfield);
|
||||||
if (complete) {
|
if (complete) {
|
||||||
isComplete = true;
|
isComplete = true;
|
||||||
|
Reference in New Issue
Block a user