forked from Qortal-Forker/qortal
reentries for discarded response infos, originally done by Phil
This commit is contained in:
@@ -129,7 +129,7 @@ public class ArbitraryDataFileManager extends Thread {
|
||||
public boolean fetchArbitraryDataFiles(Peer peer,
|
||||
byte[] signature,
|
||||
ArbitraryTransactionData arbitraryTransactionData,
|
||||
List<byte[]> hashes) throws DataException {
|
||||
List<byte[]> hashes, ArbitraryFileListResponseInfo responseInfo) throws DataException {
|
||||
|
||||
// Load data file(s)
|
||||
ArbitraryDataFile arbitraryDataFile = ArbitraryDataFile.fromTransactionData(arbitraryTransactionData);
|
||||
@@ -161,6 +161,8 @@ public class ArbitraryDataFileManager extends Thread {
|
||||
}
|
||||
else {
|
||||
LOGGER.trace("Already requesting data file {} for signature {} from peer {}", arbitraryDataFile, Base58.encode(signature), peer);
|
||||
this.addResponse(responseInfo);
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -180,7 +180,8 @@ public class ArbitraryDataFileRequestThread {
|
||||
responseInfo.getPeer(),
|
||||
arbitraryTransactionData.getSignature(),
|
||||
arbitraryTransactionData,
|
||||
Arrays.asList(Base58.decode(responseInfo.getHash58()))
|
||||
Arrays.asList(Base58.decode(responseInfo.getHash58())),
|
||||
responseInfo
|
||||
);
|
||||
} catch (DataException e) {
|
||||
LOGGER.warn("Unable to process file hashes: {}", e.getMessage());
|
||||
|
||||
Reference in New Issue
Block a user