isac-java/src/java/isac/bridge/BridgeMain.java
author Walther Neuper <wneuper@ist.tugraz.at>
Mon, 17 Dec 2018 13:02:16 +0100
changeset 5234 22aabc469ebb
parent 5233 f9e91d4ee161
child 5235 3ca9690d3e8b
permissions -rw-r--r--
tuned
     1 /**
     2  * Created on Aug 13, 2003
     3  *
     4  * @author Richard Gradischnegg RG
     5  */
     6 package isac.bridge;
     7 
     8 /**
     9  * BridgeMain: main class for bridge, does initialization and provides logging delegate and utility functionality.
    10  *
    11  * @author Richard Gradischnegg RG
    12  * @version 1.1
    13  */
    14 import isac.util.BridgeMainPaths;
    15 import isac.util.FixedPortRMISocketFactory;
    16 import info.hupel.isabelle.api.*;
    17 import info.hupel.isabelle.japi.*;
    18 import info.hupel.isabelle.setup.*;
    19 
    20 import java.awt.BorderLayout;
    21 import java.awt.Color;
    22 import java.awt.Font;
    23 import java.awt.event.WindowAdapter;
    24 import java.awt.event.WindowEvent;
    25 import java.awt.event.WindowListener;
    26 import java.io.BufferedReader;
    27 import java.io.IOException;
    28 import java.io.Serializable;
    29 import java.nio.file.Path;
    30 import java.nio.file.Paths;
    31 import java.rmi.RemoteException;
    32 import java.rmi.server.RMISocketFactory;
    33 import java.util.Arrays;
    34 
    35 import javax.swing.JFrame;
    36 import javax.swing.JPanel;
    37 import javax.swing.JScrollPane;
    38 import javax.swing.JTextArea;
    39 
    40 import org.apache.log4j.Logger;
    41 
    42 /**
    43  * Bridge main class: initializes connection to SML, starts auxillary threads, handles logging mechanism
    44  *
    45  * @author rgradisc
    46  */
    47 class BridgeMain implements Serializable {
    48 
    49     private static final long serialVersionUID = 507L;
    50     private static final Logger logger = Logger.getLogger(BridgeMain.class.getName());
    51     private JFrame log_frame_;
    52     private String path_;
    53     JPanel panel_;
    54     JTextArea text_area_;
    55     JScrollPane scroll_pane_;
    56     private Thread thread_sml_;
    57     private BridgeLogger bridge_logger_;
    58     private BufferedReader sml_reader_;
    59 
    60     public int ignore_output_ = 0;
    61     private boolean restoring_; // true = bridge is in restoring_ phase
    62     private JSystem connection_to_kernel_;
    63 
    64     /**
    65      * Constructor used to set up the bridge main program
    66      *
    67      * @param log_path_: path_ to initialization file
    68      */
    69     BridgeMain(String log_path, String isabelle_home) {
    70         // hack for suppressing warning messages
    71         // (no longer nescessary with j2sdk1.4.2)
    72         // System.setProperty("java.util.prefs.syncInterval", "20000000000");
    73 
    74         if (logger.isDebugEnabled()) {
    75             logger.debug("BridgeMain log_path =" + log_path);
    76         }
    77         Integer.valueOf(BridgeMainPaths.BRIDGE_MAIN_PORT);
    78 
    79         bridge_logger_ = new BridgeLogger(log_path);
    80         new ClientList();
    81         setUpBridgeLog();
    82         //*TTY*/startThreadsFirstTime();
    83 /* cp from last working version:
    84  *  https://hg.risc.uni-linz.ac.at/wneuper/isac/file/84f1ca6a6dd9/isac-java/src/java/isac/bridge/BridgeMain.java#l85
    85     85         log(1, "-->ISA: try connection with ISABELLE_HOME=\"" + isabelle_home + "\"...");
    86     86         Setup setup = new Setup(Paths.get(isabelle_home), JPlatform.guess(),
    87     87           new Version("2015"), Setup.defaultPackageName());
    88     88         Environment env = JSetup.makeEnvironment(setup); // without Duration
    89     89         Configuration config = Configuration.fromBuiltin("libisabelle_Isac");
    90     90         JSystem sys = JSystem.create(env, config);
    91     92         
    92     93         connection_to_kernel_ = sys;
    93     94         log(1, "<--ISA: connection established");
    94  */
    95 /* cp from downloaded libisabelle, current version:
    96 package info.hupel.isabelle.examples.java;
    97 
    98 import java.nio.file.Path;
    99 import java.nio.file.Paths;
   100 import java.util.Arrays;
   101 import info.hupel.isabelle.api.*;
   102 import info.hupel.isabelle.japi.*;
   103 import info.hupel.isabelle.setup.*;
   104 
   105 public class Hello_PIDE {
   106 
   107   public static void main(String args[]) {
   108     JResources res = JResources.dumpIsabelleResources();
   109     Configuration config = Configuration.simple("Protocol");
   110     Environment env = JSetup.makeEnvironment(JSetup.defaultSetup(new Version.Stable("2017")), res);
   111     JSystem sys = JSystem.create(env, config);
   112     String response = sys.invoke(Operations.HELLO, "world");
   113     System.out.println(response);
   114     sys.dispose();
   115   }
   116 }
   117  */
   118         /*PIDE*/log(1, "-->ISA: try connection with ISABELLE_HOME=\"" + isabelle_home + "\"...");
   119 
   120         JResources res = JResources.dumpIsabelleResources();
   121         Path path = java.nio.file.Paths.get
   122           ("/home/wneuper/.isabelle/isabisac/heaps/polyml-5.7.1_x86-linux/libisabelle_Isac");
   123         Configuration config = Configuration.simple("Protocol");
   124         Environment env = JSetup.makeEnvironment(JSetup.defaultSetup(new Version.Stable("2018")), res);
   125         JSystem sys = JSystem.create(env, config);
   126 
   127         /*PIDE*/connection_to_kernel_ = sys;
   128         /*PIDE*/log(1, "<--ISA: connection established");
   129 
   130     }
   131 
   132     protected JSystem getConnectionToKernel(){
   133       return connection_to_kernel_;
   134     }
   135     private void setUpBridgeLog() {
   136         if (BridgeMainPaths.SHOW_GUI_LOGGER) {
   137             log_frame_ = new JFrame("Java<->SML");
   138             log_frame_.setLocation(700, 250);
   139             panel_ = new JPanel();
   140             panel_.setSize(200, 300);
   141             panel_.setLayout(new BorderLayout());
   142             panel_.setBackground(Color.white);
   143 
   144             text_area_ = new JTextArea();
   145             text_area_.setFont(new Font("Monospaced", 0, 11));
   146             scroll_pane_ = new JScrollPane(text_area_,
   147                     JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
   148                     JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);
   149             panel_.add("Center", scroll_pane_);
   150             log_frame_.getContentPane().add(panel_);
   151 
   152             log_frame_.setTitle("BridgeLog Java <=> SML");
   153             WindowListener l = new WindowAdapter() {
   154                 public void windowClosing(WindowEvent e) {
   155                     System.exit(0);
   156                 }
   157             };
   158             log_frame_.addWindowListener(l);
   159             log_frame_.pack();
   160             log_frame_.setSize(300, 500);
   161             log_frame_.setVisible(true);
   162         }
   163     }
   164 
   165     // Here goes the future load balancing functionality
   166     // public void startNewKernel() {
   167     // implement load balancing
   168     // }
   169     protected void finalize() throws Throwable {
   170         super.finalize(); // gosling p.47
   171         // Objects created in run method are finalized when
   172         // program terminates and thread exits
   173         while (thread_sml_.isAlive()) {
   174             thread_sml_.interrupt();
   175             log(1, "waiting for SML thread to quit..");
   176         }
   177         bridge_logger_.log(1, "finished");
   178         bridge_logger_.close();
   179     }
   180 
   181     /**
   182      * Log a message with a specified severity level
   183      *
   184      * @param level severity level
   185      * @param msg the message to be logged
   186      */
   187     public void log(int level, String msg) {
   188         if (BridgeMainPaths.LOG_TO_FILE) {
   189             this.bridge_logger_.log(level, msg);
   190         }
   191         if (BridgeMainPaths.SHOW_GUI_LOGGER) {
   192             this.text_area_.append(msg + "\n");
   193         }
   194     }
   195 
   196     public BufferedReader getSmlReader() {
   197         //if (logger.isDebugEnabled())
   198         //    logger.debug("getSmlReader x");
   199         return sml_reader_;
   200     }
   201 
   202     public String getPath() {
   203         return path_;
   204     }
   205 
   206     public void setRMI(BridgeRMI bridgeRMI) {
   207         if (logger.isDebugEnabled()) {
   208             logger.debug("setRMI: bridge_rmi_=" + bridgeRMI);
   209         }
   210         bridgeRMI.setRmiID(1); // only one BridgeRMI used so far
   211     }
   212 
   213     boolean isRestoring() {
   214         return restoring_;
   215     }
   216 
   217     /**
   218      * @param args commandline arguments (exactly 4 expected: _iniPath _host _port _dtdPath)
   219      * @see BridgeMain()
   220      */
   221     public static void main(String[] args) {
   222 
   223         System.out.println("Starting Bridge...");
   224 
   225         String ini_load_result = BridgeMainPaths.loadFromFile(args[0]);
   226 
   227         if (ini_load_result != null) {
   228             ini_load_result += BridgeMainPaths.loadFromResource(args[0]);
   229         }
   230 
   231         if (ini_load_result != null) {
   232             System.err.println(ini_load_result);
   233             System.exit(1);
   234         }
   235 
   236         // initialize bridge main part
   237         BridgeMain bridge = new BridgeMain(BridgeMainPaths.LOG_PATH, BridgeMainPaths.ISABELLE_HOME);
   238         try {
   239             // Use ObjectManagerRMISocketFactory
   240             // 6666 = dummy
   241             RMISocketFactory.setSocketFactory(new FixedPortRMISocketFactory(BridgeMainPaths.BRIDGE_RMI_PORT));
   242 
   243             // setup rmi connection to to the clients
   244             BridgeRMI rmi = new BridgeRMI(bridge, BridgeMainPaths.HOST,
   245                     BridgeMainPaths.BRIDGE_MAIN_PORT, BridgeMainPaths.DTD_PATH);
   246 
   247 //			System.out.println( rmi );
   248 
   249             bridge.setRMI(rmi);
   250         } catch (RemoteException e) {
   251             System.out.println("Could not instantiate RMI: exiting");
   252             e.printStackTrace();
   253         } catch (IOException e) {
   254             System.out.println("Exception: " + e.getMessage());
   255             e.printStackTrace();
   256         }
   257     }
   258 }