Inheritance diagram for org.matsim.vis.snapshotwriters.SnapshotWriterManager:

[legend]

Public Member Functions
	SnapshotWriterManager (int snapshotPeriod, QSimConfigGroup.FilterSnapshots filterSnapshots)

void	notifyMobsimInitialized (MobsimInitializedEvent e)

void	notifyMobsimBeforeCleanup (MobsimBeforeCleanupEvent e)

void	notifyMobsimAfterSimStep (MobsimAfterSimStepEvent e)

final void	addSnapshotWriter (SnapshotWriter snapshotWriter)

Private Member Functions
void	closeSnapshotWriters ()

void	doSnapshot (final double time, VisMobsim visMobsim)

boolean	isGenerateSnapshot (Link link)

Private Attributes
final List< SnapshotWriter >	snapshotWriters = new ArrayList<>()

final QSimConfigGroup.FilterSnapshots	filterSnapshots

final int	snapshotPeriod

double	snapshotTime = 0.0

Static Private Attributes
static final Logger	log = LogManager.getLogger(SnapshotWriterManager.class)

Detailed Description

Definition at line 41 of file SnapshotWriterManager.java.

Constructor & Destructor Documentation

◆ SnapshotWriterManager()

org.matsim.vis.snapshotwriters.SnapshotWriterManager.SnapshotWriterManager	(	int	snapshotPeriod,
		QSimConfigGroup.FilterSnapshots	filterSnapshots
	)

Definition at line 54 of file SnapshotWriterManager.java.

References org.matsim.vis.snapshotwriters.SnapshotWriterManager.filterSnapshots, and org.matsim.vis.snapshotwriters.SnapshotWriterManager.snapshotPeriod.

                                                                                                       {
         this.snapshotPeriod = snapshotPeriod;
         this.filterSnapshots = filterSnapshots;
     }

Member Function Documentation

◆ notifyMobsimInitialized()

