Package org.eclipse.mosaic.fed.sumo.ambassador

Class AbstractSumoAmbassador

java.lang.Object

org.eclipse.mosaic.rti.api.AbstractFederateAmbassador

org.eclipse.mosaic.fed.sumo.ambassador.AbstractSumoAmbassador

All Implemented Interfaces:

Comparable<FederateAmbassador>, EventProcessor, FederateAmbassador

Direct Known Subclasses:

SumoAmbassador

@NotThreadSafe
public abstract class AbstractSumoAmbassador
extends AbstractFederateAmbassador
implements EventProcessor

Implementation of a AbstractFederateAmbassador for the traffic simulator SUMO. It allows to control the progress of the traffic simulation and publishes VehicleUpdates.

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.mosaic.rti.api.AbstractFederateAmbassador

AbstractFederateAmbassador.InteractionQueue

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,org.eclipse.mosaic.fed.sumo.ambassador.ExternalVehicleState>	externalVehicles	List of vehicles that are simulated externally.

Fields inherited from class org.eclipse.mosaic.rti.api.AbstractFederateAmbassador

ambassadorParameter, descriptor, endTime, interactionQueue, log, lookahead, rti

Method Summary

Modifier and Type	Method	Description
boolean	canProcessEvent()	Checks, if this EventProcessor is able to process any events.
void	changeExternalParameters(VehicleParametersChange vehicleParametersChange)	Changes parameters of externally added vehicles.
void	connectToFederate(String host, int port)	Connects to SUMO using the given host and port.
void	connectToFederate(String host, InputStream in, InputStream err)	Connects to SUMO using the given host with input stream.
FederateExecutor	createFederateExecutor(String host, int port, CLocalHost.OperatingSystem os)	Creates and sets new federate executor.
void	finishSimulation()	Finishes the simulation.
void	initialize(long startTime, long endTime)	This method is called to tell the federate the start time and the end time.
protected void	initSumoConnection()	Initializes the TraciClient.
boolean	isTimeConstrained()	Returns whether this federate is time constrained.
boolean	isTimeRegulating()	Returns whether this federate is time regulating.
void	processEvent(Event event)	Processes the given event.
void	processInteraction(Interaction interaction)	This method processes the interactions.
protected void	processInteractionAdvanced(Interaction interaction, long time)	This processes all other types of interactions as part of processTimeAdvanceGrant(long).
void	processTimeAdvanceGrant(long time)	This method is called by the AbstractFederateAmbassador when a time advance has been granted by the RTI.

Methods inherited from class org.eclipse.mosaic.rti.api.AbstractFederateAmbassador

advanceTime, compareTo, createDockerFederateExecutor, getEndTime, getId, getPriority, receiveInteraction, setFederateDescriptor, setRtiAmbassador

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

externalVehicles

protected final Map<String,org.eclipse.mosaic.fed.sumo.ambassador.ExternalVehicleState> externalVehicles

List of vehicles that are simulated externally.

Method Details

createFederateExecutor

@Nonnull
public FederateExecutor createFederateExecutor(String host,
 int port,
 CLocalHost.OperatingSystem os)

Creates and sets new federate executor.

Specified by:

createFederateExecutor in interface FederateAmbassador

Overrides:

createFederateExecutor in class AbstractFederateAmbassador

Parameters:

host - name of the host (as specified in /etc/hosts.json)

port - port number to be used by this federate

os - operating system enum

Returns:

FederateExecutor.

connectToFederate

public void connectToFederate(String host,
 InputStream in,
 InputStream err)
                       throws InternalFederateException

Connects to SUMO using the given host with input stream.

Specified by:

connectToFederate in interface FederateAmbassador

Overrides:

connectToFederate in class AbstractFederateAmbassador

Parameters:

host - The host on which the simulator is running.

in - This input stream is connected to the output stream of the started simulator process. The stream is only valid during this method call.

err - Error by connecting to federate.

Throws:

InternalFederateException - Exception if an error occurred while starting SUMO.

connectToFederate

public void connectToFederate(String host,
 int port)

