/******************************************************* Mosel Example Problems ====================== file mandelbrot.java ```````````````````` Mandelbrot function: f(z) = z^2 + c with z,c complex numbers. Main program producing Java GUI and coordinating all submodels. On each node in the list NODESLIST we start K model instances. Each submodel instance is sent a rectangular area for which to calculate the pixel color values. The results are passed back via a file (located at the same place as this program, no write access to remote instances is required). Once the result has been displayed by Java, the submodel is restarted for a new data set. This Java program can be run on any platform (no Xpress installation required!), the Mosel (sub)models require Xpress. - Testing Java GUI with distributed computing - (c) 2011 Fair Isaac Corporation author: S. Heipcke, Feb. 2011 *******************************************************/ import java.awt.*; import java.awt.image.*; import java.awt.event.*; import javax.swing.*; import java.io.*; import com.dashoptimization.*; public class mandelbrot extends JFrame { static final int K = 2; // Number of submodels per Mosel instance static final int NUMPX = 1000; // Graphic size in pixels static final int CWIDTH = 1100; // Window height (>=NUMPX) static final int CHEIGHT = 1000; // Window width (>=NUMPX) static final int SW = 100; // Size of subproblems in pixels static final int XOFF = 100; // Offset to left canvas border /**** ! Adapt this list to your local network: ! Use "localhost" for the current node, (under Unix also possible: "") ! Use machine names or IP addresses for remote machines ****/ static final String NODELIST[] = {"localhost",""}; static final int M = NODELIST.length; // Number of remote instances static final int A = M*K; // Total number of models static int minX,minY,ct,num,sqct,numsq; static double XMin,XMax,YMin,YMax,HX,HY,x,y; static int OffsetX,OffsetY; static int[][] SQUARE; static int[][] sol; static Integer[] confval; static boolean stoppressed; static XPRD xprd; static XPRDModel[] modPar; static XPRDMosel[] moselInst; static DrawingRegion canv; static JButton startButton,stopButton; static JComboBox choice; static JCheckBox[] check; static BufferedImage image; static mandelbrot app; /***************** Configuration ******************/ static void setMandelbrotConfig(int config) { if (config == 0) { XMin = -1,5; XMax = 0,5; YMin = -1; YMax = 1; } else if (config == 1) { XMin = -0,9; XMax = -0,915; YMin = -0,245; YMax = -0,23; } else if (config == 2) { XMin = -0,9; XMax = -0,98; YMin = -0,3; YMax = -0,22; } else if (config == 3) { XMin = -0,91; XMax = -0,94; YMin = -0,3; YMax = -0,27; } else if (config == 4) { XMin = -0,926; XMax = -0,934; YMin = -0,264; YMax = -0,256; } HX = (XMax-XMin)/NUMPX; HY = (YMax-YMin)/NUMPX; OffsetX = -(int)Math.round(XMin/HX); OffsetY = -(int)Math.round(YMin/HY); sqct=0; for(int s=1;s<=Math.ceil(NUMPX/SW);s++) for(int t=1;t<=Math.ceil(NUMPX/SW);t++) { SQUARE[sqct][0] = Math.round((float)(XMin/HX))+(s-1)*SW; SQUARE[sqct][1] = (Math.round((float)(XMin/HX))+s*SW-1<Math.round((float)(XMax/HX)))? SQUARE[sqct][2]=Math.round((float)(YMin/HY))+(t-1)*SW; SQUARE[sqct][3]=(Math.round((float)(YMin/HY))+t*SW-1<Math.round((float)(YMax/HY)))? sqct+=1; XAD and Java use the opposite encoding of RGB values static int r=col.getRed(); g=col.getGreen(); b=col.getBlue(); v=256*256; return Reading result data void throws IOException boolean ndxOK=false; BinDrvReader FileInputStream f=new bdrv=new Use Mosel bin reader if((bdrv.getControl()==BinDrvReader.CTRL_LABEL)&& (bdrv.getControl()==BinDrvReader.CTRL_OPENLST))>=0) {
     ctrl=bdrv.getControl();
     if(ctrl==BinDrvReader.CTRL_CLOSELST) break;
     else
       if(ctrl==BinDrvReader.CTRL_OPENNDX)
       {
         if(ndxOK) {
           i=bdrv.getInt()-minX;
           j=bdrv.getInt()-minY;
         }
         else {
           minX=bdrv.getInt();
           minY=bdrv.getInt();
           i=j=0;
           ndxOK=true;
         }
         if(bdrv.getControl()==BinDrvReader.CTRL_CLOSENDX)
         {
           sol[i][j]=bdrv.getInt();
         }
         else
           throw new IOException("Wrong file format. ')' expected.");
       }
       else
         throw new IOException("Wrong file format. '(' expected.");
     }
   }
   else
     throw new IOException("Wrong file format");
   f.close();
 }
  
