Added functionality to support RSUs at intersections

src/de/tud/kom/p2psim/impl/topology/movement/RSUMovementModel.java

+/*
+ * Copyright (c) 2005-2010 KOM – Multimedia Communications Lab
+ *
+ * This file is part of PeerfactSim.KOM.
+ *
+ * PeerfactSim.KOM is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * any later version.
+ *
+ * PeerfactSim.KOM is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with PeerfactSim.KOM.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+package de.tud.kom.p2psim.impl.topology.movement;
+
+import java.util.HashMap;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import de.tud.kom.p2psim.api.network.SimNetInterface;
+import de.tud.kom.p2psim.api.topology.movement.MovementModel;
+import de.tud.kom.p2psim.api.topology.movement.SimLocationActuator;
+import de.tud.kom.p2psim.impl.network.routed.RoutedNetLayer;
+import de.tud.kom.p2psim.impl.topology.PositionVector;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.information.Position;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.sumo.simulation.controller.SimulationSetupExtractor;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.sumo.simulation.controller.traci.TraciSimulationController;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.sumo.simulation.controller.xml.XMLSimulationController;
+import de.tudarmstadt.maki.simonstrator.api.Host;
+import de.tudarmstadt.maki.simonstrator.api.Time;
+import de.tudarmstadt.maki.simonstrator.api.common.graph.INodeID;
+import de.tudarmstadt.maki.simonstrator.api.component.ComponentNotAvailableException;
+import de.tudarmstadt.maki.simonstrator.api.component.sensor.future_location.FutureLocationSensor;
+import de.tudarmstadt.maki.simonstrator.api.component.sensor.location.Location;
+import de.tudarmstadt.maki.simonstrator.api.component.sis.SiSComponent;
+import de.tudarmstadt.maki.simonstrator.api.component.sis.SiSDataCallback;
+import de.tudarmstadt.maki.simonstrator.api.component.sis.SiSInfoProperties;
+import de.tudarmstadt.maki.simonstrator.api.component.sis.SiSInformationProvider.SiSProviderHandle;
+import de.tudarmstadt.maki.simonstrator.api.component.sis.exception.InformationNotAvailableException;
+import de.tudarmstadt.maki.simonstrator.api.component.sis.type.SiSTypes;
+import de.tudarmstadt.maki.simonstrator.api.util.XMLConfigurableConstructor;
+
+public class RSUMovementModel implements MovementModel, FutureLocationSensor {
+
+	private final List<SimLocationActuator> components;
+
+	private final String sumoExe;
+	private final String sumoConfigFile;
+
+	private final String sumoIntersections;
+
+	private final int offsetX;
+	private final int offsetY;
+	private final int width;
+	private final int height;
+
+	private final long timestepConversion = Time.SECOND;
+
+	private boolean initialized = false;
+
+	private SimulationSetupExtractor _controller;
+
+	private List<Position> _intersections;
+	private int _currentIndex = 0;
+
+	private final Map<INodeID, Integer> hostIntersectionMatching = new HashMap<>();
+
+	@XMLConfigurableConstructor({ "sumoExe", "sumoConfigFile", "offsetX", "offsetY", "width", "height" })
+	public RSUMovementModel(String sumoExe, String sumoConfigFile,  String offsetX, String offsetY, String width, String height) {
+		this.components = new LinkedList<>();
+
+		this.sumoExe = sumoExe;
+		this.sumoConfigFile = sumoConfigFile;
+
+		this.sumoIntersections = null;
+
+		this.offsetX = Integer.parseInt(offsetX);
+		this.offsetY = Integer.parseInt(offsetY);
+		this.width = Integer.parseInt(width);
+		this.height = Integer.parseInt(height);
+	}
+
+	@XMLConfigurableConstructor({ "sumoIntersections", "offsetX", "offsetY", "width", "height" })
+	public RSUMovementModel(String sumoIntersections,  String offsetX, String offsetY, String width, String height) {
+		this.components = new LinkedList<>();
+
+		this.sumoIntersections = sumoIntersections;
+
+		this.sumoExe = null;
+		this.sumoConfigFile = null;
+
+		this.offsetX = Integer.parseInt(offsetX);
+		this.offsetY = Integer.parseInt(offsetY);
+		this.width = Integer.parseInt(width);
+		this.height = Integer.parseInt(height);
+	}
+
+	@Override
+	public final void addComponent(SimLocationActuator comp) {
+		components.add(comp);
+
+		try {
+			final SiSComponent sis = comp.getHost().getComponent(SiSComponent.class);
+			sis.provide().nodeState(SiSTypes.FUTURE_PHY_LOCATION,
+					new SiSDataCallback<Location>() {
+
+				Set<INodeID> localID = INodeID
+						.getSingleIDSet(comp.getHost().getId());
+
+				@Override
+				public Location getValue(INodeID nodeID,
+						SiSProviderHandle providerHandle)
+								throws InformationNotAvailableException {
+					if (nodeID.equals(comp.getHost().getId())) {
+						return getFutureLocation(comp.getHost());
+					} else {
+						throw new InformationNotAvailableException();
+					}
+				}
+
+				@Override
+				public Set<INodeID> getObservedNodes() {
+					return localID;
+				}
+
+				@Override
+				public SiSInfoProperties getInfoProperties() {
+					return new SiSInfoProperties();
+				}
+			});
+		} catch (ComponentNotAvailableException e) {
+			// Nothing to do
+		}
+
+	}
+
+	@Override
+	public void setTimeBetweenMoveOperations(long time) {
+		//Do nothing, only used for placement of RSU
+	}
+
+	@Override
+	public synchronized void placeComponent(SimLocationActuator actuator) {
+		if (!initialized) {
+			initializeModel();
+			initialized = true;
+		}
+		if (_currentIndex < _intersections.size()) {
+			// Initial placement
+			Position intersection = _intersections.get(_currentIndex);
+			actuator.updateCurrentLocation(new PositionVector(intersection.getX() / VehicleMovementModel.SCALING_FACTOR, intersection.getY() / VehicleMovementModel.SCALING_FACTOR));
+
+			hostIntersectionMatching.put(actuator.getHost().getId(), _currentIndex);
+
+			_currentIndex++;
+
+			//Put interfaces online
+			try {
+				RoutedNetLayer routedNetLayer = actuator.getHost().getComponent(RoutedNetLayer.class);
+				for (SimNetInterface netInterface : routedNetLayer.getSimNetworkInterfaces()) {
+					if (netInterface.isOffline()) {
+						netInterface.goOnline();
+					}
+				}
+			} catch (ComponentNotAvailableException e) {
+				e.printStackTrace();
+			}
+		} else {
+			actuator.updateCurrentLocation(new PositionVector(Double.NaN, Double.NaN));
+		}
+	}
+
+	/**
+	 * Initializes the movement model by executing BonnMotion and parsing the
+	 * resulting movement trace.
+	 */
+	protected void initializeModel() {
+		if (this.sumoExe != null) {
+			_controller = TraciSimulationController.createSimulationController(sumoExe, sumoConfigFile);
+			_controller.init();
+			_controller.setObservedArea(offsetX, offsetY, offsetX + width, offsetY + height);
+			_intersections = _controller.getAllIntersections(true);
+		} else {
+			_controller = new XMLSimulationController(null, sumoIntersections);
+			_controller.init();
+			_controller.setObservedArea(offsetX, offsetY, offsetX + width, offsetY + height);
+			_intersections = _controller.getAllIntersections(true);
+		}
+
+		//		System.out.println("Require " + _intersections.size() + " RSUs");
+	}
+
+	@Override
+	public Location getFutureLocation(Host pHost) {
+		if (hostIntersectionMatching.containsKey(pHost.getId())) {
+			int intersection = hostIntersectionMatching.get(pHost.getId());
+			Position intersectionPosition = _intersections.get(intersection);
+			if (intersectionPosition != null) {
+				return new PositionVector(intersectionPosition.getX(), intersectionPosition.getY());
+			}
+		}
+		return null;
+	}
+
+}
\ No newline at end of file

