jgfmontecarlobench.java

MPI for java for Distributed Programming

/**************************************************************************
*                                                                         *
*             Java Grande Forum Benchmark Suite - MPJ Version 1.0         *
*                                                                         *
*                            produced by                                  *
*                                                                         *
*                  Java Grande Benchmarking Project                       *
*                                                                         *
*                                at                                       *
*                                                                         *
*                Edinburgh Parallel Computing Centre                      *
*                                                                         * 
*                email: [e-mail]                     *
*                                                                         *
*                                                                         *
*      This version copyright (c) The University of Edinburgh, 2001.      *
*                         All rights reserved.                            *
*                                                                         *
**************************************************************************/
package jgf_mpj_benchmarks.section3.montecarlo; 


//package montecarlo; 

import jgf_mpj_benchmarks.jgfutil.*;
import java.io.*;
//import jgfutil.*; 
import mpi.*;

public class JGFMonteCarloBench extends CallAppDemo implements JGFSection3 {

  public static int nprocess;
  public static int rank;

  public JGFMonteCarloBench(int nprocess, int rank) {
        this.nprocess=nprocess;
        this.rank=rank;
  }


  public void JGFsetsize(int size){
    this.size = size;
  }

  public void JGFinitialise(){

      initialise();

  }

  public void JGFapplication() throws MPIException{ 

    MPI.COMM_WORLD.Barrier();
    if(rank==0) {
      JGFInstrumentor.startTimer("Section3:MonteCarlo:Run");  
    }

    runiters();

    MPI.COMM_WORLD.Barrier();
    if(rank==0) {
      JGFInstrumentor.stopTimer("Section3:MonteCarlo:Run");  
    }

 
    if(rank==0) {
      presults();
    }

  } 


  public void JGFvalidate(){
   double refval[] = {-0.0333976656762814,-0.03215796752868655};
   double dev = Math.abs(AppDemo.JGFavgExpectedReturnRateMC - refval[size]);
   if (dev > 1.0e-12 ){
     System.out.println("Validation failed");
     System.out.println(" expectedReturnRate= " + AppDemo.JGFavgExpectedReturnRateMC + "  " + dev + "  " + size);
    }
  }

  public void JGFtidyup(){    

    System.gc();
  }


  public void JGFrun(int size) throws MPIException{

    if(rank==0) {
      JGFInstrumentor.addTimer("Section3:MonteCarlo:Total", "Solutions",size);
      JGFInstrumentor.addTimer("Section3:MonteCarlo:Run", "Samples",size);
    }

    JGFsetsize(size); 

    MPI.COMM_WORLD.Barrier();
    if(rank==0) {
      JGFInstrumentor.startTimer("Section3:MonteCarlo:Total");
    }

    JGFinitialise(); 
    JGFapplication(); 

    if(rank==0) {
      JGFvalidate();
    } 
    JGFtidyup(); 

    MPI.COMM_WORLD.Barrier();
    if(rank==0) {
      JGFInstrumentor.stopTimer("Section3:MonteCarlo:Total");

      JGFInstrumentor.addOpsToTimer("Section3:MonteCarlo:Run", (double) input[1] );
      JGFInstrumentor.addOpsToTimer("Section3:MonteCarlo:Total", 1);

      JGFInstrumentor.printTimer("Section3:MonteCarlo:Run"); 
      JGFInstrumentor.printTimer("Section3:MonteCarlo:Total"); 
    }
  }


}