Qortal/qortal
1
0
Fork 0
mirror of https://github.com/Qortal/qortal.git synced 2025-07-21 11:51:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove unused code

Browse Source
This commit is contained in:
PhilReact 2025-07-10 12:59:13 +03:00
parent f7cb4ce264
commit 05b83ade47
3 changed files with 5 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/qortal/controller/arbitrary/ArbitraryDataFileListManager.java
View File

@ -587,9 +587,7 @@ public class ArbitraryDataFileListManager {
// Forward to requesting peer // Forward to requesting peer
LOGGER.debug("Forwarding file list with {} hashes to requesting peer: {}", hashes.size(), requestingPeer); LOGGER.debug("Forwarding file list with {} hashes to requesting peer: {}", hashes.size(), requestingPeer);
if (!requestingPeer.sendMessage(forwardArbitraryDataFileListMessage)) { requestingPeer.sendMessage(forwardArbitraryDataFileListMessage);
// requestingPeer.disconnect("failed to forward arbitrary data file list");
}
} }
} }
} }
@ -787,7 +785,6 @@ public class ArbitraryDataFileListManager {
if (!peer.sendMessage(arbitraryDataFileListMessage)) { if (!peer.sendMessage(arbitraryDataFileListMessage)) {
LOGGER.debug("Couldn't send list of hashes"); LOGGER.debug("Couldn't send list of hashes");
// peer.disconnect("failed to send list of hashes");
continue; continue;
} }

17
src/main/java/org/qortal/controller/arbitrary/ArbitraryDataFileManager.java
View File

@ -410,14 +410,6 @@ public void queueFileSendToPeer(Peer peer, Message fileMessage) {
// The ID needs to match that of the original request // The ID needs to match that of the original request
message.setId(originalMessage.getId()); message.setId(originalMessage.getId());
// if (!requestingPeer.sendMessageWithTimeout(message, (int) ArbitraryDataManager.ARBITRARY_REQUEST_TIMEOUT)) {
// LOGGER.info("Failed to forward arbitrary data file to peer {}", requestingPeer);
// requestingPeer.disconnect("failed to forward arbitrary data file");
// }
// else {
// LOGGER.info("Forwarded arbitrary data file to peer {}", requestingPeer);
// }
getOrCreateSendManager(requestingPeer).queueMessage(message); getOrCreateSendManager(requestingPeer).queueMessage(message);
} catch (Exception e) { } catch (Exception e) {
@ -695,13 +687,7 @@ public void queueFileSendToPeer(Peer peer, Message fileMessage) {
LOGGER.debug("Sending file {}...", arbitraryDataFile); LOGGER.debug("Sending file {}...", arbitraryDataFile);
ArbitraryDataFileMessage arbitraryDataFileMessage = new ArbitraryDataFileMessage(signature, arbitraryDataFile); ArbitraryDataFileMessage arbitraryDataFileMessage = new ArbitraryDataFileMessage(signature, arbitraryDataFile);
arbitraryDataFileMessage.setId(message.getId()); arbitraryDataFileMessage.setId(message.getId());
// if (!peer.sendMessageWithTimeout(arbitraryDataFileMessage, (int) ArbitraryDataManager.ARBITRARY_REQUEST_TIMEOUT)) {
// LOGGER.info("Couldn't send file {}", arbitraryDataFile);
// // peer.disconnect("failed to send file");
// }
// else {
// LOGGER.debug("Sent file {}", arbitraryDataFile);
// }
getOrCreateSendManager(peer).queueMessage(arbitraryDataFileMessage); getOrCreateSendManager(peer).queueMessage(arbitraryDataFileMessage);
} }
@ -737,7 +723,6 @@ public void queueFileSendToPeer(Peer peer, Message fileMessage) {
fileUnknownMessage.setId(message.getId()); fileUnknownMessage.setId(message.getId());
if (!peer.sendMessage(fileUnknownMessage)) { if (!peer.sendMessage(fileUnknownMessage)) {
LOGGER.debug("Couldn't sent file-unknown response"); LOGGER.debug("Couldn't sent file-unknown response");
// peer.disconnect("failed to send file-unknown response");
} }
else { else {
LOGGER.debug("Sent file-unknown response for file {}", arbitraryDataFile); LOGGER.debug("Sent file-unknown response for file {}", arbitraryDataFile);

6
src/main/java/org/qortal/controller/arbitrary/ArbitraryMetadataManager.java
View File

@ -360,9 +360,8 @@ public class ArbitraryMetadataManager {
// Forward to requesting peer // Forward to requesting peer
LOGGER.debug("Forwarding metadata to requesting peer: {}", requestingPeer); LOGGER.debug("Forwarding metadata to requesting peer: {}", requestingPeer);
if (!requestingPeer.sendMessage(forwardArbitraryMetadataMessage)) { requestingPeer.sendMessage(forwardArbitraryMetadataMessage);
// requestingPeer.disconnect("failed to forward arbitrary metadata");
}
} }
} }
} }
@ -479,7 +478,6 @@ public class ArbitraryMetadataManager {
arbitraryMetadataMessage.setId(message.getId()); arbitraryMetadataMessage.setId(message.getId());
if (!peer.sendMessage(arbitraryMetadataMessage)) { if (!peer.sendMessage(arbitraryMetadataMessage)) {
LOGGER.debug("Couldn't send metadata"); LOGGER.debug("Couldn't send metadata");
// peer.disconnect("failed to send metadata");
continue; continue;
} }
LOGGER.debug("Sent metadata"); LOGGER.debug("Sent metadata");