- Timestamp:
- 07/16/13 23:31:35 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/hosting/ClientAtServer.java
r100 r102 30 30 31 31 import static com.framsticks.core.TreeOperations.*; 32 import static com.framsticks.params.AccessOperations.*; 32 33 33 34 import java.net.Socket; … … 61 62 cliObject = new Cli(this); 62 63 rootTree = new LocalTree(); 64 rootTree.setName(server.getName() + " root tree"); 63 65 // rootTree.setDispatcher(new AtOnceDispatcher<Tree>()); 64 66 rootTree.setDispatcher(server.getHosted().getDispatcher()); … … 114 116 public static File printToFile(String path, Access access) { 115 117 ListSink sink = new ListSink(); 116 access.save(sink);118 save(access, sink); 117 119 return new File(path, new ListSource(sink.getOut())); 118 120 } … … 143 145 if (request instanceof SetRequest) { 144 146 SetRequest setRequest = (SetRequest) request; 145 //TODO Primitive Param?146 147 tree.set(path, access.getFramsClass().getParamEntry(setRequest.getField(), PrimitiveParam.class), setRequest.getValue(), new FutureHandler<Integer>(responseCallback) { 147 148 @Override … … 198 199 protected void joinableStart() { 199 200 Dispatching.use(connection, this); 201 Dispatching.use(rootTree, this); 200 202 } 201 203 202 204 @Override 203 205 protected void joinableInterrupt() { 206 Dispatching.drop(rootTree, this); 204 207 Dispatching.drop(connection, this); 205 208 } … … 207 210 @Override 208 211 protected void joinableFinish() { 212 209 213 } 210 214 … … 212 216 protected void joinableJoin() throws InterruptedException { 213 217 Dispatching.join(connection); 218 Dispatching.join(rootTree); 214 219 } 215 220
Note: See TracChangeset
for help on using the changeset viewer.