forked from Qortal/qortal
Add extra isInterrupted() quick-exits to Controller during TRANSACTION_SIGNATURES processing.
This commit is contained in:
parent
fc82bcaf49
commit
c559c16a4a
@ -728,6 +728,10 @@ public class Controller extends Thread {
|
|||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Check isInterrupted() here and exit fast
|
||||||
|
if (Thread.currentThread().isInterrupted())
|
||||||
|
return;
|
||||||
|
|
||||||
// Fetch actual transaction data from peer
|
// Fetch actual transaction data from peer
|
||||||
Message getTransactionMessage = new GetTransactionMessage(signature);
|
Message getTransactionMessage = new GetTransactionMessage(signature);
|
||||||
Message responseMessage = peer.getResponse(getTransactionMessage);
|
Message responseMessage = peer.getResponse(getTransactionMessage);
|
||||||
@ -737,6 +741,10 @@ public class Controller extends Thread {
|
|||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Check isInterrupted() here and exit fast
|
||||||
|
if (Thread.currentThread().isInterrupted())
|
||||||
|
return;
|
||||||
|
|
||||||
TransactionMessage transactionMessage = (TransactionMessage) responseMessage;
|
TransactionMessage transactionMessage = (TransactionMessage) responseMessage;
|
||||||
TransactionData transactionData = transactionMessage.getTransactionData();
|
TransactionData transactionData = transactionMessage.getTransactionData();
|
||||||
Transaction transaction = Transaction.fromData(repository, transactionData);
|
Transaction transaction = Transaction.fromData(repository, transactionData);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user