source: tmcsimulator/trunk/src/atmsdriver/ATMSDriver.java @ 79

package atmsdriver;



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 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;

    

    /** 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();

            // 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;

    }



    /**

     * Runs the Paramics simulator.

     */

    public static void main(String[] args) {

        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);

        }

    }

}