/***************** Application setup ******************/
  
  public mandelbrot() {
    super("Mandelbrot");
    setLocation(50,25);
    
  // Initialize data structures  
    numsq=(int)Math.round(Math.ceil((float)(NUMPX/SW))*
                                     Math.ceil((float)(NUMPX/SW)));
    SQUARE = new int[numsq][4];
    sol=new int[SW][SW];
    setMandelbrotConfig(0);                 // Default config values

  // Create graphic objects
    startButton = new JButton("Start");
    startButton.setAlignmentX(Component.CENTER_ALIGNMENT);
    startButton.setMaximumSize(new Dimension(100,30));
    startButton.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent ae) { 
        int c = (Integer)(choice.getSelectedItem());
        startButton.setEnabled(false);
        setMandelbrotConfig(c);
        new RenderingThread(c).start();     
      } 
    });
 
    confval = new Integer[5];
    for(int i=0;i<=4;i++) confval[i]=i;    
    choice = new JComboBox<Integer>(confval);
    choice.setMaximumSize(new Dimension(40,30));
    JLabel label = new JLabel("Config:");

    JPanel buttonsPanel = new JPanel();
    buttonsPanel.setLayout(new BoxLayout(buttonsPanel,BoxLayout.Y_AXIS));
    buttonsPanel.add(startButton);
    Box confBox = new Box(BoxLayout.X_AXIS);
    confBox.setMaximumSize(new Dimension(100,60));
    confBox.add(label);
    confBox.add(confBox.createHorizontalStrut(10));
    confBox.add(choice);
    confBox.add(confBox.createHorizontalStrut(10));
    buttonsPanel.add(confBox);

    stopButton = new JButton("Stop");
    stopButton.setAlignmentX(Component.CENTER_ALIGNMENT);
    stopButton.setMaximumSize(new Dimension(100,30));
    stopButton.setEnabled(false);
    stoppressed=false;
    stopButton.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent ae) { 
        stoppressed=true; 
      } 
    });
    buttonsPanel.add(stopButton);
    
    Box checkBox = new Box(BoxLayout.Y_AXIS);
    checkBox.setMaximumSize(new Dimension(100,A*30));
    checkBox.setAlignmentX(Component.CENTER_ALIGNMENT);
    checkBox.add(checkBox.createHorizontalStrut(10));
    check = new JCheckBox[A];
    for(int i=0;i<A;i++) check[i]=new JCheckBox((i+1)+=":" (NODELIST[i%M]==""?"(local)":NODELIST[i%M]), canv=new JScrollPane canvasScroller=new true image=(BufferedImage)(canv.createImage(NUMPX, Window closing event: stop application public void Disconnect remote connections i=0;i<M;i++) Main static xprd=new modPar=new moselInst=new try Establish moselInst[i]=xprd.connect(NODELIST[i]); failed:=" + e);
      System.exit(1);
    }

    try {                               // Compile the model
      moselInst[0].compile(" ,="rmt:mandelbrotsub.mos" Cleaning up Define and start GUI app=new Canvas class DrawingRegion extends JComponent protected Drawing RenderingThread Thread int this.c=c;} Graphics buffer=image.getGraphics(); Color.white NUMPX Start first lot of model executions modstartct=0; nbrunning=0; n=0;n<((M*K<sqct)?M*K:sqct);n++) modPar[n].setExecParam("IODRV",="bin:" run>0)) {
        xprd.waitForEvent();
        ev=xprd.getNextEvent();
        if (ev.eventClass==ev.EVENT_END) {
          modendct++; 
          evmod=ev.sender;
	  num = evmod.getResult();
	  check[evmod.getNumber()-1].setSelected(false);

     // Read result data
        try {
          readSol("solmod"+num+".txt"); 
        } catch(IOException e) {
          System.out.println("Could not read file "+num);
          System.exit(1);
        }
        new File("solmod"+num+".txt").delete();

     // Draw result square on buffer
        for(int s=0;s<SW;s++)
	  for(int t=0;t<SW;t++) {
            image.setRGB(SQUARE[num][0]+s+OffsetX,SQUARE[num][2]+t+OffsetY,
                    invertColorValue(new Color(sol[s][t])));
          }	  
        canv.repaint();

     // Start new instance
        if ((modstartct< sqct) && (!stoppressed)) {
          evmod.execParams="MINX="+SQUARE[modstartct][0] + ",MAXX="+
                    SQUARE[modstartct][1] + ",MINY="+ SQUARE[modstartct][2] +
                    ",MAXY="+SQUARE[modstartct][3] + ",NUM="+modstartct +
                    ",HX="+HX + ",HY="+HY + ",NUMPX="+NUMPX + 
                    ",CONFIG="+c+",IODRV='bin:'";
	  check[evmod.getNumber()-1].setSelected(true);
          try {
	    evmod.run();
          }
          catch(IOException e) {
            System.out.println("Model run failed: " + e);
            System.exit(1);
          }
          modstartct++;
        }
	else
	  nbrunning--;
        }  
      }  // while

      stopButton.setEnabled(false);
      startButton.setEnabled(true);
      stoppressed=false;
    }
  }   
 
}