--no commit message

--no commit message

modules/cloudsim-examples/src/main/java/org/cloudbus/cloudsim/examples/network/datacenter/TestBagofTaskApp.java

+package org.cloudbus.cloudsim.examples.network.datacenter;
+
+/**
+ * BagofTaskApp is an example of AppCloudlet having three noncommunicating tasks. 
+ * 
+ * 
+ * Please refer to following publication for more details:
+ * 
+ * Saurabh Kumar Garg and Rajkumar Buyya, NetworkCloudSim: Modelling Parallel
+ * Applications in Cloud Simulations, Proceedings of the 4th IEEE/ACM
+ * International Conference on Utility and Cloud Computing (UCC 2011, IEEE CS
+ * Press, USA), Melbourne, Australia, December 5-7, 2011.
+ *
+ * 
+ * @author Saurabh Kumar Garg
+ * @since CloudSim Toolkit 1.0
+ */
+
+import java.util.List;
+
+import org.cloudbus.cloudsim.UtilizationModel;
+import org.cloudbus.cloudsim.UtilizationModelFull;
+import org.cloudbus.cloudsim.core.CloudSim;
+import org.cloudbus.cloudsim.network.datacenter.AppCloudlet;
+import org.cloudbus.cloudsim.network.datacenter.NetworkCloudlet;
+import org.cloudbus.cloudsim.network.datacenter.NetworkConstants;
+import org.cloudbus.cloudsim.network.datacenter.TaskStage;
+
+public class TestBagofTaskApp extends AppCloudlet {
+
+	public TestBagofTaskApp(int type, int appID, double deadline, 	int numbervm, int userId) {
+		super(type, appID, deadline, numbervm,userId);
+		
+		this.numbervm=this.getnumvm();
+		this.exeTime=getExecTime()/this.numbervm;
+	}
+	
+	@Override
+    public void createCloudletList(List<Integer> vmIdList){
+		//basically, each task runs the simulation and then data is consolidated in one task
+		int executionTime = getExecTime();
+		long memory = 1000;
+		long fileSize = NetworkConstants.FILE_SIZE;
+		long outputSize = NetworkConstants.OUTPUT_SIZE;
+		int pesNumber = NetworkConstants.PES_NUMBER;
+		int stgId=0;
+		int t=NetworkConstants.currentCloudletId;
+	  	for(int i=0;i<numbervm;i++){
+    		UtilizationModel utilizationModel = new UtilizationModelFull();
+    		NetworkCloudlet cl = new NetworkCloudlet(NetworkConstants.currentCloudletId, executionTime/numbervm, pesNumber, fileSize, outputSize, memory, utilizationModel, utilizationModel, utilizationModel);
+    		NetworkConstants.currentCloudletId++;
+    		cl.setUserId(userId);
+			cl.submittime=CloudSim.clock();
+    		cl.currStagenum=-1;
+			cl.setVmId(vmIdList.get(i));
+			//compute and send data to node 0
+    		cl.stages.add(new TaskStage(NetworkConstants.EXECUTION, NetworkConstants.COMMUNICATION_LENGTH, executionTime/numbervm, stgId++, memory, vmIdList.get(0),cl.getCloudletId()));
+    		
+    		//0 has an extra stage of waiting for results; others send
+    		if (i==0){
+    			for(int j=1;j<numbervm;j++)
+    				cl.stages.add(new TaskStage(NetworkConstants.WAIT_RECV, NetworkConstants.COMMUNICATION_LENGTH, 0, stgId++, memory, vmIdList.get(j),cl.getCloudletId()+j));
+    		} else {
+    			cl.stages.add(new TaskStage(NetworkConstants.WAIT_SEND, NetworkConstants.COMMUNICATION_LENGTH, 0, stgId++, memory, vmIdList.get(0),t));
+    		}
+    		
+    		clist.add(cl);    			
+    	}	
+	}
+	
+	/**
+	 * One can generate number of VMs for each application based on deadline
+	 * @return
+	 */
+	public int getnumvm(){
+		double exetime=getExecTime()/2;//for two vms
+		if(this.deadline>exetime)
+			return 2;
+		else if(this.deadline>(exetime/4)) return 4;
+			
+		return 4;
+	}
+	
+	private int getExecTime() {
+		//use exec constraints 
+		
+		return 100;
+	}
+
+	
+}