Simulation.java

package EPON;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.util.concurrent.Semaphore;

public class Simulation {
    public static  int ONUNUMBER = 32;
    public static final int CYCLENUMBER = 10000;
    public static final int WAKEUPTHRESHOLD = -1;
    public static final int SLEEPTHRESHOLD = -1;
    
     
    public static final double RTT = 0;
    public static final double GUARDTIME = 1e-6;
    public static final double WAKEUPTIME = 20e-4;
    public static final double PACKETBIT = 64 * 8;
    public static final double RATE = 1e9;
    
    public static double OFFERLOAD;
    public static int totalpackets=0;
    public static double ARRIVALRATE;

    public static int[] report;

    public static double[] grant; //grant time
    public static int[] totalpacket; 

    public static Semaphore server_lock;
    public static Semaphore[] customer_lock = new Semaphore[ONUNUMBER];
    
    public static PrintWriter out;

    
    public static void main(String[] args) {
        
        try {
            out = new PrintWriter(new File("EPON_out.txt"));
        } catch (FileNotFoundException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        
        Thread[] ONUThread;
        Thread OLTThread;
    
        for (OFFERLOAD = 0.1; OFFERLOAD < 0.71; OFFERLOAD += 0.1){
            totalpackets=0;
            
            grant = new double[ONUNUMBER];
            report = new int[ONUNUMBER];
            totalpacket= new int[ONUNUMBER];
       

            ARRIVALRATE = OFFERLOAD * RATE / (PACKETBIT * ONUNUMBER);

            for(int i = 0; i < ONUNUMBER; i++){
                customer_lock[i] = new Semaphore(1);
                try {
                    customer_lock[i].acquire();
                }catch (InterruptedException e){}
            }
            server_lock = new Semaphore(1);

            ONUThread = new Thread[ONUNUMBER];
            OLTThread = new Thread(new Server(ONUNUMBER,CYCLENUMBER));
            OLTThread.start();

            for(int i = 0; i < ONUNUMBER; i++){
                ONUThread[i] = new Thread(new Customer(i));
                ONUThread[i].start();
            }

            try {
                OLTThread.join();
            }catch (InterruptedException e){}

            for(int i = 0; i < ONUNUMBER; i++){
                try {
                    ONUThread[i].join();
                }catch (InterruptedException e){}
            }
        
            //System.out.println(totalpacket[0]);
            for(int jin = 0; jin < ONUNUMBER; jin++){
                totalpackets+=totalpacket[jin];
            }
            //System.out.println(totalpacket[0]);
            //System.out.println(totalpackets);
            System.out.println((Server.systime-totalpackets*512/(1e9))*1e6/Server.systime);
            }
        
        //out.close();
    }

    public static void set_grant(int i,double t){grant[i] = t;}    
    public static void set_totalpacket(int i,int t){totalpacket[i] =  t;}   //Server
    public static double read_grant(int i){return grant[i];}                    //Customer
}