Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2024-12-25 07:19:30 -05:00
Code Issues Packages Projects Releases Wiki Activity

walletAndNetworkReady does not wait for sufficient broadcast peers

Browse Source
This commit is contained in:
woodser 2023-04-22 17:26:45 -04:00
parent e0929653af
commit a0bc57c893
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core/src/main/java/haveno/core/app/AppStartupState.java
View File

@ -73,14 +73,14 @@ public class AppStartupState {
p2pNetworkAndWalletInitialized = EasyBind.combine(updatedDataReceived, p2pNetworkAndWalletInitialized = EasyBind.combine(updatedDataReceived,
isBlockDownloadComplete, isBlockDownloadComplete,
hasSufficientPeersForBroadcast, hasSufficientPeersForBroadcast, // TODO: consider sufficient number of peers?
allDomainServicesInitialized, allDomainServicesInitialized,
(a, b, c, d) -> { (a, b, c, d) -> {
log.info("p2pNetworkAndWalletInitialized = {} = updatedDataReceived={} && isBlockDownloadComplete={} && hasSufficientPeersForBroadcast={} && allDomainServicesInitialized={}", (a && b && c && d), updatedDataReceived.get(), isBlockDownloadComplete.get(), hasSufficientPeersForBroadcast.get(), allDomainServicesInitialized.get()); log.info("Combined initialized state = {} = updatedDataReceived={} && isBlockDownloadComplete={} && hasSufficientPeersForBroadcast={} && allDomainServicesInitialized={}", (a && b && c && d), updatedDataReceived.get(), isBlockDownloadComplete.get(), hasSufficientPeersForBroadcast.get(), allDomainServicesInitialized.get());
if (a && b && c) { if (a && b) {
walletAndNetworkReady.set(true); walletAndNetworkReady.set(true);
} }
return a && d; // app fully initialized before daemon connection and wallet by default return a && d; // app fully initialized before daemon connection and wallet by default // TODO: rename variable
}); });
p2pNetworkAndWalletInitialized.subscribe((observable, oldValue, newValue) -> { p2pNetworkAndWalletInitialized.subscribe((observable, oldValue, newValue) -> {
if (newValue) { if (newValue) {