| Method Summary |
|
| protected boolean | allNecessaryAssetsReported()
|
| protected void | attachSubtask(Task subtask, SequentialScheduleElement spe)
attachSubtask adds a created subtask to the parent task's expansion. |
| public void | changeExpansion(Expansion exp)
|
| protected UTILAllocationCallback | createAllocCallback()
|
| protected UTILAssetCallback | createAssetCallback()
|
| abstract public Schedule | createEmptyPlan(Task parent)
createEmptyPlan creates an empty schedule (there are no tasks
yet in the workflow) made up of custom schedule elements. |
| protected UTILExpansionCallback | createExpansionCallback()
|
| protected UTILFilterCallback | createThreadCallback(UTILGenericListener bufferingThread)
|
| public void | enterHash(String key, SequentialScheduleElement obj)
|
| protected void | execute()
|
| protected UTILAllocationCallback | getAllocCallback()
|
| protected UTILAssetCallback | getAssetCallback()
|
| final protected Iterator | getAssets()
|
| public Map | getChildToParentUID()
|
| protected SequentialScheduleElement | getElement(Task child, Task parent, String uid)
Finds the schedule element for the child task in the taskToSSE map. |
| protected UTILExpansionCallback | getExpansionCallback()
|
| protected UTILFilterCallback | getInputTaskCallback()
|
| public Task | getParentTask(Task child, String uid)
Gets the parent task for the child task with the UID uid. |
| protected List | getPrunedTaskList(List tasks)
|
| public void | handleChangedAssets(Enumeration e)
|
| public void | handleConstraintViolation(Expansion exp, List violatedConstraints)
|
| public void | handleFailedExpansion(Expansion exp, List failedSubTaskResults)
|
| public void | handleIllFormedTask(Task t)
|
| public void | handleNewAssets(Enumeration e)
|
| public void | handleRemovedAlloc(Allocation alloc)
|
| public boolean | handleRescindedAlloc(Allocation alloc)
|
| public void | handleSuccessfulAlloc(Allocation alloc)
When an allocation is succesful you ignore it unless it is a meaningful allocation.
Meaningful is defined as having a non-null reported result and a highest confidence rating.
This would indicate that an allocation to an actual resource has been done. |
| public void | handleSuccessfulExpansion(Expansion exp, List successfulSubtasks)
|
| public void | handleTask(Task t)
handleTask creates an empty schedule and attaches it to the parent task. |
| public boolean | interestingAsset(Asset a)
|
| public boolean | interestingExpandedTask(Task t)
|
| public boolean | interestingNotification(Task t)
|
| public boolean | interestingTask(Task t)
|
| public void | localSetup()
|
| public boolean | needToRescind(Allocation alloc)
|
| public void | processTasks(List tasks)
If necessary subordinates have not reported yet, accumulates tasks into
a delayedTasks list, and asks to be kicked again in 10 seconds, by which
time hopefully the subordinates have reported. |
| public PlanningFactory | publicGetFactory()
|
| public MessageAddress | publicGetMessageAddress()
|
| public String | publicGetMyClusterName()
|
| public Plan | publicGetRealityPlan()
|
| public void | publicPublishAdd(Object o)
|
| public void | publicPublishChange(Object o)
|
| public void | publishChangedExpansion(Expansion exp)
|
| public void | publishRemovalOfAllocation(Allocation alloc)
|
| protected void | replanDependingTasks(Task parentTask, long beforeTime)
re-examine the workflow to see if the any tasks overlap the time
of the recently changed allocation, if they do, replan tasks
that depend on it. |
| public void | reportChangedExpansion(Expansion exp)
Mainly just calls updateAllocationResult on exp
Also prints debug info when tasks fail. |
| public void | setupFilters()
|
| public void | turnCrank(Task task)
turnCrank is a basic planning cycle. |
| public boolean | wantToChangeExpansion(Expansion exp)
|
