From ca838539b9117b4b9cd9b5a44a740a3fdaab8da7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Simon=20K=C3=B6nnecke?= <simonkoennecke@gmail.com>
Date: Tue, 19 Jul 2016 13:02:15 +0200
Subject: [PATCH] snapshot load
---
.../fucoin/gui/SuperVisorGuiControlImpl.java | 24 ++++++++++++-------
1 file changed, 16 insertions(+), 8 deletions(-)
diff --git a/src/main/java/fucoin/gui/SuperVisorGuiControlImpl.java b/src/main/java/fucoin/gui/SuperVisorGuiControlImpl.java
index 13be49d..16dac8b 100644
--- a/src/main/java/fucoin/gui/SuperVisorGuiControlImpl.java
+++ b/src/main/java/fucoin/gui/SuperVisorGuiControlImpl.java
@@ -14,9 +14,7 @@ import scala.concurrent.Future;
import scala.concurrent.duration.Duration;
import java.time.LocalDateTime;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
public class SuperVisorGuiControlImpl implements SuperVisorGuiControl {
private SuperVisorImpl superVisor;
@@ -61,14 +59,24 @@ public class SuperVisorGuiControlImpl implements SuperVisorGuiControl {
loadedSnapshotsOfWallets.clear();
loadedSnapshotDateTime = time;
-
+ fucoin.supervisor.Snapshot snapshot = superVisor.readSnapShot(time);
try {
Timeout timeout = new Timeout(Duration.create(10, "seconds"));
- for (Map.Entry<String, ActorRef> item : superVisor.getKnownNeighbors().entrySet()) {
- Future<Object> futureNeighbour = Patterns.ask(item.getValue(), new ActionWalletGetSnapshot(time), timeout);
- ActionWalletGetSnapshotAnswer snapshot = (ActionWalletGetSnapshotAnswer)
+ Vector data = snapshot.getAmountTableModel().getDataVector();
+ /*AbstractNode node = new AbstractNode() {
+ @Override
+ public void onReceive(Object message) {
+
+ }
+ };*/
+ for (Object aData : data) {
+ String name = (String) ((ArrayList<Object>) aData).get(1);
+ ActorRef ref = superVisor.getKnownNeighbors().get(name);
+ Future<Object> futureNeighbour = Patterns.ask(ref, new ActionWalletGetSnapshot(time), timeout);
+ ActionWalletGetSnapshotAnswer snapshotAnswer = (ActionWalletGetSnapshotAnswer)
Await.result(futureNeighbour, timeout.duration());
- addSnapshot(snapshot.getSnapshot());
+ addSnapshot(snapshotAnswer.getSnapshot());
+ //addSnapshot(new Gson().fromJson(node.readSnapshot(name, time), Snapshot.class) );
}
} catch (Exception e) {
e.printStackTrace();
--
GitLab