- Timestamp:
- 07/06/13 03:51:11 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/dumping/LoadStream.java
r96 r97 2 2 3 3 import com.framsticks.communication.File; 4 import com.framsticks.core. InstanceUtils;4 import com.framsticks.core.TreeOperations; 5 5 import com.framsticks.core.Path; 6 6 import com.framsticks.params.ListSource; 7 import com.framsticks.core. Instance;7 import com.framsticks.core.Tree; 8 8 import com.framsticks.util.*; 9 9 import com.framsticks.util.dispatching.Future; … … 24 24 private final static Logger log = Logger.getLogger(LoadStream.class.getName()); 25 25 26 protected final Instance instance;26 protected final Tree tree; 27 27 protected final Path mountPath; 28 28 protected final BufferedReader stream; … … 31 31 32 32 33 public LoadStream(Path mountPath, BufferedReader stream, Instance instance, Future<Path> future) {34 this. instance = instance;33 public LoadStream(Path mountPath, BufferedReader stream, Tree tree, Future<Path> future) { 34 this.tree = tree; 35 35 this.mountPath = mountPath; 36 36 this.stream = stream; … … 59 59 if (line.equals("ok")) { 60 60 if (query.first.equals("get")) { 61 Path path = InstanceUtils.createIfNeeded(instance, query.second);62 InstanceUtils.processFetchedValues(path, files);61 Path path = TreeOperations.createIfNeeded(tree, query.second); 62 TreeOperations.processFetchedValues(path, files); 63 63 } else if (query.first.equals("info")) { 64 64 assert files.size() == 1; 65 InstanceUtils.processFetchedInfo(instance, files.get(0));65 TreeOperations.processFetchedInfo(tree, files.get(0)); 66 66 } else { 67 67 assert false; … … 87 87 } 88 88 log.info("loaded in: " + stopwatch); 89 future.pass(Path.to( instance, mountPath.getTextual()));89 future.pass(Path.to(tree, mountPath.getTextual())); 90 90 } 91 91
Note: See TracChangeset
for help on using the changeset viewer.