public final class ClusteringEngine extends SimEntity
| Modifier and Type | Field and Description |
|---|---|
protected int |
cloudletsSubmitted
The number of tasks submitted.
|
protected BasicClustering |
engine
The clustering engine to use
|
protected java.util.List<Job> |
jobList
The job list
|
protected java.util.List<Task> |
taskList
The task list
|
protected java.util.List<? extends Task> |
taskReceivedList
The task received list.
|
protected java.util.List<? extends Task> |
taskSubmittedList
The task submitted list.
|
| Constructor and Description |
|---|
ClusteringEngine(java.lang.String name,
int schedulers)
Created a new ClusteringEngine object.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
finishExecution()
Send an internal event communicating the end of the simulation.
|
java.util.List<Job> |
getJobList()
Gets the job list.
|
java.util.List<Task> |
getTaskList()
Gets the task list.
|
java.util.List<Task> |
getTaskReceivedList()
Gets the task received list.
|
java.util.List<Task> |
getTaskSubmittedList()
Gets the tasks submitted list.
|
WorkflowEngine |
getWorkflowEngine()
returns the WorkflowEngine
|
int |
getWorkflowEngineId()
returns the WorkflowEngineId
|
protected void |
processClustering()
Processes events available for this ClusteringEngine.
|
protected void |
processDatastaging()
Adds data stage-in jobs to the job list
|
void |
processEvent(SimEvent ev)
Processes events available for this Broker.
|
protected void |
processOtherEvent(SimEvent ev)
Overrides this method when making a new and different type of Broker.
|
protected void |
setJobList(java.util.List<Job> jobList)
Sets the job list.
|
protected void |
setTaskList(java.util.List<Task> taskList)
Sets the task list.
|
protected void |
setTaskReceivedList(java.util.List<Task> taskReceivedList)
Sets the task received list.
|
protected void |
setTaskSubmittedList(java.util.List<Task> taskSubmittedList)
Sets the tasks submitted list.
|
void |
shutdownEntity()
This method is invoked by the
Simulation before the simulation finishes. |
void |
startEntity()
This method is invoked by the
Simulation class when the simulation is started. |
void |
submitTaskList(java.util.List<Task> list)
This method is used to send to the broker the list of cloudlets.
|
cancelEvent, clone, getEventBuffer, getId, getName, getNextEvent, getNextEvent, getState, numEventsWaiting, numEventsWaiting, pause, run, schedule, schedule, schedule, schedule, scheduleFirst, scheduleFirst, scheduleFirst, scheduleFirst, scheduleFirstNow, scheduleFirstNow, scheduleFirstNow, scheduleFirstNow, scheduleNow, scheduleNow, scheduleNow, scheduleNow, selectEvent, send, send, send, send, sendNow, sendNow, sendNow, sendNow, setEventBuffer, setId, setState, waitForEventprotected java.util.List<Task> taskList
protected java.util.List<Job> jobList
protected java.util.List<? extends Task> taskSubmittedList
protected java.util.List<? extends Task> taskReceivedList
protected int cloudletsSubmitted
protected BasicClustering engine
public ClusteringEngine(java.lang.String name,
int schedulers)
throws java.lang.Exception
name - name to be associated with this entity (as required by
Sim_entity class from simjava package)schedulers - the number of schedulers in this ClusteringEnginejava.lang.Exception - the exceptionpublic int getWorkflowEngineId()
public WorkflowEngine getWorkflowEngine()
public void submitTaskList(java.util.List<Task> list)
list - the listprotected void processClustering()
ev - a SimEvent objectprotected void processDatastaging()
$none - public void processEvent(SimEvent ev)
processEvent in class SimEntityev - a SimEvent objectprotected void processOtherEvent(SimEvent ev)
#body() for incoming unknown tags.ev - a SimEvent objectprotected void finishExecution()
public void shutdownEntity()
SimEntitySimulation before the simulation finishes. If you want
to save data in log files this is the method in which the corresponding code would be placed.shutdownEntity in class SimEntitypublic void startEntity()
SimEntitySimulation class when the simulation is started. This
method should be responsible for starting the entity up.startEntity in class SimEntitypublic java.util.List<Task> getTaskList()
T - the generic typepublic java.util.List<Job> getJobList()
T - the generic typeprotected void setTaskList(java.util.List<Task> taskList)
T - the generic typetaskList - the new task listprotected void setJobList(java.util.List<Job> jobList)
T - the generic typejobList - the new job listpublic java.util.List<Task> getTaskSubmittedList()
T - the generic typeprotected void setTaskSubmittedList(java.util.List<Task> taskSubmittedList)
T - the generic typetaskSubmittedList - the new task submitted listpublic java.util.List<Task> getTaskReceivedList()
T - the generic typeprotected void setTaskReceivedList(java.util.List<Task> taskReceivedList)
T - the generic typetaskReceivedList - the new cloudlet received list