Changeset 188 in tmcsimulator for trunk/src/tmcsim/cadsimulator/managers/TrafficModelManager.java

Timestamp:

10/29/2017 03:13:25 PM (9 years ago)

Author:

jdalbey

Message:

TrafficModelManager?.java: Now integrated into CAD Server. Passes smoke test, needs system testing.

File:

• trunk/src/tmcsim/cadsimulator/managers/TrafficModelManager.java (modified) (9 diffs)

trunk/src/tmcsim/cadsimulator/managers/TrafficModelManager.java

@@ -26 +26 @@
 import java.util.logging.Logger;
 import javax.swing.JOptionPane;
+import javax.swing.JWindow;
 import javax.swing.Timer;
+import javax.swing.UIManager;
 import tmcsim.cadsimulator.Coordinator;
+import tmcsim.cadsimulator.viewer.model.CADSimulatorState;
 import tmcsim.client.ATMSBatchDriver;
 import tmcsim.client.ATMSBatchViewer;
@@ -39 +42 @@
  * @version 2.0
  */
-public class TrafficModelManager extends Observable 
+public class TrafficModelManager
 {
     private final static int ONE_SECOND = 1000;
@@ -78 +81 @@
     };
 
-    /**
-     * Reference to the simulation Coordinator from whom we get simulation
-     * elapsed time.
-     */
-    private Coordinator theCoordinator;
 
     /**
@@ -112 +110 @@
      *
      * @param propertiesFile Target file path of properties file.
-     */
-    public TrafficModelManager(String propertiesFile) throws SimulationException 
+     * @param theCoordinator Reference to the simulation Coordinator from whom we get simulation
+     * elapsed time.
+     */
+    public TrafficModelManager(String propertiesFile, final Coordinator theCoordinator) 
+            throws SimulationException 
     {
         if (!loadProperties(propertiesFile))
@@ -119 +120 @@
             System.exit(0);
         }
-
+//        final Coordinator theCoordinator = theCoordinator;
         // Initialize the highway model
         incidents = new HashMap<String, List<TrafficEvent>>();
         highways = new Highways(
-                "config/vds_data/highways_fullmap.txt",
+                atmsProperties.getProperty(PROPERTIES.HIGHWAYS_MAP_FILE.name),
+                //"config/vds_data/highways_fullmap.txt",
                 //        "192.168.251.46", 8080);  //IP address of FEP Sim Linux VM
-                "localhost", 8080); 
+                atmsProperties.getProperty(PROPERTIES.FEPSIM_IP_ADDR.name),
+                8080); 
 
         // READ THE BATCH FILE OF COMMANDS and put in a queue
-        readBatchFile();
+        eventQueue = readBatchFile();
         // Launch the display
         theView = new TrafficModelViewer(this, new ArrayList<String>(incidents.keySet()));
@@ -245 +248 @@
         return true;
     }
-    private void readBatchFile()
+    /**
+     * Read a file of traffic events.  
+     * @return the chronologically ordered list of events
+     */
+    // Method is package private to facilitate unit testing.
+    LinkedList<TrafficEvent> readBatchFile()
     {
         FileInputStream fis;
+        LinkedList<TrafficEvent> eventList = new LinkedList<TrafficEvent>();
         try
         {
-            fis = new FileInputStream("config/vds_data/atmsBatchEvents.txt");
-            eventQueue = new LinkedList<TrafficEvent>();
+            fis = new FileInputStream(
+                    //"config/vds_data/atmsBatchEvents.txt");
+            atmsProperties.getProperty(PROPERTIES.EVENTS_FILE.name));
             // Read all lines from the file of events
             Scanner scan = new Scanner(fis);
@@ -264 +274 @@
                     {
                         evt = new TrafficEvent(line);
-                        eventQueue.add(evt);
+                        eventList.add(evt);
                         String incident = evt.incident;
                         // Add the line to the list for the corresponding incident
@@ -293 +303 @@
             Logger.getLogger(ATMSBatchDriver.class.getName()).log(Level.SEVERE, null, ex);
         }
-        System.out.println("Events file read, " + eventQueue.size() + " events queued.");
+        System.out.println("Events file read, " + eventList.size() + " events queued.");
         // Put the events in chronological order
-        Collections.sort(eventQueue);
+        Collections.sort(eventList);
+        return eventList;
     }
 
@@ -343 +354 @@
     }
 
+    /**
+     * Construct the CADClient with the properties file path, either from the
+     * command line arguments or default.
+     *
+     * @param args Command line arguments.
+     */
+    public static void main(String[] args) throws RemoteException
+    {
+        final String CONFIG_FILE_NAME = "traffic_model_config.properties";        
+        if (System.getProperty("CONFIG_DIR") == null)
+        {
+            System.setProperty("CONFIG_DIR", "config");
+        }
+        CADSimulatorState theModel = new CADSimulatorState();
+        Coordinator theCoordinator = new Coordinator(theModel);
+        try
+        {
+            UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
+            new TrafficModelManager(System.getProperty("CONFIG_DIR") + System.getProperty("file.separator") + CONFIG_FILE_NAME,
+            theCoordinator);
+
+        }
+        catch (Exception e)
+        {
+            atmsLogger.logp(Level.SEVERE, "SimulationManager", "Main",
+                    "Error initializing application.");
+
+            JOptionPane.showMessageDialog(new JWindow(), e.getMessage(),
+                    "Error - Program Exiting", JOptionPane.ERROR_MESSAGE);
+
+            System.exit(-1);
+        }
+
+    }
     class WriteToFEPThread extends Thread
     {