forked from I2P_Developers/i2p.i2p
* i2psnark: Fix rare IOOBE (ticket #777)
This commit is contained in:
@ -356,22 +356,21 @@ class PeerState implements DataLoader
|
|||||||
+ piece + "," + begin + "," + length + ") from "
|
+ piece + "," + begin + "," + length + ") from "
|
||||||
+ peer);
|
+ peer);
|
||||||
|
|
||||||
int r = getFirstOutstandingRequest(piece);
|
|
||||||
|
|
||||||
// Unrequested piece number?
|
|
||||||
if (r == -1)
|
|
||||||
{
|
|
||||||
if (_log.shouldLog(Log.INFO))
|
|
||||||
_log.info("Unrequested 'piece: " + piece + ", "
|
|
||||||
+ begin + ", " + length + "' received from "
|
|
||||||
+ peer);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Lookup the correct piece chunk request from the list.
|
// Lookup the correct piece chunk request from the list.
|
||||||
Request req;
|
Request req;
|
||||||
synchronized(this)
|
synchronized(this)
|
||||||
{
|
{
|
||||||
|
int r = getFirstOutstandingRequest(piece);
|
||||||
|
|
||||||
|
// Unrequested piece number?
|
||||||
|
if (r == -1) {
|
||||||
|
if (_log.shouldLog(Log.INFO))
|
||||||
|
_log.info("Unrequested 'piece: " + piece + ", "
|
||||||
|
+ begin + ", " + length + "' received from "
|
||||||
|
+ peer);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
req = outstandingRequests.get(r);
|
req = outstandingRequests.get(r);
|
||||||
while (req.getPiece() == piece && req.off != begin
|
while (req.getPiece() == piece && req.off != begin
|
||||||
&& r < outstandingRequests.size() - 1)
|
&& r < outstandingRequests.size() - 1)
|
||||||
|
Reference in New Issue
Block a user