- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/experiment/Simulator.java
r103 r105 4 4 import com.framsticks.communication.queries.NeedFile; 5 5 import com.framsticks.communication.queries.NeedFileAcceptor; 6 import com.framsticks.core.ListChange;7 import com.framsticks.core.Path;8 import com.framsticks.core.Tree;9 import com.framsticks.core.ValueChange;10 6 import com.framsticks.params.AccessOperations; 11 7 import com.framsticks.params.CastFailure; … … 19 15 import com.framsticks.params.types.ProcedureParam; 20 16 import com.framsticks.remote.RemoteTree; 17 import com.framsticks.structure.Path; 18 import com.framsticks.structure.Tree; 19 import com.framsticks.structure.messages.ListChange; 20 import com.framsticks.structure.messages.ValueChange; 21 import com.framsticks.util.ExceptionHandler; 21 22 import com.framsticks.util.FramsticksException; 22 23 import com.framsticks.util.dispatching.AbstractJoinable; 23 24 import com.framsticks.util.dispatching.Dispatcher; 24 25 import com.framsticks.util.dispatching.Dispatching; 25 import com.framsticks.util.dispatching. ExceptionResultHandler;26 import com.framsticks.util.dispatching.FutureHandler; 26 27 import com.framsticks.util.dispatching.Future; 27 import com.framsticks.util.dispatching.FutureHandler;28 28 import com.framsticks.util.dispatching.Joinable; 29 29 import com.framsticks.util.dispatching.JoinableParent; … … 35 35 import org.apache.logging.log4j.LogManager; 36 36 import org.apache.logging.log4j.Logger; 37 import static com.framsticks.core.TreeOperations.*; 37 import static com.framsticks.params.ParamsUtil.arguments; 38 import static com.framsticks.params.ParamsUtil.getParam; 39 import static com.framsticks.structure.TreeOperations.*; 38 40 39 41 @FramsClassAnnotation 40 public final class Simulator extends AbstractJoinable implements Dispatcher<Simulator>, JoinableParent, UniqueObject, Exception ResultHandler {42 public final class Simulator extends AbstractJoinable implements Dispatcher<Simulator>, JoinableParent, UniqueObject, ExceptionHandler { 41 43 42 44 private static final Logger log = LogManager.getLogger(Simulator.class); … … 69 71 public void action(ValueChange argument) { 70 72 try { 71 boolean running = simulatorClass.getParamEntry("running", BooleanParam.class).reassign(argument.value, null).getValue();73 boolean running = getParam(simulatorClass, "running", BooleanParam.class).reassign(argument.value, null).getValue(); 72 74 log.debug("running state of {} changed: {}", Simulator.this, running); 73 75 if (!running) { … … 80 82 }; 81 83 82 addListener(simulatorPath, simulatorClass.getParamEntry("running_changed", EventParam.class), runningListener, ValueChange.class, new FutureHandler<Void>(this) {84 addListener(simulatorPath, getParam(simulatorClass, "running_changed", EventParam.class), runningListener, ValueChange.class, new Future<Void>(this) { 83 85 @Override 84 86 protected void result(Void result) { … … 160 162 public void start() { 161 163 log.debug("starting simulator {}", this); 162 call(simulatorPath, "start", new Object[] {}, Object.class, FutureHandler.doNothing(Object.class, this));164 call(simulatorPath, "start", arguments(), Object.class, Future.doNothing(Object.class, this)); 163 165 } 164 166 … … 199 201 protected final AtomicInteger netloadIdCounter = new AtomicInteger(); 200 202 201 public <N> void netload(final N net, final Future <Object> future) {203 public <N> void netload(final N net, final FutureHandler<Object> future) { 202 204 final String netloadId = "NetLoadSaveLogic" + netloadIdCounter.getAndIncrement(); 203 205 … … 231 233 simulatorPath.getTree().addNeedFileAcceptor(Integer.MIN_VALUE, acceptor.get()); 232 234 233 call(simulatorPath, get FramsClass(simulatorPath).getParamEntry("netload_id", ProcedureParam.class), new Object[] { netloadId }, Object.class, new FutureHandler<Object>(future) {235 call(simulatorPath, getParam(simulatorPath, "netload_id", ProcedureParam.class), arguments(netloadId), Object.class, new Future<Object>(future) { 234 236 235 237 @Override 236 238 protected void result(Object result) { 237 log.debug(" upload of {} done", file);239 log.debug("netload of {} done", file); 238 240 future.pass(result); 239 241 } … … 242 244 } 243 245 244 public <N> void netsave(Class<N> netJavaClass, final Future <N> futureNet) {245 call(simulatorPath, get FramsClass(simulatorPath).getParamEntry("netsave", ProcedureParam.class), new Object[] { }, netJavaClass, new FutureHandler<N>(futureNet) {246 public <N> void netsave(Class<N> netJavaClass, final FutureHandler<N> futureNet) { 247 call(simulatorPath, getParam(simulatorPath, "netsave", ProcedureParam.class), arguments(), netJavaClass, new Future<N>(futureNet) { 246 248 247 249 @Override 248 250 protected void result(N net) { 249 log.debug(" downloadof {} done", net);251 log.debug("netsave of {} done", net); 250 252 futureNet.pass(net); 251 253 } 252 254 }); 253 254 255 } 255 256 }
Note: See TracChangeset
for help on using the changeset viewer.