import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates the host list.
 * 
 * @param hostsNumber the hosts number
 * 
 * @return the list< power host>
 */
public static List<PowerHost> createHostList(int hostsNumber) {
	List<PowerHost> hostList = new ArrayList<PowerHost>();
	for (int i = 0; i < hostsNumber; i++) {
		int hostType = i % Constants.HOST_TYPES;

		List<Pe> peList = new ArrayList<Pe>();
		for (int j = 0; j < Constants.HOST_PES[hostType]; j++) {
			peList.add(new Pe(j, new PeProvisionerSimple(Constants.HOST_MIPS[hostType])));
		}

		hostList.add(new PowerHostUtilizationHistory(
				i,
				new RamProvisionerSimple(Constants.HOST_RAM[hostType]),
				new BwProvisionerSimple(Constants.HOST_BW),
				Constants.HOST_STORAGE,
				peList,
				new VmSchedulerTimeSharedOverSubscription(peList),
				Constants.HOST_POWER[hostType]));
	}
	return hostList;
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * The main method.
 * 
 * @param args the arguments
 * @throws IOException Signals that an I/O exception has occurred.
 */
public static void main(String[] args) throws IOException {
	String experimentName = "planetlab_npa";
	String outputFolder = "output";
	String inputFolder = NonPowerAware.class.getClassLoader().getResource("workload/planetlab/20110303")
			.getPath();

	Log.setDisabled(!Constants.ENABLE_OUTPUT);
	Log.printLine("Starting " + experimentName);

	try {
		CloudSim.init(1, Calendar.getInstance(), false);

		DatacenterBroker broker = Helper.createBroker();
		int brokerId = broker.getId();

		List<Cloudlet> cloudletList = PlanetLabHelper.createCloudletListPlanetLab(brokerId, inputFolder);
		List<Vm> vmList = Helper.createVmList(brokerId, cloudletList.size());
		List<PowerHost> hostList = Helper.createHostList(PlanetLabConstants.NUMBER_OF_HOSTS);

		PowerDatacenterNonPowerAware datacenter = (PowerDatacenterNonPowerAware) Helper.createDatacenter(
				"Datacenter",
				PowerDatacenterNonPowerAware.class,
				hostList,
				new PowerVmAllocationPolicySimple(hostList));

		datacenter.setDisableMigrations(true);

		broker.submitVmList(vmList);
		broker.submitCloudletList(cloudletList);

		CloudSim.terminateSimulation(Constants.SIMULATION_LIMIT);
		double lastClock = CloudSim.startSimulation();

		List<Cloudlet> newList = broker.getCloudletReceivedList();
		Log.printLine("Received " + newList.size() + " cloudlets");

		CloudSim.stopSimulation();

		Helper.printResults(
				datacenter,
				vmList,
				lastClock,
				experimentName,
				Constants.OUTPUT_CSV,
				outputFolder);

	} catch (Exception e) {
		e.printStackTrace();
		Log.printLine("The simulation has been terminated due to an unexpected error");
		System.exit(0);
	}

	Log.printLine("Finished " + experimentName);
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates the host list.
 * 
 * @param hostsNumber the hosts number
 * 
 * @return the list< power host>
 */
public static List<PowerHost> createHostList(int hostsNumber) {
	List<PowerHost> hostList = new ArrayList<PowerHost>();
	for (int i = 0; i < hostsNumber; i++) {
		int hostType = i % Constants.HOST_TYPES;

		List<Pe> peList = new ArrayList<Pe>();
		//HOST_PES 每台物理机中的处理单元个数
		for (int j = 0; j < Constants.HOST_PES[hostType]; j++) {
			peList.add(new Pe(j, new PeProvisionerSimple(Constants.HOST_MIPS[hostType])));
		}

		hostList.add(new PowerHostUtilizationHistory(
				i,
				new RamProvisionerSimple(Constants.HOST_RAM[hostType]),
				new BwProvisionerSimple(Constants.HOST_BW),
				Constants.HOST_STORAGE,
				peList,
				new VmSchedulerTimeSharedOverSubscription(peList),
				// 设置能耗模型
				Constants.HOST_POWER[hostType]));
	}
	return hostList;
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
public PowerHost getHost(){
	return (PowerHost) getHostList().get(0);
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates the host list.
 * 
 * @param hostsNumber
 *            the hosts number
 */
public void createHostList(int hostsNumber) {
	for (int i = 1; i <= hostsNumber; i++) {
		hostList.add(new PowerHost(i, new RamProvisionerSimple(MyConstants.HOST_RAM), new BwProvisionerSimple(
				MyConstants.HOST_BW), MyConstants.HOST_STORAGE, peList, new VmSchedulerTimeSharedOverSubscription(
				peList), MyConstants.HOST_POWER_MODEL));
	}
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Checks if is host over utilized.
 * 
 * @param _host the _host
 * @return true, if is host over utilized
 */
@Override
protected boolean isHostOverUtilized(PowerHost host) {
	addHistoryEntry(host, getUtilizationThreshold());
	double totalRequestedMips = 0;
	for (Vm vm : host.getVmList()) {
		totalRequestedMips += vm.getCurrentRequestedTotalMips();
	}
	double utilization = totalRequestedMips / host.getTotalMips();
	return utilization > getUtilizationThreshold();
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
private static FogDevice createFogDevice(String nodeName, long mips,
		int ram, long upBw, long downBw, int level, double ratePerMips) {
	
	List<Pe> peList = new ArrayList<Pe>();

	// 3. Create PEs and add these into a list.
	peList.add(new Pe(0, new PeProvisionerOverbooking(mips))); // need to store Pe id and MIPS Rating

	int hostId = FogUtils.generateEntityId();
	long storage = 1000000; // host storage
	int bw = 10000;

	PowerHost host = new PowerHost(
			hostId,
			new RamProvisionerSimple(ram),
			new BwProvisionerOverbooking(bw),
			storage,
			peList,
			new StreamOperatorScheduler(peList),
			new PowerModelLinear(107.339, 83.4333)
		);

	List<Host> hostList = new ArrayList<Host>();
	hostList.add(host);

	String arch = "x86"; // system architecture
	String os = "Linux"; // operating system
	String vmm = "Xen";
	double time_zone = 10.0; // time zone this resource located
	double cost = 3.0; // the cost of using processing in this resource
	double costPerMem = 0.05; // the cost of using memory in this resource
	double costPerStorage = 0.001; // the cost of using storage in this
									// resource
	double costPerBw = 0.0; // the cost of using bw in this resource
	LinkedList<Storage> storageList = new LinkedList<Storage>(); // we are not adding SAN
												// devices by now

	FogDeviceCharacteristics characteristics = new FogDeviceCharacteristics(
			arch, os, vmm, host, time_zone, cost, costPerMem,
			costPerStorage, costPerBw);

	FogDevice fogdevice = null;
	try {
		fogdevice = new FogDevice(nodeName, characteristics, 
				new AppModuleAllocationPolicy(hostList), storageList, 10, upBw, downBw, 0, ratePerMips);
	} catch (Exception e) {
		e.printStackTrace();
	}
	
	fogdevice.setLevel(level);
	return fogdevice;
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
public static FogDevice createFogDevice(String name, int mips, double uplinkBandwidth, double downlinkBandwidth, double latency, double ratePerMips) {

		List<Pe> peList = new ArrayList<Pe>();
		peList.add(new Pe(0, new PeProvisionerOverbooking(mips))); // need to store Pe id and MIPS Rating

		int hostId = FogUtils.generateEntityId();
		int ram = 2048; // host memory (MB)
		long storage = 1000000; // host storage
		int bw = 10000;

		PowerHost host = new PowerHost(
				hostId,
				new RamProvisionerSimple(ram),
				new BwProvisionerOverbooking(bw),
				storage,
				peList,
				new StreamOperatorScheduler(peList),
				new PowerModelLinear(100, 40)
			);

		List<Host> hostList = new ArrayList<Host>();
		hostList.add(host);

		String arch = "x86"; // system architecture
		String os = "Linux"; // operating system
		String vmm = "Xen";
		double time_zone = 10.0; // time zone this resource located
		double cost = 3.0; // the cost of using processing in this resource
		double costPerMem = 0.05; // the cost of using memory in this resource
		double costPerStorage = 0.001; // the cost of using storage in this
										// resource
		double costPerBw = 0.0; // the cost of using bw in this resource
		LinkedList<Storage> storageList = new LinkedList<Storage>(); // we are not adding SAN
													// devices by now

		FogDeviceCharacteristics characteristics = new FogDeviceCharacteristics(
				arch, os, vmm, host, time_zone, cost, costPerMem,
				costPerStorage, costPerBw);

		FogDevice fogdevice = null;
		try {
			fogdevice = new FogDevice(name, characteristics, 
					new AppModuleAllocationPolicy(hostList), storageList, 10, uplinkBandwidth, downlinkBandwidth, latency, ratePerMips);
		} catch (Exception e) {
			e.printStackTrace();
		}

		return fogdevice;
	}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates a vanilla fog device
 * @param nodeName name of the device to be used in simulation
 * @param mips MIPS
 * @param ram RAM
 * @param upBw uplink bandwidth
 * @param downBw downlink bandwidth
 * @param level hierarchy level of the device
 * @param ratePerMips cost rate per MIPS used
 * @param busyPower
 * @param idlePower
 * @return
 */
private static FogDevice createFogDevice(String nodeName, long mips,
		int ram, long upBw, long downBw, int level, double ratePerMips, double busyPower, double idlePower) {
	
	List<Pe> peList = new ArrayList<Pe>();

	// 3. Create PEs and add these into a list.
	peList.add(new Pe(0, new PeProvisionerOverbooking(mips))); // need to store Pe id and MIPS Rating

	int hostId = FogUtils.generateEntityId();
	long storage = 1000000; // host storage
	int bw = 10000;

	PowerHost host = new PowerHost(
			hostId,
			new RamProvisionerSimple(ram),
			new BwProvisionerOverbooking(bw),
			storage,
			peList,
			new StreamOperatorScheduler(peList),
			new FogLinearPowerModel(busyPower, idlePower)
		);

	List<Host> hostList = new ArrayList<Host>();
	hostList.add(host);

	String arch = "x86"; // system architecture
	String os = "Linux"; // operating system
	String vmm = "Xen";
	double time_zone = 10.0; // time zone this resource located
	double cost = 3.0; // the cost of using processing in this resource
	double costPerMem = 0.05; // the cost of using memory in this resource
	double costPerStorage = 0.001; // the cost of using storage in this
									// resource
	double costPerBw = 0.0; // the cost of using bw in this resource
	LinkedList<Storage> storageList = new LinkedList<Storage>(); // we are not adding SAN
												// devices by now

	FogDeviceCharacteristics characteristics = new FogDeviceCharacteristics(
			arch, os, vmm, host, time_zone, cost, costPerMem,
			costPerStorage, costPerBw);

	FogDevice fogdevice = null;
	try {
		fogdevice = new FogDevice(nodeName, characteristics, 
				new AppModuleAllocationPolicy(hostList), storageList, 10, upBw, downBw, 0, ratePerMips);
	} catch (Exception e) {
		e.printStackTrace();
	}
	
	fogdevice.setLevel(level);
	return fogdevice;
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates a vanilla fog device
 * @param nodeName name of the device to be used in simulation
 * @param mips MIPS
 * @param ram RAM
 * @param upBw uplink bandwidth
 * @param downBw downlink bandwidth
 * @param level hierarchy level of the device
 * @param ratePerMips cost rate per MIPS used
 * @param busyPower
 * @param idlePower
 * @return
 */
private static FogDevice createFogDevice(String nodeName, long mips,
		int ram, long upBw, long downBw, int level, double ratePerMips, 
		double busyPower, double idlePower) {
	
	List<Pe> peList = new ArrayList<Pe>();

	// 3. Create PEs and add these into a list.
	peList.add(new Pe(0, new PeProvisionerOverbooking(mips))); // need to store Pe id and MIPS Rating

	int hostId = FogUtils.generateEntityId();
	long storage = 1000000; // host storage
	int bw = 10000;

	PowerHost host = new PowerHost(
			hostId,
			new RamProvisionerSimple(ram),
			new BwProvisionerOverbooking(bw),
			storage,
			peList,
			new StreamOperatorScheduler(peList),
			new FogLinearPowerModel(busyPower, idlePower)
		);

	List<Host> hostList = new ArrayList<Host>();
	hostList.add(host);

	String arch = "x86"; // system architecture
	String os = "Linux"; // operating system
	String vmm = "Xen";
	double time_zone = 10.0; // time zone this resource located
	double cost = 3.0; // the cost of using processing in this resource
	double costPerMem = 0.05; // the cost of using memory in this resource
	double costPerStorage = 0.001; // the cost of using storage in this resource
	double costPerBw = 0.0; // the cost of using bw in this resource
	LinkedList<Storage> storageList = new LinkedList<Storage>(); // we are not adding SAN devices by now

	FogDeviceCharacteristics characteristics = new FogDeviceCharacteristics(
			arch, os, vmm, host, time_zone, cost, costPerMem,
			costPerStorage, costPerBw);

	FogDevice fogdevice = null;
	try {
		fogdevice = new FogDevice(nodeName, characteristics, 
				new AppModuleAllocationPolicy(hostList), storageList, 10, upBw, downBw, 0, ratePerMips);
	} catch (Exception e) {
		e.printStackTrace();
	}
	
	fogdevice.setLevel(level);
	return fogdevice;
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates the datacenter.
 * 
 * @param name the name
 * @param datacenterClass the datacenter class
 * @param hostList the host list
 * @param vmAllocationPolicy the vm allocation policy
 * @param simulationLength
 * 
 * @return the power datacenter
 * 
 * @throws Exception the exception
 */
public static Datacenter createDatacenter(
		String name,
		Class<? extends Datacenter> datacenterClass,
		List<PowerHost> hostList,
		VmAllocationPolicy vmAllocationPolicy) throws Exception {
	String arch = "x86"; // system architecture
	String os = "Linux"; // operating system
	String vmm = "Xen";
	double time_zone = 10.0; // time zone this resource located
	double cost = 3.0; // the cost of using processing in this resource
	double costPerMem = 0.05; // the cost of using memory in this resource
	double costPerStorage = 0.001; // the cost of using storage in this resource
	double costPerBw = 0.0; // the cost of using bw in this resource

	DatacenterCharacteristics characteristics = new DatacenterCharacteristics(
			arch,
			os,
			vmm,
			hostList,
			time_zone,
			cost,
			costPerMem,
			costPerStorage,
			costPerBw);

	Datacenter datacenter = null;
	try {
		datacenter = datacenterClass.getConstructor(
				String.class,
				DatacenterCharacteristics.class,
				VmAllocationPolicy.class,
				List.class,
				Double.TYPE).newInstance(
				name,
				characteristics,
				vmAllocationPolicy,
				new LinkedList<Storage>(),
				Constants.SCHEDULING_INTERVAL);
	} catch (Exception e) {
		e.printStackTrace();
		System.exit(0);
	}

	return datacenter;
}
 

import org.cloudbus.cloudsim.power.PowerHost; //导入依赖的package包/类
/**
 * Creates main() to run this example.
 * 
 * @param args the args
 * @throws IOException
 */
public static void main(String[] args) throws IOException {
	String experimentName = "random_npa";
	String outputFolder = "output";

	Log.setDisabled(!Constants.ENABLE_OUTPUT);
	Log.printLine("Starting " + experimentName);

	try {
		CloudSim.init(1, Calendar.getInstance(), false);

		DatacenterBroker broker = Helper.createBroker();
		int brokerId = broker.getId();

		List<Cloudlet> cloudletList = RandomHelper.createCloudletList(
				brokerId,
				RandomConstants.NUMBER_OF_VMS);
		List<Vm> vmList = Helper.createVmList(brokerId, cloudletList.size());
		List<PowerHost> hostList = Helper.createHostList(RandomConstants.NUMBER_OF_HOSTS);

		PowerDatacenterNonPowerAware datacenter = (PowerDatacenterNonPowerAware) Helper.createDatacenter(
				"Datacenter",
				PowerDatacenterNonPowerAware.class,
				hostList,
				new PowerVmAllocationPolicySimple(hostList));

		datacenter.setDisableMigrations(true);

		broker.submitVmList(vmList);
		broker.submitCloudletList(cloudletList);

		CloudSim.terminateSimulation(Constants.SIMULATION_LIMIT);
		double lastClock = CloudSim.startSimulation();

		List<Cloudlet> newList = broker.getCloudletReceivedList();
		Log.printLine("Received " + newList.size() + " cloudlets");

		CloudSim.stopSimulation();

		Helper.printResults(
				datacenter,
				vmList,
				lastClock,
				experimentName,
				Constants.OUTPUT_CSV,
				outputFolder);

	} catch (Exception e) {
		e.printStackTrace();
		Log.printLine("The simulation has been terminated due to an unexpected error");
		System.exit(0);
	}

	Log.printLine("Finished " + experimentName);
}