|
Lightweight Bartering Grid | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectlbg.peer.core.scheduler.Scheduler
public class Scheduler
Schedules Local Tasks, both locally and as Consumption Tasks, and Supplying Tasks. Also Preempts Supplying Tasks as needed.
Constructor Summary | |
---|---|
Scheduler(Peer managed_peer,
Negotiator negotiator,
java.lang.String target_scheduling_local_policy,
java.lang.String target_scheduling_running_preemption_policy,
java.lang.String target_scheduling_waiting_preemption_policy,
java.lang.String target_supplying_filtering_policy,
java.lang.String target_scheduling_supplying_policy,
java.lang.String target_scheduling_consumption_policy)
Creates a new Scheduler. |
Method Summary | |
---|---|
void |
accountSchedulerConsumptionDecision(long scheduled_tasks,
double blacklisted_supplier_ratio)
|
void |
accountSchedulerLocalDecision()
|
void |
accountSchedulerPreemptionDecision()
|
void |
accountSchedulerSupplyingDecision()
|
boolean |
filterOutSupplyingTask(Task t)
Indicates whether target Supplying Task should be filtered out, or may be safely queued. |
double |
getBlacklistedSupplierRatio()
|
void |
preemptLocalResources(Task prioritary_task)
Preempts some Supplying Tasks on Local Resources so as to enable the Local scheduling of target prioritary Local Task. |
void |
preemptWaitingSupplyingTasks()
Preempts some waiting Supplying Tasks. |
void |
schedule(SchedulerControlFlags ctrl_flags)
Activates scheduling of Local, Supplying and Consumption Tasks following target scheduling control flags. |
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public Scheduler(Peer managed_peer, Negotiator negotiator, java.lang.String target_scheduling_local_policy, java.lang.String target_scheduling_running_preemption_policy, java.lang.String target_scheduling_waiting_preemption_policy, java.lang.String target_supplying_filtering_policy, java.lang.String target_scheduling_supplying_policy, java.lang.String target_scheduling_consumption_policy) throws GridException
managed_peer
- managed Peernegotiator
- Negotiator of the managed Peertarget_scheduling_local_policy
- selected Local scheduling policytarget_scheduling_running_preemption_policy
- selected running Preemption policytarget_scheduling_waiting_preemption_policy
- selected waiting Preemption policytarget_supplying_filtering_policy
- selected Supplying filtering policytarget_scheduling_supplying_policy
- selected Supplying scheduling policytarget_scheduling_consumption_policy
- selected Consumption scheduling policy
GridException
Method Detail |
---|
public java.lang.String toString()
toString
in class java.lang.Object
public void schedule(SchedulerControlFlags ctrl_flags) throws GridException
Also asks the Negotiator to generate Supplying Requests as needed.
ctrl_flags
- target scheduling control flags
GridException
- if a parameter is illegal,
or an error happens while schedulingpublic void preemptLocalResources(Task prioritary_task) throws GridException
prioritary_task
- target prioritary Local Task
GridException
- if a parameter is illegal,
or an error happens while preemptingpublic void preemptWaitingSupplyingTasks() throws GridException
GridException
public boolean filterOutSupplyingTask(Task t) throws GridException
GridException
public void accountSchedulerLocalDecision()
public void accountSchedulerPreemptionDecision()
public void accountSchedulerConsumptionDecision(long scheduled_tasks, double blacklisted_supplier_ratio) throws GridException
GridException
public void accountSchedulerSupplyingDecision()
public double getBlacklistedSupplierRatio()
getBlacklistedSupplierRatio
in interface ISchedulerStats
|
Lightweight Bartering Grid | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Copyright (c) 2005-2008, Cyril Briquet, parts Xavier Dalem.