resscheduler.java

本人历尽千辛万苦找的clustream中的jar包

package org.osu.ogsa.stream.info;
import java.util.Random;
import java.lang.Math;
import java.lang.System;
import org.apache.log4j.*;

public class ResScheduler 
{
	//public static double DECAY_PRO = 0.8;
	
/*	private static Category log = Category.getInstance(ResScheduler.class.getName());
	public int [][] getPaths()
	{
		//We can use different algorithm to get the path
		//the paths returned to the caller are in the matrix

	}

	static {
		//Create the network roadmap according to bandwidth matrix

                try{
        	        ConfigFileReader c = new ConfigFileReader();
               		c.init("stream.cnf");
			DEFAULT_BUFFER_SIZE = c.getInt("DEFAULT_BUFFER_SIZE");
			NET_BANDWIDTH = c.getDouble("NET_BANDWIDTH");
			WINDOW_SIZE = c.getInt("WINDOW_SIZE");
			IDLE_TIME = c.getInt("IDLE_TIME"); //microsecond
			DELAY_THRESHOLD = c.getInt("DELAY_THRESHOLD"); //microsecond
			IFSPECIFYPARA = c.getBoolean("IFSPECIFYPARA");
			FULLY_LOADED = c.getDouble("FULLY_LOADED");
			MAJORITY_BUF_THRESHOLD = c.getDouble("MAJORITY_BUF_THRESHOLD");
			OVER_LOADED_THRESHOLD = c.getDouble("OVER_LOADED_THRESHOLD");
			LIGHT_LOADED_THRESHOLD = c.getDouble("LIGHT_LOADED_THRESHOLD");
			LONGTERM_OVER_LOADED_THRESHOLD = c.getDouble("LONGTERM_OVER_LOADED_THRESHOLD");
			LONGTERM_LIGHT_LOADED_THRESHOLD = c.getDouble("LONGTERM_LIGHT_LOADED_THRESHOLD");
			LONGTERM_EXTREMELY_OVER_LOADED_THRESHOLD = c.getDouble("LONGTERM_EXTREMELY_OVER_LOADED_THRESHOLD");
			LONGTERM_EXTREMELY_LIGHT_LOADED_THRESHOLD = c.getDouble("LONGTERM_EXTREMELY_LIGHT_LOADED_THRESHOLD");
			P1 = c.getDouble("P1");
			P2 = c.getDouble("P2");
			P3 = c.getDouble("P3");
			OUTPUTBUFFER_FACTOR = c.getDouble("OUTPUTBUFFER_FACTOR");
			INPUTBUFFER_FACTOR = c.getDouble("INPUTBUFFER_FACTOR");
			LEARNING_RATE = c.getDouble("LEARNING_RATE");
			System.out.println("DEFAULT_BUFFER_SIZE="+DEFAULT_BUFFER_SIZE);
			System.out.println("NET_BANDWIDTH="+NET_BANDWIDTH);
			System.out.println("IDLE_TIME="+IDLE_TIME);
			System.out.println("DELAY_THRESHOLD="+DELAY_THRESHOLD);
			System.out.println("IFSPECIFYPARA="+IFSPECIFYPARA);
			System.out.println("FULLY_LOADED="+FULLY_LOADED);
			System.out.println("MAJORITY_BUF_THRESHOLD="+MAJORITY_BUF_THRESHOLD);
			System.out.println("OVER_LOADED_THRESHOLD="+OVER_LOADED_THRESHOLD);
			System.out.println("LIGHT_LOADED_THRESHOLD="+LIGHT_LOADED_THRESHOLD);
			System.out.println("LONGTERM_OVER_LOADED_THRESHOLD="+LONGTERM_OVER_LOADED_THRESHOLD);
			System.out.println("LONGTERM_LIGHT_LOADED_THRESHOLD="+LONGTERM_LIGHT_LOADED_THRESHOLD);
			System.out.println("LONGTERM_EXTREMELY_OVER_LOADED_THRESHOLD="+LONGTERM_EXTREMELY_OVER_LOADED_THRESHOLD);
			System.out.println("LONGTERM_EXTREMELY_LIGHT_LOADED_THRESHOLD="+LONGTERM_EXTREMELY_LIGHT_LOADED_THRESHOLD);
			System.out.println("P1="+P1);
			System.out.println("P2="+P2);
			System.out.println("P3="+P3);
			System.out.println("OUTPUTBUFFER_FACTOR="+OUTPUTBUFFER_FACTOR);
			System.out.println("INPUTBUFFER_FACTOR="+INPUTBUFFER_FACTOR);
			System.out.println("LEARNING_RATE="+LEARNING_RATE);
                }
                catch(Exception e)
                {
                        log.error(e.toString());
                }
        }

	public static int Biased_Coin(Random rand, double probability)
	{
		return Biased_Coin(rand, probability, 100);
	}

	public static int Biased_Coin(Random rand, double probability, int factor)
	{
        	int rand_int = 1 + (Math.abs(rand.nextInt()) % factor );
		log.debug("rand_int :"+ rand_int);
	        if(rand_int <= (int)(probability* (double)factor))
			return HEAD;
		else
			return TAIL;
	} */
}