source: tmcsimulator/branches/trunk/src/atmsdriver/ATMSDriver.java @ 82

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"),

        FEP_WRITER_HOST("FEPWriterHost"),

        FEP_WRITER_PORT("FEPWriterPort");



        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.writeToFEP();

            

            // Update if exchangeInfo is recieved

            if (exInfo != null) {

                

            }



            // 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)),

                ATMSDriverProperties.getProperty(PROPERTIES.FEP_WRITER_HOST.name),

                Integer.parseInt(ATMSDriverProperties.getProperty(

                        PROPERTIES.FEP_WRITER_PORT.name)));

        

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

        }

    }

}