Connects to SUMO using the given host and port.

Specified by:

connectToFederate in interface FederateAmbassador

Overrides:

connectToFederate in class AbstractFederateAmbassador

Parameters:

host - host on which SUMO is running.

port - port on which TraCI is listening.

initialize

public void initialize(long startTime,
 long endTime)
                throws InternalFederateException

This method is called to tell the federate the start time and the end time.

Specified by:

initialize in interface FederateAmbassador

Overrides:

initialize in class AbstractFederateAmbassador

Parameters:

startTime - Start time of the simulation run in nano seconds.

endTime - End time of the simulation run in nano seconds.

Throws:

InternalFederateException - Exception is thrown if an error is occurred while execute of a federate.

initSumoConnection

protected void initSumoConnection()
                           throws InternalFederateException

Initializes the TraciClient.

Throws:

InternalFederateException - Exception is thrown if an error is occurred while execution of a federate.

processInteraction

public void processInteraction(Interaction interaction)
                        throws InternalFederateException

This method processes the interactions.

Overrides:

processInteraction in class AbstractFederateAmbassador

Parameters:

interaction - The interaction that can be processed

Throws:

InternalFederateException - Exception is thrown if an error is occurred while execute of a federate.

processInteractionAdvanced

protected void processInteractionAdvanced(Interaction interaction,
 long time)
                                   throws InternalFederateException

This processes all other types of interactions as part of processTimeAdvanceGrant(long).

Parameters:

interaction - The interaction to process.

time - The time of the processed interaction.

Throws:

InternalFederateException - Exception if the interaction time is not correct.

processEvent

public void processEvent(Event event)
                  throws Exception

Description copied from interface: EventProcessor

Processes the given event.

Specified by:

processEvent in interface EventProcessor

Parameters:

event - the event to process

Throws:

Exception

processTimeAdvanceGrant

public void processTimeAdvanceGrant(long time)
                             throws InternalFederateException

Description copied from class: AbstractFederateAmbassador

This method is called by the AbstractFederateAmbassador when a time advance has been granted by the RTI. Before this call is placed, any unprocessed interaction is forwarded to the federate using the processInteraction method.

Overrides:

processTimeAdvanceGrant in class AbstractFederateAmbassador

Parameters:

time - The timestamp towards which the federate can advance it local time.

Throws:

InternalFederateException

changeExternalParameters

public void changeExternalParameters(VehicleParametersChange vehicleParametersChange)
                              throws InternalFederateException

Changes parameters of externally added vehicles. So far only color change is supported.

Parameters:

vehicleParametersChange - Stores a list of vehicle parameters that should be changed.

Throws:

InternalFederateException - Throws an IllegalArgumentException if color could not be set correctly.

finishSimulation

public void finishSimulation()

Description copied from class: AbstractFederateAmbassador

Finishes the simulation.

Specified by:

finishSimulation in interface FederateAmbassador

Overrides:

finishSimulation in class AbstractFederateAmbassador

isTimeConstrained

public boolean isTimeConstrained()

Description copied from interface: FederateAmbassador

Returns whether this federate is time constrained. Is set if the federate is sensitive towards the correct ordering of events. The federate ambassador will ensure that the message processing happens in time stamp order. If set to false, interactions will be processed will be in receive order.

Specified by:

isTimeConstrained in interface FederateAmbassador

Returns:

true if this federate is time constrained, else false

isTimeRegulating

public boolean isTimeRegulating()

Description copied from interface: FederateAmbassador

Returns whether this federate is time regulating. Is set if the federate influences other federates and can prevent them from advancing their local time.

Specified by:

isTimeRegulating in interface FederateAmbassador

Returns:

true if this federate is time regulating, false else

canProcessEvent

public boolean canProcessEvent()

Description copied from interface: EventProcessor

Checks, if this EventProcessor is able to process any events. If the processor is not currently to able to process a given event, those events will be skipped and never reach this EventProcessor.

Specified by:

canProcessEvent in interface EventProcessor

Returns:

true if this EventProcessor is currently able to process events, otherwise false.