src/de/tud/kom/p2psim/impl/topology/placement/RSUPlacement.java

+/*
+ * Copyright (c) 2005-2010 KOM – Multimedia Communications Lab
+ *
+ * This file is part of PeerfactSim.KOM.
+ *
+ * PeerfactSim.KOM is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * any later version.
+ *
+ * PeerfactSim.KOM is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with PeerfactSim.KOM.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+package de.tud.kom.p2psim.impl.topology.placement;
+
+import java.util.List;
+
+import de.tud.kom.p2psim.api.topology.TopologyComponent;
+import de.tud.kom.p2psim.api.topology.placement.PlacementModel;
+import de.tud.kom.p2psim.impl.topology.PositionVector;
+import de.tud.kom.p2psim.impl.topology.movement.VehicleMovementModel;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.information.Position;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.sumo.simulation.controller.SimulationSetupExtractor;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.sumo.simulation.controller.traci.TraciSimulationController;
+import de.tud.kom.p2psim.impl.topology.movement.vehicular.sumo.simulation.controller.xml.XMLSimulationController;
+import de.tudarmstadt.maki.simonstrator.api.util.XMLConfigurableConstructor;
+
+/**
+ */
+public class RSUPlacement implements PlacementModel {
+
+	private final String sumoExe;
+	private final String sumoConfigFile;
+
+	private final String sumoIntersections;
+
+	private final int offsetX;
+	private final int offsetY;
+	private final int width;
+	private final int height;
+
+	private SimulationSetupExtractor _controller;
+
+	private List<Position> _intersections;
+	private int _currentIndex = 0;
+
+	@XMLConfigurableConstructor({ "sumoExe", "sumoConfigFile", "offsetX", "offsetY", "width", "height" })
+	public RSUPlacement(String sumoExe, String sumoConfigFile, String offsetX, String offsetY, String width, String height) {
+		this.sumoExe = sumoExe;
+		this.sumoConfigFile = sumoConfigFile;
+
+		this.sumoIntersections = null;
+
+		this.offsetX = Integer.parseInt(offsetX);
+		this.offsetY = Integer.parseInt(offsetY);
+		this.width = Integer.parseInt(width);
+		this.height = Integer.parseInt(height);
+
+		initializeModel();
+	}
+
+	@XMLConfigurableConstructor({ "sumoIntersections", "offsetX", "offsetY", "width", "height" })
+	public RSUPlacement(String sumoIntersections, String offsetX, String offsetY, String width, String height) {
+		this.sumoIntersections = sumoIntersections;
+
+		this.sumoExe = null;
+		this.sumoConfigFile = null;
+
+		this.offsetX = Integer.parseInt(offsetX);
+		this.offsetY = Integer.parseInt(offsetY);
+		this.width = Integer.parseInt(width);
+		this.height = Integer.parseInt(height);
+
+		initializeModel();
+	}
+
+	/**
+	 * Initializes the movement model by executing BonnMotion and parsing the
+	 * resulting movement trace.
+	 */
+	protected void initializeModel() {
+		if (this.sumoExe != null) {
+			_controller = TraciSimulationController.createSimulationController(sumoExe, sumoConfigFile);
+			_controller.init();
+			_controller.setObservedArea(offsetX, offsetY, offsetX + width, offsetY + height);
+			_intersections = _controller.getAllIntersections(true);
+		} else {
+			_controller = new XMLSimulationController(null, sumoIntersections);
+			_controller.init();
+			_controller.setObservedArea(offsetX, offsetY, offsetX + width, offsetY + height);
+			_intersections = _controller.getAllIntersections(true);
+		}
+	}
+
+	@Override
+	public void addComponent(TopologyComponent comp) {
+		//
+	}
+
+	@Override
+	public PositionVector place(TopologyComponent comp) {
+		if (_currentIndex < _intersections.size()) {
+			Position intersection = _intersections.get(_currentIndex);
+			_currentIndex++;
+			return new PositionVector(intersection.getX() / VehicleMovementModel.SCALING_FACTOR, intersection.getY() / VehicleMovementModel.SCALING_FACTOR);
+		} else {
+			return new PositionVector(Double.NaN, Double.NaN);
+		}
+	}
+
+}