|
|
@ -112,10 +112,10 @@ class LoadingState extends HookedState {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
Future<void> load() async {
|
|
|
|
Future<void> load() async {
|
|
|
|
print("Loading next");
|
|
|
|
log.fine("Loading next");
|
|
|
|
await for (var line in loadingProgress) {
|
|
|
|
await for (var line in loadingProgress) {
|
|
|
|
// append(line);
|
|
|
|
// append(line);
|
|
|
|
print(line);
|
|
|
|
log.info(line);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -145,7 +145,7 @@ class SyncingState extends HookedState {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
Future<SyncedState> next(Stream<String> processOutput) async {
|
|
|
|
Future<SyncedState> next(Stream<String> processOutput) async {
|
|
|
|
print("Syncing next");
|
|
|
|
log.fine("Syncing next");
|
|
|
|
|
|
|
|
|
|
|
|
Future<void> printStdout() async {
|
|
|
|
Future<void> printStdout() async {
|
|
|
|
await for (var line in processOutput) {
|
|
|
|
await for (var line in processOutput) {
|
|
|
@ -155,7 +155,7 @@ class SyncingState extends HookedState {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
append(line);
|
|
|
|
append(line);
|
|
|
|
print(line);
|
|
|
|
log.info(line);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -180,7 +180,7 @@ class SyncingState extends HookedState {
|
|
|
|
printStdout();
|
|
|
|
printStdout();
|
|
|
|
await checkSync();
|
|
|
|
await checkSync();
|
|
|
|
|
|
|
|
|
|
|
|
print('syncing: loop exit');
|
|
|
|
log.fine('syncing: loop exit');
|
|
|
|
|
|
|
|
|
|
|
|
final _height = await rpc.height();
|
|
|
|
final _height = await rpc.height();
|
|
|
|
SyncedState _next = SyncedState(setState, getNotification, stdout, processOutput);
|
|
|
|
SyncedState _next = SyncedState(setState, getNotification, stdout, processOutput);
|
|
|
@ -200,14 +200,14 @@ class SyncedState extends HookedState {
|
|
|
|
SyncedState(f, s, this.stdout, this.processOutput) : super (f, s);
|
|
|
|
SyncedState(f, s, this.stdout, this.processOutput) : super (f, s);
|
|
|
|
|
|
|
|
|
|
|
|
Future<ReSyncingState> next() async {
|
|
|
|
Future<ReSyncingState> next() async {
|
|
|
|
print("Synced next");
|
|
|
|
log.fine("Synced next");
|
|
|
|
|
|
|
|
|
|
|
|
Future<void> logStdout() async {
|
|
|
|
Future<void> logStdout() async {
|
|
|
|
await for (var line in processOutput) {
|
|
|
|
await for (var line in processOutput) {
|
|
|
|
if (!synced) break;
|
|
|
|
if (!synced) break;
|
|
|
|
// print('synced: print stdout loop');
|
|
|
|
// print('synced: print stdout loop');
|
|
|
|
stdout += line;
|
|
|
|
stdout += line;
|
|
|
|
print(line);
|
|
|
|
log.info(line);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -228,7 +228,7 @@ class SyncedState extends HookedState {
|
|
|
|
|
|
|
|
|
|
|
|
await checkSync();
|
|
|
|
await checkSync();
|
|
|
|
|
|
|
|
|
|
|
|
print('synced: loop exit');
|
|
|
|
log.fine('synced: loop exit');
|
|
|
|
|
|
|
|
|
|
|
|
ReSyncingState _next = ReSyncingState(setState, getNotification, stdout, processOutput);
|
|
|
|
ReSyncingState _next = ReSyncingState(setState, getNotification, stdout, processOutput);
|
|
|
|
setState(_next);
|
|
|
|
setState(_next);
|
|
|
@ -250,14 +250,14 @@ class ReSyncingState extends HookedState {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
Future<SyncedState> next() async {
|
|
|
|
Future<SyncedState> next() async {
|
|
|
|
print("ReSyncing next");
|
|
|
|
log.fine("ReSyncing next");
|
|
|
|
|
|
|
|
|
|
|
|
Future<void> printStdout() async {
|
|
|
|
Future<void> printStdout() async {
|
|
|
|
await for (var line in processOutput) {
|
|
|
|
await for (var line in processOutput) {
|
|
|
|
if (synced) break;
|
|
|
|
if (synced) break;
|
|
|
|
// print('re-syncing: print stdout loop');
|
|
|
|
// print('re-syncing: print stdout loop');
|
|
|
|
append(line);
|
|
|
|
append(line);
|
|
|
|
print(line);
|
|
|
|
log.info(line);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -275,7 +275,7 @@ class ReSyncingState extends HookedState {
|
|
|
|
printStdout();
|
|
|
|
printStdout();
|
|
|
|
await checkSync();
|
|
|
|
await checkSync();
|
|
|
|
|
|
|
|
|
|
|
|
print('resync: await exit');
|
|
|
|
log.fine('resync: await exit');
|
|
|
|
SyncedState _next = SyncedState(setState, getNotification, stdout, processOutput);
|
|
|
|
SyncedState _next = SyncedState(setState, getNotification, stdout, processOutput);
|
|
|
|
_next.height = await rpc.height();
|
|
|
|
_next.height = await rpc.height();
|
|
|
|
setState(_next);
|
|
|
|
setState(_next);
|
|
|
|