mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-01-18 05:12:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #7355 from alvasw/RestApi_Fix_parseBlockCompleteAfterBatchProcessing_data_race

Browse Source 
RestApi: Fix parseBlockCompleteAfterBatchProcessing data race
This commit is contained in:
Alejandro García 2025-01-15 21:12:45 +00:00 committed by GitHub
commit 0b56ce5914
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
restapi/src/main/java/bisq/restapi/RestApi.java
View File

@ -38,6 +38,8 @@ import bisq.core.user.Preferences;
import bisq.common.app.Version;
import bisq.common.config.Config;
import java.util.concurrent.atomic.AtomicBoolean;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
@ -69,7 +71,7 @@ public class RestApi extends ExecutableForAppWithP2p {
private OfferBookService offerBookService;
private PriceFeedService priceFeedService;
@Getter
private boolean parseBlockCompleteAfterBatchProcessing;
private final AtomicBoolean parseBlockCompleteAfterBatchProcessing = new AtomicBoolean();
public RestApi() {
super("Bisq Rest Api", "bisq_restapi", "bisq_restapi", Version.VERSION);
@ -108,7 +110,7 @@ public class RestApi extends ExecutableForAppWithP2p {
@Override
public void onParseBlockCompleteAfterBatchProcessing(Block block) {
log.error("onParseBlockCompleteAfterBatchProcessing");
parseBlockCompleteAfterBatchProcessing = true;
parseBlockCompleteAfterBatchProcessing.set(true);
}
});
}
@ -130,6 +132,6 @@ public class RestApi extends ExecutableForAppWithP2p {
}
public void checkDaoReady() {
checkArgument(parseBlockCompleteAfterBatchProcessing, "DAO not ready yet");
checkArgument(parseBlockCompleteAfterBatchProcessing.get(), "DAO not ready yet");
}
}