Heyloo friends,
I tried priority scheduling in cloudsim using AHP(Analytical hierarchical Process).AHP is just a theoretical method of finding out the priorities using some mathematical calculations.The output of AHP is just priorities and it is most efficient method of finding priorities.
so,below i gave the code by which i got the folloeing output.I dint make any changes in DatacenterBroker.java file i just created a new class file and wrote the following code.But the problem is everything is working right but if you observe in the output all the burst times are same..It shouldnt be like that i tried alot but failed..I would be grateful if anyone could find the error or add any kind of code so that their burst times are correct.
Step 1:
Code which i saved as PJSC.java.
package org.cloudbus.cloudsim.examples;
/*
* Title: CloudSim Toolkit
* Description: CloudSim (Cloud Simulation) Toolkit for Modeling and Simulation
* of Clouds
* Licence: GPL - http://www.gnu.org/copyleft/gpl.html
*
* Copyright (c) 2009, The University of Melbourne, Australia
*/
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.LinkedList;
import java.util.List;
import java.util.Scanner;
import org.cloudbus.cloudsim.Cloudlet;
import org.cloudbus.cloudsim.CloudletSchedulerTimeShared;
import org.cloudbus.cloudsim.Datacenter;
import org.cloudbus.cloudsim.DatacenterBroker;
import org.cloudbus.cloudsim.DatacenterCharacteristics;
import org.cloudbus.cloudsim.Host;
import org.cloudbus.cloudsim.Log;
import org.cloudbus.cloudsim.Pe;
import org.cloudbus.cloudsim.Storage;
import org.cloudbus.cloudsim.UtilizationModel;
import org.cloudbus.cloudsim.UtilizationModelFull;
import org.cloudbus.cloudsim.Vm;
import org.cloudbus.cloudsim.VmAllocationPolicySimple;
import org.cloudbus.cloudsim.VmSchedulerTimeShared;
import org.cloudbus.cloudsim.core.CloudSim;
import org.cloudbus.cloudsim.provisioners.BwProvisionerSimple;
import org.cloudbus.cloudsim.provisioners.PeProvisionerSimple;
import org.cloudbus.cloudsim.provisioners.RamProvisionerSimple;
/**
* A simple example showing how to create a datacenter with one host and run one
* cloudlet on it.
*/
public class PJSC {
/** The cloudlet list. */
private static List<Cloudlet> cloudletList;
/** The vmlist. */
private static List<Vm> vmlist;
/**
* Creates main() to run this example.
*
* @param args the args
*/
static int[] ids;
@SuppressWarnings("unused")
public static void main(String[] args) {
Log.printLine("Starting CloudSimExample1...");
try {
// First step: Initialize the CloudSim package. It should be called
// before creating any entities.
int num_user = 1; // number of cloud users
Calendar calendar = Calendar.getInstance();
boolean trace_flag = false; // mean trace events
// Initialize the CloudSim library
CloudSim.init(num_user, calendar, trace_flag);
// Second step: Create Datacenters
// Datacenters are the resource providers in CloudSim. We need at
// list one of them to run a CloudSim simulation
Datacenter datacenter0 = createDatacenter("Datacenter_0");
// Third step: Create Broker
DatacenterBroker broker = createBroker();
int brokerId = broker.getId();
// Fourth step: Create one virtual machine
vmlist = new ArrayList<Vm>();
// VM description
int vmid = 0;
int mips = 1000;
long size = 10000; // image size (MB)
int ram = 512; // vm memory (MB)
long bw = 1000;
int pesNumber = 1; // number of cpus
String vmm = "Xen"; // VMM name
// create VM
Vm vm = new Vm(vmid, brokerId, mips, pesNumber, ram, bw, size, vmm, new CloudletSchedulerTimeShared());
// add the VM to the vmList
vmlist.add(vm);
// submit vm list to the broker
broker.submitVmList(vmlist);
// Fifth step: Create one Cloudlet
cloudletList = new ArrayList<Cloudlet>();
// Creates a container to store Cloudlets
LinkedList<Cloudlet> list = new LinkedList<Cloudlet>();
// Cloudlet properties
int id = 0;
long length = 400000;
long fileSize = 300;
long outputSize = 300;
UtilizationModel utilizationModel = new UtilizationModelFull();
// double priority = 0;
/*Cloudlet cloudlet1 = new Cloudlet(id, length,priority, pesNumber, fileSize, outputSize, utilizationModel, utilizationModel, utilizationModel);
cloudlet1.setUserId(brokerId);
cloudlet1.setVmId(vmid);
id++;
Cloudlet cloudlet2 = new Cloudlet(id, length,priority, pesNumber, fileSize, outputSize, utilizationModel, utilizationModel, utilizationModel);
cloudlet2.setUserId(brokerId);
cloudlet2.setVmId(vmid);
id++;
Cloudlet cloudlet3 = new Cloudlet(id, length,priority, pesNumber, fileSize, outputSize, utilizationModel, utilizationModel, utilizationModel);
cloudlet3.setUserId(brokerId);
cloudlet3.setVmId(vmid);
id++;
Cloudlet cloudlet4 = new Cloudlet(id, length,priority, pesNumber, fileSize, outputSize, utilizationModel, utilizationModel, utilizationModel);
cloudlet4.setUserId(brokerId);
cloudlet4.setVmId(vmid);
id++;
*/
Cloudlet[] cloudlet = new Cloudlet[5];
int userId=0,cloudlets=0,idShift=0;
for(int i=0;i<4;i++)
{
cloudlet[i] = new Cloudlet( idShift + i, length, pesNumber, fileSize, outputSize, utilizationModel, utilizationModel, utilizationModel);
cloudlet[i].setUserId(brokerId);
cloudlet[i].setVmId(vmid);
}
A a=new A();
int i,j;
float[][] resource=new float[3][3];
float[] eigen1=new float[3];
float[] pv=new float[3];
float[] f=new float[4];
//resource matrix
System.out.println("enter the resource matrix");
Scanner sc =new Scanner(System.in);
for(i=0;i<3;i++)
{
for(j=0;j<3;j++)
{
resource[i][j]=sc.nextFloat();
}
}
for(j=0;j<3;j++)
{
for(i=0;i<3;i++)
{
eigen1[j]+=resource[i][j];
}
}
for(j=0;j<3;j++)
{
System.out.println(eigen1[j]);
}
for(i=0;i<3;i++)
{
for(j=0;j<3;j++)
{
resource[j][i]=resource[j][i]/eigen1[i];
}
}
for(i=0;i<3;i++)
{
for(j=0;j<3;j++)
{
System.out.println(resource[i][j]);
}
}
System.out.println("CSE2");
for(i=0;i<3;i++)
{
for(j=0;j<3;j++)
{
pv[i]+=resource[i][j];
}
pv[i]=pv[i]/3;
}
for(j=0;j<3;j++)
{
System.out.println(pv[j]);
}
for(j=0;j<3;j++)
{
a.jungle();
}
System.out.println("Priority Order");
for(j=0;j<4;j++)
{
f[j]=0;
}
for(j=0;j<4;j++)
{
for(int k=0;k<3;k++)
{
f[j]+=pv[k] * a.pv1[j][k];
}
}
for(j=0;j<4;j++)
{
System.out.println(f[j]);
}
int[] ids={0,1,2,3};
for(j=0;j<4;j++)
{
for(i=j+1;i<4;i++)
{
if (f[j]<f[i])
{
float temp;
temp=f[j];
f[j]=f[i];
f[i]=temp;
int t;
t=ids[j];
ids[j]=ids[i];
ids[i]=t;
}
}
}
System.out.println("sorted priorities");
for(i=0;i<4;i++)
{
System.out.println(f[i]+"\t"+ids[i]);
}
// add the cloudlet to the list
for(i=0;i<4;i++)
{
cloudletList.add(cloudlet[ids[i]]);
}
/*cloudletList.add(cloudlet[1]);
cloudletList.add(cloudlet[2]);
cloudletList.add(cloudlet[3]);
cloudletList.add(cloudlet[4]);
*/
// submit cloudlet list to the broker
broker.submitCloudletList(cloudletList);
//bind the cloudlets to the vms. This way, the broker
// will submit the bound cloudlets only to the specific VM
for(i=0;i<4;i++)
{
broker.bindCloudletToVm(cloudlet[ids[i]].getCloudletId(),vm.getId());
}
/* broker.bindCloudletToVm(cloudlet[1].getCloudletId(),vm.getId());
broker.bindCloudletToVm(cloudlet[2].getCloudletId(),vm.getId());
broker.bindCloudletToVm(cloudlet[3].getCloudletId(),vm.getId());
broker.bindCloudletToVm(cloudlet[4].getCloudletId(),vm.getId());*/
// Sixth step: Starts the simulation
CloudSim.startSimulation();
CloudSim.stopSimulation();
//Final step: Print results when simulation is over
List<Cloudlet> newList = broker.getCloudletReceivedList();
printCloudletList(newList);
Log.printLine("PJSC Successfully Executed!!!");
}
catch (Exception e)
{
e.printStackTrace();
Log.printLine("Unwanted errors happen");
}
}
/**
* Creates the datacenter.
*
* @param name the name
*
* @return the datacenter
*/
private static Datacenter createDatacenter(String name) {
// Here are the steps needed to create a PowerDatacenter:
// 1. We need to create a list to store
// our machine
List<Host> hostList = new ArrayList<Host>();
// 2. A Machine contains one or more PEs or CPUs/Cores.
// In this example, it will have only one core.
List<Pe> peList = new ArrayList<Pe>();
int mips = 1000;
// 3. Create PEs and add these into a list.
peList.add(new Pe(0, new PeProvisionerSimple(mips))); // need to store Pe id and MIPS Rating
// 4. Create Host with its id and list of PEs and add them to the list
// of machines
int hostId = 0;
int ram = 2048; // host memory (MB)
long storage = 1000000; // host storage
int bw = 10000;
hostList.add(
new Host(
hostId,
new RamProvisionerSimple(ram),
new BwProvisionerSimple(bw),
storage,
peList,
new VmSchedulerTimeShared(peList)
)
); // This is our machine
// 5. Create a DatacenterCharacteristics object that stores the
// properties of a data center: architecture, OS, list of
// Machines, allocation policy: time- or space-shared, time zone
// and its price (G$/Pe time unit).
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
DatacenterCharacteristics characteristics = new DatacenterCharacteristics(
arch, os, vmm, hostList, time_zone, cost, costPerMem,
costPerStorage, costPerBw);
// 6. Finally, we need to create a PowerDatacenter object.
Datacenter datacenter = null;
try {
datacenter = new Datacenter(name, characteristics, new VmAllocationPolicySimple(hostList), storageList, 0);
} catch (Exception e) {
e.printStackTrace();
}
return datacenter;
}
// We strongly encourage users to develop their own broker policies, to
// submit vms and cloudlets according
// to the specific rules of the simulated scenario
/**
* Creates the broker.
*
* @return the datacenter broker
*/
private static DatacenterBroker createBroker() {
DatacenterBroker broker = null;
try {
broker = new DatacenterBroker("Broker");
} catch (Exception e) {
e.printStackTrace();
return null;
}
return broker;
}
/**
* Prints the Cloudlet objects.
*
* @param list list of Cloudlets
*/
private static void printCloudletList(List<Cloudlet> list) {
int size = list.size();
Cloudlet cloudlet;
String indent = " ";
Log.printLine();
Log.printLine("========== OUTPUT ==========");
Log.printLine("Cloudlet ID" + indent + "STATUS" + indent
+ "Data center ID" + indent + "VM ID" + indent + "Time" + indent
+ "Start Time" + indent + "Finish Time");
DecimalFormat dft = new DecimalFormat("###.##");
for (int i = 0; i < size; i++) {
cloudlet = list.get(i);
Log.print(indent + cloudlet.getCloudletId() + indent + indent);
if (cloudlet.getCloudletStatus() == Cloudlet.SUCCESS) {
Log.print("SUCCESS");
Log.printLine(indent + indent + cloudlet.getResourceId()
+ indent + indent + indent + cloudlet.getVmId()
+ indent + indent
+ dft.format(cloudlet.getActualCPUTime()) + indent
+ indent + dft.format(cloudlet.getExecStartTime())
+ indent + indent
+ dft.format(cloudlet.getFinishTime()));
}
}
}
}
class A
{
static int k=0;
static float[][] pv1=new float[4][3];
void jungle()
{
//float[][] resource=new float[3][3];
//float[] eigen1=new float[3];
float[] eigen2=new float[4];
float[][] job1=new float[4][4];
//float[][] job2=new float[4][4];
//float[][] job3=new float[4][4];
//float[] pv=new float[3];
int i,j;
System.out.println("enter the job matrix");
Scanner sc1=new Scanner(System.in);
for(i=0;i<4;i++)
{
for(j=0;j<4;j++)
{
job1[i][j]=sc1.nextFloat();
}
}
for(j=0;j<4;j++)
{
for(i=0;i<4;i++)
{
eigen2[j]+=job1[i][j];
}
}
for(j=0;j<4;j++)
{
System.out.println(eigen2[j]);
}
for(i=0;i<4;i++)
{
for(j=0;j<4;j++)
{
job1[j][i]=job1[j][i]/eigen2[i];
}
}
// this is for printing eigen matrix.
/*for(i=0;i<4;i++)
{
for(j=0;j<4;j++)
{
System.out.print(job1[i][j]+"\t");
}
System.out.print("\n");
}*/
System.out.println("CSE2");
for(i=0;i<4;i++)
{
for(j=0;j<4;j++)
{
pv1[i][k]+=job1[i][j];
}
pv1[i][k]=pv1[i][k]/4;
}
for(j=0;j<4;j++)
{
System.out.print(pv1[j][k]+"\t");
}
System.out.print("\n\n");
k++;
if(k==3)
{
/*for(i=0;i<3;i++)
{
for(j=0;j<4;j++)
{
pv1[j][i]=pv1[i][j];
//System.out.print(pv1[i][j]+"\t");
}
//System.out.print("\n");
}*/
for(j=0;j<4;j++)
{
for(i=0;i<3;i++)
{
System.out.print(pv1[j][i]+"\t");
}
System.out.print("\n");
}
}
}
}
Step 2:I saved it in package org.cloudbus.cloudsim.examples on the left side.
Step:3
Output Screens.
1)
2)
3)
4)
5)
In Below output you can see that burst times are same it shouldnt be like that,they have to change after executing each cloudlet.this is the problem!!
I would be really very Grateful if you people could spend time on it and let me know where do i need to change or add any code to get correct burst times..Thanx in Advance!!!!...:)
