Ecosystem/haveno
Ecosystem/haveno
2
1
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2024-12-22 19:49:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

thaw reserved outputs within task if canceled

Browse source
This commit is contained in:
woodser 2024-05-23 18:17:27 -04:00
parent f2f5a6fd24
commit 796603f82b
2 changed files with 27 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
core/src/main/java/haveno/core/offer/placeoffer/tasks/MakerReserveOfferFunds.java
View file

@ -79,22 +79,33 @@ public class MakerReserveOfferFunds extends Task<PlaceOfferModel> {
Integer preferredSubaddressIndex = fundingEntry == null ? null : fundingEntry.getSubaddressIndex(); Integer preferredSubaddressIndex = fundingEntry == null ? null : fundingEntry.getSubaddressIndex();
// attempt creating reserve tx // attempt creating reserve tx
synchronized (HavenoUtils.getWalletFunctionLock()) { try {
for (int i = 0; i < TradeProtocol.MAX_ATTEMPTS; i++) { synchronized (HavenoUtils.getWalletFunctionLock()) {
try { for (int i = 0; i < TradeProtocol.MAX_ATTEMPTS; i++) {
//if (true) throw new RuntimeException("Pretend error"); try {
reserveTx = model.getXmrWalletService().createReserveTx(penaltyFee, makerFee, sendAmount, securityDeposit, returnAddress, openOffer.isReserveExactAmount(), preferredSubaddressIndex); //if (true) throw new RuntimeException("Pretend error");
} catch (Exception e) { reserveTx = model.getXmrWalletService().createReserveTx(penaltyFee, makerFee, sendAmount, securityDeposit, returnAddress, openOffer.isReserveExactAmount(), preferredSubaddressIndex);
log.warn("Error creating reserve tx, attempt={}/{}, offerId={}, error={}", i + 1, TradeProtocol.MAX_ATTEMPTS, openOffer.getShortId(), e.getMessage()); } catch (Exception e) {
if (i == TradeProtocol.MAX_ATTEMPTS - 1) throw e; log.warn("Error creating reserve tx, attempt={}/{}, offerId={}, error={}", i + 1, TradeProtocol.MAX_ATTEMPTS, openOffer.getShortId(), e.getMessage());
model.getProtocol().startTimeoutTimer(); // reset protocol timeout if (i == TradeProtocol.MAX_ATTEMPTS - 1) throw e;
HavenoUtils.waitFor(TradeProtocol.REPROCESS_DELAY_MS); // wait before retrying model.getProtocol().startTimeoutTimer(); // reset protocol timeout
HavenoUtils.waitFor(TradeProtocol.REPROCESS_DELAY_MS); // wait before retrying
}
// verify still open
verifyScheduled();
if (reserveTx != null) break;
} }
// verify still open
verifyScheduled();
if (reserveTx != null) break;
} }
} catch (Exception e) {
// reset state with wallet lock
model.getXmrWalletService().resetAddressEntriesForOpenOffer(offer.getId());
if (reserveTx != null) {
model.getXmrWalletService().thawOutputs(HavenoUtils.getInputKeyImages(reserveTx));
}
throw e;
} }
// reset protocol timeout // reset protocol timeout

3
core/src/main/java/haveno/core/trade/protocol/tasks/TakerReserveTradeFunds.java
View file

@ -81,7 +81,8 @@ public class TakerReserveTradeFunds extends TradeTask {
} }
} catch (Exception e) { } catch (Exception e) {
// thaw reserved inputs // reset state with wallet lock
model.getXmrWalletService().resetAddressEntriesForTrade(trade.getId());
if (reserveTx != null) { if (reserveTx != null) {
model.getXmrWalletService().thawOutputs(HavenoUtils.getInputKeyImages(reserveTx)); model.getXmrWalletService().thawOutputs(HavenoUtils.getInputKeyImages(reserveTx));
trade.getSelf().setReserveTxKeyImages(null); trade.getSelf().setReserveTxKeyImages(null);