|
|
|
@ -4,6 +4,9 @@ import com.olexyn.ensync.artifacts.SyncDirectory;
|
|
|
|
|
import com.olexyn.ensync.artifacts.SyncMap;
|
|
|
|
|
|
|
|
|
|
import java.io.File;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
import java.util.Map.Entry;
|
|
|
|
|
|
|
|
|
|
import static com.olexyn.ensync.Main.MAP_OF_SYNCMAPS;
|
|
|
|
|
|
|
|
|
|
public class Flow implements Runnable {
|
|
|
|
@ -17,20 +20,30 @@ public class Flow implements Runnable {
|
|
|
|
|
|
|
|
|
|
public void run() {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
while (true) {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
synchronized (MAP_OF_SYNCMAPS) {
|
|
|
|
|
|
|
|
|
|
readOrMakeStateFile();
|
|
|
|
|
|
|
|
|
|
for (var syncMapEntry : MAP_OF_SYNCMAPS.entrySet()) {
|
|
|
|
|
for (Entry<String, SyncMap> syncMapEntry : MAP_OF_SYNCMAPS.entrySet()) {
|
|
|
|
|
|
|
|
|
|
for (Entry<String, SyncDirectory> SDEntry : syncMapEntry.getValue().syncDirectories.entrySet()) {
|
|
|
|
|
|
|
|
|
|
for (var SDEntry : syncMapEntry.getValue().syncDirectories.entrySet()) {
|
|
|
|
|
doSyncDirectory(SDEntry.getValue());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
long pause = 2000;
|
|
|
|
|
System.out.println("Pausing... for " + pause + "ms.");
|
|
|
|
|
Thread.sleep(pause);
|
|
|
|
|
} catch (InterruptedException ignored) {}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
SyncDirectory SD = SDEntry.getValue();
|
|
|
|
|
|
|
|
|
|
private void doSyncDirectory(SyncDirectory SD) {
|
|
|
|
|
state = "READ";
|
|
|
|
|
SD.readFreshState();
|
|
|
|
|
|
|
|
|
@ -46,22 +59,6 @@ public class Flow implements Runnable {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
long pause = 2000;
|
|
|
|
|
System.out.println("Pausing... for "+pause+ "ms.");
|
|
|
|
|
Thread.sleep(pause);
|
|
|
|
|
} catch (InterruptedException ignored) {
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public String getState() {
|
|
|
|
|
return state == null ? "NONE" : state;
|
|
|
|
|
}
|
|
|
|
|