void org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimInitialized ( MobsimInitializedEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimInitializedListener.

Definition at line 60 of file SnapshotWriterManager.java.

References org.matsim.core.mobsim.framework.MobsimTimer.getSimStartTime(), org.matsim.core.mobsim.qsim.interfaces.Netsim.getSimTimer(), and org.matsim.vis.snapshotwriters.SnapshotWriterManager.snapshotPeriod.

                                                                   {
         Netsim mobsim = (Netsim) e.getQueueSimulation();
         this.snapshotTime = Math.floor(mobsim.getSimTimer().getSimStartTime()
                 / this.snapshotPeriod)
                 * this.snapshotPeriod;
         if (this.snapshotTime < mobsim.getSimTimer().getSimStartTime()) {
             this.snapshotTime += this.snapshotPeriod;
         }
     }

Here is the call graph for this function:

◆ notifyMobsimBeforeCleanup()

void org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimBeforeCleanup ( MobsimBeforeCleanupEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimBeforeCleanupListener.

Definition at line 71 of file SnapshotWriterManager.java.

References org.matsim.vis.snapshotwriters.SnapshotWriterManager.closeSnapshotWriters().

                                                                       {
         closeSnapshotWriters();
     }

Here is the call graph for this function:

◆ closeSnapshotWriters()

void org.matsim.vis.snapshotwriters.SnapshotWriterManager.closeSnapshotWriters ( )

private

Definition at line 75 of file SnapshotWriterManager.java.

Referenced by org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimBeforeCleanup().

                                         {
         for (SnapshotWriter writer : this.snapshotWriters) {
             writer.finish();
         }
     }

◆ notifyMobsimAfterSimStep()

void org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimAfterSimStep ( MobsimAfterSimStepEvent e )

Implements org.matsim.core.mobsim.framework.listeners.MobsimAfterSimStepListener.

Definition at line 82 of file SnapshotWriterManager.java.

References org.matsim.vis.snapshotwriters.SnapshotWriterManager.doSnapshot(), org.matsim.core.mobsim.framework.events.MobsimAfterSimStepEvent< T extends Mobsim >.getSimulationTime(), and org.matsim.vis.snapshotwriters.SnapshotWriterManager.snapshotPeriod.

                                                                     {
         double time = e.getSimulationTime();
         if (time >= this.snapshotTime) {
             this.snapshotTime += this.snapshotPeriod;
             doSnapshot(time, (VisMobsim) e.getQueueSimulation());
         }
     }

Here is the call graph for this function:

◆ doSnapshot()

void org.matsim.vis.snapshotwriters.SnapshotWriterManager.doSnapshot	(	final double	time,
		VisMobsim	visMobsim
	)

private

Definition at line 90 of file SnapshotWriterManager.java.

References org.matsim.vis.snapshotwriters.VisNetwork.getVisLinks(), org.matsim.vis.snapshotwriters.VisMobsim.getVisNetwork(), and org.matsim.vis.snapshotwriters.SnapshotWriterManager.isGenerateSnapshot().

Referenced by org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimAfterSimStep().

                                                                     {
         if (!this.snapshotWriters.isEmpty()) {
 
             // This could be parallel since mihal has fixed some concurrency issues in the SnapshotInfoBuilder
             // I think mainly by using separate builders for each generated AgentPositionInfo.
             // I don't have time to test this right now, but if this ever appears to be a bottle neck, this probably
             // can be replaced by a parallel stream. janek: oct' 2021
             var positions = visMobsim.getVisNetwork().getVisLinks().values().stream()
                     .filter(visLink -> isGenerateSnapshot(visLink.getLink()))
                     .flatMap(visLink -> visLink.getVisData().addAgentSnapshotInfo(new HashSet<>()).stream())
                     .collect(Collectors.toSet());
 
             // We do not put non-network agents in movies.
             // Otherwise, we would add snapshots from visMobsim.getNonNetworkAgentSnapshots() here.
 
             for (SnapshotWriter writer : this.snapshotWriters) {
                 writer.beginSnapshot(time);
                 for (AgentSnapshotInfo position : positions) {
                     writer.addAgent(position);
                 }
                 writer.endSnapshot();
             }
         }
     }

Here is the call graph for this function:

◆ addSnapshotWriter()

final void org.matsim.vis.snapshotwriters.SnapshotWriterManager.addSnapshotWriter ( SnapshotWriter snapshotWriter )

Definition at line 115 of file SnapshotWriterManager.java.

Referenced by org.matsim.vis.snapshotwriters.SnapshotWritersModule.SnapshotWriterManagerProvider.get().

                                                                        {
         this.snapshotWriters.add(snapshotWriter);
     }

◆ isGenerateSnapshot()

boolean org.matsim.vis.snapshotwriters.SnapshotWriterManager.isGenerateSnapshot ( Link link )

private

Definition at line 119 of file SnapshotWriterManager.java.

References org.matsim.vis.snapshotwriters.SnapshotWriterManager.filterSnapshots, org.matsim.vis.snapshotwriters.SnapshotWritersModule.GENERATE_SNAPSHOT_FOR_LINK_KEY, org.matsim.utils.objectattributes.attributable.Attributes.getAttribute(), and org.matsim.utils.objectattributes.attributable.Attributable.getAttributes().

Referenced by org.matsim.vis.snapshotwriters.SnapshotWriterManager.doSnapshot().

                                                   {
         switch (filterSnapshots) {
             case no:
                 return true;
             case withLinkAttributes:
                 return Objects.equals(link.getAttributes().getAttribute(SnapshotWritersModule.GENERATE_SNAPSHOT_FOR_LINK_KEY), true);
             default:
                 throw new RuntimeException("Unexpected filter snapshot setting: " + filterSnapshots + " Possible are: [no, withLinkAttributes]. This can be changed in config.qsim.filterSnapshots");
         }
     }

Here is the call graph for this function:

Member Data Documentation

◆ log

final Logger org.matsim.vis.snapshotwriters.SnapshotWriterManager.log = LogManager.getLogger(SnapshotWriterManager.class)

staticprivate

Definition at line 43 of file SnapshotWriterManager.java.

◆ snapshotWriters

final List<SnapshotWriter> org.matsim.vis.snapshotwriters.SnapshotWriterManager.snapshotWriters = new ArrayList<>()

private

Definition at line 45 of file SnapshotWriterManager.java.

◆ filterSnapshots

final QSimConfigGroup.FilterSnapshots org.matsim.vis.snapshotwriters.SnapshotWriterManager.filterSnapshots

private

Definition at line 46 of file SnapshotWriterManager.java.

Referenced by org.matsim.vis.snapshotwriters.SnapshotWriterManager.isGenerateSnapshot(), and org.matsim.vis.snapshotwriters.SnapshotWriterManager.SnapshotWriterManager().

◆ snapshotPeriod

final int org.matsim.vis.snapshotwriters.SnapshotWriterManager.snapshotPeriod

private

Definition at line 47 of file SnapshotWriterManager.java.

Referenced by org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimAfterSimStep(), org.matsim.vis.snapshotwriters.SnapshotWriterManager.notifyMobsimInitialized(), and org.matsim.vis.snapshotwriters.SnapshotWriterManager.SnapshotWriterManager().

◆ snapshotTime

double org.matsim.vis.snapshotwriters.SnapshotWriterManager.snapshotTime = 0.0

private

time since last snapshot

Definition at line 52 of file SnapshotWriterManager.java.

The documentation for this class was generated from the following file:

vis/snapshotwriters/SnapshotWriterManager.java

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ SnapshotWriterManager()

Member Function Documentation

◆ notifyMobsimInitialized()

◆ notifyMobsimBeforeCleanup()

◆ closeSnapshotWriters()

◆ notifyMobsimAfterSimStep()

◆ doSnapshot()

◆ addSnapshotWriter()

◆ isGenerateSnapshot()

Member Data Documentation

◆ log

◆ snapshotWriters

◆ filterSnapshots

◆ snapshotPeriod

◆ snapshotTime