Changeset 79 in tmcsimulator for trunk/src/atmsdriver/ATMSDriver.java

Timestamp:

10/05/2017 12:51:23 PM (9 years ago)

Author:

jtorres

Message:

new atmsdriver package in trunk. fep_rpc_client dynamic data packing added in branches. fep_rpc_client refactored data packing code into static DataPacker? class. Added vds_data folder into config/. Added new project configuration for ATMSDriver.

Location:

trunk/src/atmsdriver

Files:

• . (added)
• ATMSDriver.java (copied) (copied from branches/ATMSDriver/src/atmsdriver/ATMSDriver.java) (1 diff)

trunk/src/atmsdriver/ATMSDriver.java

@@ -1 +1 @@
 package atmsdriver;
 
-import atmsdriver.network.model.Network;
+import atmsdriver.model.Network;
 import java.io.File;
+import java.io.FileInputStream;
+import java.util.Properties;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
-/** 
+/**
  *
  * @author John A. Torres
  * @version 09/10/2017
  */
-public class ATMSDriver {
-    final private String ldsFileName = "./lds_data/lookup_lds";
-    final private String loopFileName = "./lds_data/lookup_loop";
-    final private String networkFileName = "./networkFile.txt";
+public class ATMSDriver implements Runnable {
+
+    /** ATMSDriver Error logger. */
+    private static Logger ATMSDriverLogger = Logger.getLogger("atmsdriver");
+
+    private static final String CONFIG_FILE_NAME = "atms_driver_config.properties";
+
+    /** Properties object for the CADClient class. */
+    private Properties ATMSDriverProperties;
+
+    /**
+     * Enumeration containing properties name values. See ATMSDriver class
+     * description for more information.
+     *
+     * @author John Torres
+     * @see ATMSDriver
+     */
+    private static enum PROPERTIES {
+
+        LDS_FILE_NAME("LDSFileName"),
+        LOOP_FILE_NAME("LoopFileName"),
+        NETWORK_FILE_NAME("NetworkFileName"),
+        EXCHANGE_FILE_NAME("ExchangeFileName");
+
+        public String name;
+
+        private PROPERTIES(String n) {
+            name = n;
+        }
+    }
+
+    /** Network model. */
     final private Network network;
     
-    public ATMSDriver()
-    {
-        File ldsFile = new File(ldsFileName);
-        File loopFile = new File(loopFileName);
-        File networkFile = new File(networkFileName);
-        network = new Network(ldsFile, loopFile, networkFile);
-        try {
+    /** Sleep Time (10 seconds). **/
+    private static final int SLEEP_TIME = 10000;
+    
+    /** Exchange Reader */
+    private ExchangeReader exchangeReader;
+    
+    @Override
+    public void run() {
+        // Check for packets and update the simulator
+        for (;;) {
+            // Flush the input file
+            ExchangeInfo exInfo = exchangeReader.parse(ATMSDriverProperties
+                    .getProperty(PROPERTIES.EXCHANGE_FILE_NAME.name));
             network.toXML();
-        } catch (Exception ex) {
-            Logger.getLogger(ATMSDriver.class.getName()).log(Level.SEVERE, null, ex);
+            // Update if packet is recieved
+            if (exInfo != null) {
+                System.out.println("Grabbed");
+            }
+
+            // Sleep
+            try {
+                Thread.sleep(SLEEP_TIME);
+            } catch (InterruptedException ie) {
+                
+            }
         }
     }
-    
+
+    public ATMSDriver(String propertiesFile) {
+
+        if (!verifyProperties(propertiesFile)) {
+            System.exit(0);
+        }
+
+        network = new Network(
+                new File(ATMSDriverProperties.getProperty(
+                                PROPERTIES.LDS_FILE_NAME.name)),
+                new File(ATMSDriverProperties.getProperty(
+                                PROPERTIES.LOOP_FILE_NAME.name)),
+                new File(ATMSDriverProperties.getProperty(
+                                PROPERTIES.NETWORK_FILE_NAME.name)));
+        network.toXML();
+        exchangeReader = new ExchangeReader();
+    }
+
+    private boolean verifyProperties(String propertiesFile) {
+        // Load the properties file.
+        try {
+            ATMSDriverProperties = new Properties();
+            ATMSDriverProperties.load(new FileInputStream(propertiesFile));
+        } catch (Exception e) {
+            ATMSDriverLogger.logp(Level.SEVERE, "ATMSDriver",
+                    "Constructor", "Exception in reading properties file.", e);
+        }
+
+        return true;
+    }
+
     /**
-     * @param args the command line arguments
+     * Runs the Paramics simulator.
      */
     public static void main(String[] args) {
-        ATMSDriver driver = new ATMSDriver();
+        try {
+            if (System.getProperty("ATMSDRIVER_PROPERTIES") != null) {
+                new Thread(new ATMSDriver(System.getProperty(
+                        "ATMSDRIVER_PROPERTIES"))).start();
+            } else {
+                throw new Exception("ATMSDRIVER_PROPERTIES system property not defined.");
+            }
+        } catch (Exception e) {
+            ATMSDriverLogger.logp(Level.SEVERE, "ATMSDriver", "Main",
+                    "Error occured initializing application", e);
+            System.exit(-1);
+        }
     }
-    
 }