Changeset 105 in tmcsimulator for trunk/src

Timestamp:

10/12/2017 09:57:54 AM (9 years ago)

Author:

jdalbey

Message:

ATMSDriverClient.java Enhanced so it now syncs with Sim Mgr clock and reads a file of events and pretends to launch each event at the schedule time. Added batch event data file.

File:

• trunk/src/tmcsim/client/ATMSDriverClient.java (modified) (6 diffs)

trunk/src/tmcsim/client/ATMSDriverClient.java

@@ -4 +4 @@
 import java.awt.event.ActionListener;
 import java.io.FileInputStream;
+import java.io.FileNotFoundException;
 import java.rmi.Naming;
 import java.rmi.RemoteException;
 import java.rmi.server.UnicastRemoteObject;
+import java.util.LinkedList;
 import java.util.Properties;
+import java.util.Queue;
+import java.util.Scanner;
 import java.util.concurrent.TimeUnit;
 import java.util.logging.Level;
@@ -33 +37 @@
         CADClientInterface
 {
+    private static final String CONFIG_FILE_NAME = "cad_client_config.properties";
+    private final static int ONE_SECOND = 1000;
     /**
      * Error logger.
@@ -82 +88 @@
      */
     private CADClientInterface client = this;
-    private static final String CONFIG_FILE_NAME = "cad_client_config.properties";
-    private final static int ONE_SECOND = 1000;
+    
+    /** 
+     * Queue of batch events
+     */
+    private Queue<String> eventQueue;
+    
 
     /**
@@ -104 +114 @@
 
         // READ THE BATCH FILE OF COMMANDS and put in a queue
+        readBatchFile();
         // Consider special cases:  1) time to fire first command
         // has already past when application starts.
@@ -114 +125 @@
             public void actionPerformed(ActionEvent e)
             {
+                String currentClock = "";
                 try
                 {
                     long simtime = theCoorInt.getCurrentSimulationTime();
+                    currentClock = formatInterval(simtime);
+                    System.out.println("Current clock: " + currentClock);
+                } catch (RemoteException ex)
+                {
+                    Logger.getLogger(ATMSDriverClient.class.getName()).log(Level.SEVERE, null, ex);
+                }
+                if (!eventQueue.isEmpty())
+                {
                     // Check the queue of commands to see if the first
                     // item matches the current time.  IF so, 
                     // issue that command and remove it from queue.
-                    
+                    String nextEvent = eventQueue.peek();
+                    String eventTime = nextEvent.substring(0,8);
+                    System.out.println("Next event will be launched at: " + eventTime);
+                    if (eventTime.equals(currentClock))
+                    {
+                        System.out.println("LAUNCHING EVENT at " + nextEvent );
+                        eventQueue.remove();
+                    }
                     //theView.updateTime("" + formatInterval(simtime));
-                } catch (RemoteException ex)
-                {
-                    Logger.getLogger(ATMSDriverClient.class.getName()).log(Level.SEVERE, null, ex);
                 }
             }
@@ -133 +157 @@
     }
 
+    private void readBatchFile()
+    {
+        FileInputStream fis;
+        try {
+            fis = new FileInputStream("config/vds_data/atmsBatchEvents.txt");
+            Scanner scan = new Scanner(fis);
+            eventQueue = new LinkedList<String>();
+            while (scan.hasNext())
+            {
+                eventQueue.add(scan.nextLine());
+            }
+        } catch (FileNotFoundException ex) {
+            Logger.getLogger(ATMSDriverClient.class.getName()).log(Level.SEVERE, null, ex);
+        }
+    }
+    
     /**
      * Connect to the Coordinator's RMI object, and register this object for