Monitoring code used for 2021 Run

analysis/.gitignore

@@ -0,0 +1 @@
+/bin/

online-monitoring/src/main/java/org/hps/monitoring/application/Commands.java

@@ -1,7 +1,8 @@
 package org.hps.monitoring.application;
 
 /**
- * These strings are used to identify <code>ActionEvent</code> commands in the MonitoringApplication.
+ * These strings are used to identify <code>ActionEvent</code> commands in the
+ * MonitoringApplication.
  */
 final class Commands {
 
@@ -51,7 +52,8 @@ final class Commands {
     static final String DATA_SOURCE_CHANGED = "dataSourceChanged";
 
     /**
-     * Reset the application window to its default settings including scroll pane positions.
+     * Reset the application window to its default settings including scroll
+     * pane positions.
      */
     static final String DEFAULT_WINDOW = "defaultWindow";
 
@@ -154,7 +156,7 @@ final class Commands {
      * Action when plot is selected from a tab.
      */
     static final String PLOT_SELECTED = "PlotSelected";
-    
+
     /**
      * Enable plot pop-up window.
      */
@@ -166,7 +168,8 @@ final class Commands {
     static final String PROCESSING_STAGE_CHANGED = "processingStageChanged";
 
     /**
-     * Select one of the items from the recent files list to be the current data source.
+     * Select one of the items from the recent files list to be the current data
+     * source.
      */
     static final String RECENT_FILE_SELECTED = "recentFileSelected";
 
@@ -185,6 +188,11 @@ final class Commands {
      */
     static final String SAVE_PLOTS = "savePlots";
 
+    /**
+     * Save the plots to a ROOT, AIDA or PDF file.
+     */
+    static final String SAVE_ROOT_AND_PDF = "savePlotsRootPdf";
+
     /**
      * Save a screenshot from the window graphics.
      */

online-monitoring/src/main/java/org/hps/monitoring/application/EventButtonsPanel.java

@@ -16,7 +16,8 @@
 import org.hps.monitoring.application.model.ConnectionStatusModel;
 
 /**
- * This is the panel with buttons for connecting or disconnecting from the session and controlling the application when
+ * This is the panel with buttons for connecting or disconnecting from the
+ * session and controlling the application when
  * event processing is paused.
  */
 @SuppressWarnings("serial")
@@ -53,6 +54,11 @@ static ImageIcon getImageIcon(final String resource) {
         return new ImageIcon(image);
     }
 
+    /**
+     * Button for saving PDF & root files
+     */
+    private final JButton saveButton;
+
     /**
      * Button for connect and disconnect which is toggled depending on state.
      */
@@ -84,6 +90,7 @@ static ImageIcon getImageIcon(final String resource) {
         connectionModel.addPropertyChangeListener(this);
 
         setLayout(new FlowLayout());
+        this.saveButton = addButton("/monitoringButtonGraphics/icons8-multicast-64.png", Commands.SAVE_ROOT_AND_PDF, listener, true);
         this.connectButton = addButton(DISCONNECTED_ICON, Commands.CONNECT, listener, true);
         this.resumeButton = addButton("/toolbarButtonGraphics/media/Play24.gif", Commands.RESUME, listener, false);
         this.pauseButton = addButton("/toolbarButtonGraphics/media/Pause24.gif", Commands.PAUSE, listener, false);
@@ -125,7 +132,8 @@ private JButton addButton(final String resource, final String actionCommand, fin
     }
 
     /**
-     * Handle property change events to set status from changes to the connection status model.
+     * Handle property change events to set status from changes to the
+     * connection status model.
      *
      * @param evt the <code>PropertyChangeEvent</code> to handle
      */

online-monitoring/src/main/java/org/hps/monitoring/application/MonitoringApplication.java

@@ -18,6 +18,8 @@
 import java.io.IOException;
 import java.io.OutputStream;
 import java.io.PrintStream;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -60,9 +62,11 @@
 import org.lcsim.util.log.DefaultLogFormatter;
 
 /**
- * This is the primary class that implements the data monitoring GUI application.
+ * This is the primary class that implements the data monitoring GUI
+ * application.
  * <p>
- * It should not be used directly. Instead the {@link Main} class should be used from the command line.
+ * It should not be used directly. Instead the {@link Main} class should be used
+ * from the command line.
  *
  */
 final class MonitoringApplication implements ActionListener, PropertyChangeListener {
@@ -99,7 +103,8 @@ public void publish(final LogRecord record) {
     }
 
     /**
-     * Log handler which publishes messages to a stream (console or file in this case).
+     * Log handler which publishes messages to a stream (console or file in this
+     * case).
      */
     class MonitoringApplicationStreamHandler extends StreamHandler {
 
@@ -217,27 +222,30 @@ static MonitoringApplication create(final Configuration configuration) {
     private EventProcessing processing;
 
     /**
-     * The model which has information about the current run and events being processed.
+     * The model which has information about the current run and events being
+     * processed.
      */
     private final RunModel runModel = new RunModel();
 
     /**
      * The handler for putting messages into the log table.
      */
     private MonitoringApplicationStreamHandler streamHandler;
-    
+
     /**
      * Class for displayed a pop-up of selected region.
      * Initialization is delayed until after AIDA is properly configured.
      */
     private ChartPopup popup = null;
-    
+
     private boolean plotPopupEnabled = true;
-    
+
     /**
-     * Instantiate and show the monitoring application with the given configuration.
+     * Instantiate and show the monitoring application with the given
+     * configuration.
      *
-     * @param userConfiguration the Configuration object containing application settings
+     * @param userConfiguration the Configuration object containing application
+     * settings
      */
     MonitoringApplication(final Configuration userConfiguration) {
 
@@ -309,6 +317,8 @@ public void actionPerformed(final ActionEvent e) {
             runDisconnectThread();
         } else if (Commands.SAVE_PLOTS.equals(command)) {
             savePlots();
+        } else if (Commands.SAVE_ROOT_AND_PDF.equals(command)) {
+            savePlotsRootPdf();
         } else if (Commands.EXIT.equals(command)) {
             // This will trigger the window closing action that cleans everything up.
             this.frame.dispose();
@@ -351,10 +361,11 @@ public void actionPerformed(final ActionEvent e) {
         } else if (Commands.PLOT_POPUP.equals(command)) {
             this.plotPopupEnabled = ((JCheckBox) e.getSource()).isSelected();
         }
-    }      
-    
+    }
+
     /**
-     * Redirect <code>System.out</code> and <code>System.err</code> to a chosen file.
+     * Redirect <code>System.out</code> and <code>System.err</code> to a chosen
+     * file.
      */
     private void chooseLogFile() {
         final JFileChooser fc = new JFileChooser();
@@ -485,7 +496,8 @@ private List<String> getRunData() {
     }
 
     /**
-     * Get the run model with information about the run and event(s) currently being processed.
+     * Get the run model with information about the run and event(s) currently
+     * being processed.
      *
      * @return the run model
      */
@@ -494,10 +506,12 @@ RunModel getRunModel() {
     }
 
     /**
-     * This method sets the configuration on the model, which fires a change for every property.
+     * This method sets the configuration on the model, which fires a change for
+     * every property.
      *
      * @param configuration the new configuration
-     * @param merge <code>true</code> to merge the configuration into the current one rather than replace it
+     * @param merge <code>true</code> to merge the configuration into the
+     * current one rather than replace it
      */
     private void loadConfiguration(final Configuration configuration, final boolean merge) {
 
@@ -581,7 +595,8 @@ private void logToFile(final File file) {
     }
 
     /**
-     * Send <code>System.out</code> and <code>System.err</code> back to the terminal, e.g. if they were previously sent
+     * Send <code>System.out</code> and <code>System.err</code> back to the
+     * terminal, e.g. if they were previously sent
      * to a file.
      */
     private void logToTerminal() {
@@ -761,6 +776,53 @@ private void savePlots() {
         }
     }
 
+    /**
+     * Save plots to an AIDA, ROOT or PDF file using a file chooser.
+     */
+    private void savePlotsRootPdf() {
+        int runNum = this.runModel.getRunNumber();
+        String stationName = this.configurationModel.getStationName();
+        String timestamp = DateTimeFormatter.ofPattern("yyyy-MM-dd:HH:mm:ss").format(LocalDateTime.now());
+        String plotsDir=this.configurationModel.getPlotsDir();
+        String pdfOut = plotsDir+"/"+stationName + "-run" + runNum + "-" + timestamp + ".pdf";
+        String rootOut = plotsDir+"/"+stationName + "-run" + runNum + "-" + timestamp + ".root";
+
+        final File pdfFile = new File(pdfOut);
+        final File rootFile = new File(rootOut);
+        if (!pdfFile.exists()) {
+            String fileName = pdfFile.getAbsolutePath();
+            try {
+                // Write out all plot graphics from the tabs to a single PDF file.
+                ExportPdf.write(MonitoringPlotFactory.getPlotterRegistry().getPlotters(), fileName,
+                        getRunData());
+                LOGGER.info("saved plots to " + fileName);
+                DialogUtil.showInfoDialog(this.frame, "Plots Saved", "Plots were successfully saved to " + '\n'
+                        + fileName);
+            } catch (final IOException e) {
+                this.errorHandler.setError(e).setMessage("Error Saving Plots").printStackTrace().log()
+                        .showErrorDialog();
+            }
+        } else {
+            DialogUtil.showErrorDialog(this.frame, "File Exists", "Selected file already exists.");
+        }
+
+        if (!rootFile.exists()) {
+            String fileName = rootFile.getAbsolutePath();
+            try {
+                AIDA.defaultInstance().saveAs(fileName);
+                LOGGER.info("saved plots to " + fileName);
+                DialogUtil.showInfoDialog(this.frame, "Plots Saved", "Plots were successfully saved to " + '\n'
+                        + fileName);
+            } catch (final IOException e) {
+                this.errorHandler.setError(e).setMessage("Error Saving Plots").printStackTrace().log()
+                        .showErrorDialog();
+            }
+        } else {
+            DialogUtil.showErrorDialog(this.frame, "File Exists", "Selected already exists.");
+        }
+
+    }
+
     /**
      * Save a screenshot to a file using a file chooser.
      */
@@ -805,7 +867,8 @@ private void saveSettings() {
     }
 
     /**
-     * Export a JTable's data to a comma-delimited text file using a file chooser.
+     * Export a JTable's data to a comma-delimited text file using a file
+     * chooser.
      *
      * @param table the table to export
      */
@@ -857,7 +920,7 @@ public void regionSelected(final PlotterRegion region) {
                 if (region != null) {
                     MonitoringApplication.this.frame.getPlotInfoPanel().setCurrentRegion(region);
                 }
-                
+
                 if (plotPopupEnabled) {
                     popup.update(region);
                 }
@@ -866,7 +929,7 @@ public void regionSelected(final PlotterRegion region) {
 
         // Perform global configuration of the JFreeChart back end.
         AnalysisFactory.configure();
-        
+
         this.popup = new ChartPopup();
     }
 
@@ -981,7 +1044,8 @@ private synchronized void startSession() {
      * Save a screenshot to an output file.
      *
      * @param fileName the name of the output file
-     * @param format the output file format (must be accepted by <code>ImageIO</code>)
+     * @param format the output file format (must be accepted by
+     * <code>ImageIO</code>)
      */
     private void writeScreenshot(final String fileName, final String format) {
         this.frame.repaint();

online-monitoring/src/main/java/org/hps/monitoring/application/model/ConfigurationModel.java

@@ -117,6 +117,11 @@ public final class ConfigurationModel extends AbstractModel {
      */
     private static final int MAX_RECENT_FILES = 10;
 
+    /**
+     * The directory to store plots (pdf and root) files in
+     */
+    private static final String PLOTS_DIR_PROPERTY="PlotsDir";
+
     /**
      * The ET TCP/IP port.
      */
@@ -431,7 +436,14 @@ public Boolean getLogToFile() {
     public Long getMaxEvents() {
         return this.configuration.getLong(MAX_EVENTS_PROPERTY);
     }
-
+    /**
+     * Get the directory to but root and pdf files
+     * @return directory name
+     */
+    public String getPlotsDir(){
+        return this.configuration.get(PLOTS_DIR_PROPERTY);
+    }
+
     /**
      * Get the ET TCP/IP port value.
      *