mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2024-11-19 09:52:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add deterministic delay for seed node shutdown at reorg

Browse Source 
We shut down with a deterministic delay per seed to avoid that all seeds shut down at the
same time in case of a reorg. We use 30 sec. as distance delay between the seeds to be on the
safe side. We have 12 seeds so that's 6 minutes.
This commit is contained in:
chimp1984 2021-11-10 18:31:53 +01:00
parent 0edccd9fe1
commit 6f51793d1b
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
1 changed files with 29 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
seednode/src/main/java/bisq/seednode/SeedNodeMain.java
View File

@ -25,9 +25,11 @@ import bisq.core.user.Cookie;
import bisq.core.user.CookieKey;
import bisq.core.user.User;
import bisq.network.p2p.NodeAddress;
import bisq.network.p2p.P2PService;
import bisq.network.p2p.P2PServiceListener;
import bisq.network.p2p.peers.PeerManager;
import bisq.network.p2p.seed.SeedNodeRepository;
import bisq.common.Timer;
import bisq.common.UserThread;
@ -42,6 +44,9 @@ import bisq.common.handlers.ResultHandler;
import com.google.inject.Key;
import com.google.inject.name.Names;
import java.util.ArrayList;
import java.util.List;
import lombok.extern.slf4j.Slf4j;
@Slf4j
@ -108,11 +113,28 @@ public class SeedNodeMain extends ExecutableForAppWithP2p {
seedNode.setInjector(injector);
if (DevEnv.isDaoActivated()) {
injector.getInstance(DaoStateSnapshotService.class).setDaoRequiresRestartHandler(() -> gracefulShutDown(() -> {
}));
injector.getInstance(DaoStateSnapshotService.class).setDaoRequiresRestartHandler(
// We shut down with a deterministic delay per seed to avoid that all seeds shut down at the
// same time in case of a reorg. We use 30 sec. as distance delay between the seeds to be on the
// safe side. We have 12 seeds so that's 6 minutes.
() -> UserThread.runAfter(this::gracefulShutDown, 1 + (getMyIndex() * 30L))
);
}
}
private int getMyIndex() {
P2PService p2PService = injector.getInstance(P2PService.class);
SeedNodeRepository seedNodeRepository = injector.getInstance(SeedNodeRepository.class);
List<NodeAddress> seedNodes = new ArrayList<>(seedNodeRepository.getSeedNodeAddresses());
NodeAddress myAddress = p2PService.getAddress();
for (int i = 0; i < seedNodes.size(); i++) {
if (seedNodes.get(i).equals(myAddress)) {
return i;
}
}
return 0;
}
@Override
protected void startApplication() {
Cookie cookie = injector.getInstance(User.class).getCookie();
@ -197,6 +219,11 @@ public class SeedNodeMain extends ExecutableForAppWithP2p {
}
private void gracefulShutDown() {
gracefulShutDown(() -> {
});
}
@Override
public void gracefulShutDown(ResultHandler resultHandler) {
seedNode.shutDown();