|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of BrokerReservation in orca.policy.core |
|---|
| Fields in orca.policy.core with type parameters of type BrokerReservation | |
|---|---|
protected java.util.Vector<BrokerReservation> |
AgentQueuedBestFitPolicyPlugin.queue
Queue of requests that failed but have been deferred: not sure how to recover queue |
| Methods in orca.policy.core with parameters of type BrokerReservation | |
|---|---|
protected void |
BrokerBasePolicyPlugin.addForApproval(BrokerReservation r)
Add a reservation to the approval list |
protected void |
BrokerBasePolicyPlugin.addForApprovalCalendar(BrokerReservation r)
Adds the reservation to the approval list and removes the reservation from the closing calendar (if it belongs to it). |
protected void |
BrokerBasePolicyPlugin.addToCalendar(ResourceSet mine,
BrokerReservation reservation,
ReservationClient source,
Term approved)
Record the new reservation in the agent's calendar |
void |
BrokerBasePolicyPlugin.approve(BrokerReservation r)
Approve a reservation. |
boolean |
BrokerSimplePolicyPlugin.bind(BrokerReservation reservation)
Handles an incoming request to allocate resources and issue a ticket for the reservation. |
protected long |
BrokerSimplePolicyPlugin.calculateAvailable(long startTime,
ReservationClient source,
BrokerReservation reservation)
Calculate the available resources for a particular start time |
protected boolean |
BrokerBestFitPolicyPlugin.canResize(BrokerReservation r,
long[] available)
Determine if this request can be resized. |
protected boolean |
BrokerWorstFitPolicyPlugin.canResize(BrokerReservation r,
long[] available)
Determine if this request can be resized. |
protected boolean |
BrokerWorstFitMultiplePoolsPolicyPlugin.canResize(BrokerReservation r,
long[] available)
Determine if this request can be resized. |
protected long |
BrokerBestFitPolicyPlugin.checkRequestEndTime(long[] maxResources,
long start,
long end,
BrokerReservation r)
Determine if the new growth affects the endtime of the request - would only affect the endtime |
protected long |
BrokerWorstFitPolicyPlugin.checkRequestEndTime(long[] maxResources,
long start,
long end,
BrokerReservation r)
Determine if the new growth affects the endtime of the request - would only affect the endtime |
protected long |
BrokerWorstFitMultiplePoolsPolicyPlugin.checkRequestEndTime(long[] maxResources,
long start,
long end,
BrokerReservation r)
Determine if the new growth affects the endtime of the request - would only affect the endtime |
boolean |
BrokerSimplePolicyPlugin.extend(BrokerReservation reservation)
Handles an incoming request to extend previously allocated resources and issue a ticket for the reservation. |
protected void |
BrokerBestFitPolicyPlugin.extendTicket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Extend a ticket. |
protected void |
BrokerWorstFitPolicyPlugin.extendTicket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Extend a ticket. |
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.extendTicket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Extend a ticket. |
protected ResourceSet |
BrokerSimplePolicyPlugin.extractTicket(BrokerReservation reservation,
ReservationClient source,
Term approved,
long resourceShare)
Extract the ticket from the source and check to see if the resulting ticket satisfies the request |
protected ResourceSet |
BrokerWorstFitMultiplePoolsPolicyPlugin.extractTicket(BrokerReservation reservation,
ReservationClient source,
Term approved,
long resourceShare)
|
AllotmentTable |
BrokerBestFitPolicyPlugin.findAllotment(ResourceEntry request,
ResourceTable table,
int unitsNeeded,
AllotmentTable allotment,
int minIndex,
BrokerReservation r,
int extendedUnits)
Recursively determines the machines and number of units per machine that will be allocated to a request |
AllotmentTable |
BrokerWorstFitPolicyPlugin.findAllotment(ResourceEntry request,
ResourceTable table,
int unitsNeeded,
AllotmentTable allotment,
int minIndex,
BrokerReservation r,
int extendedUnits)
Recursively determines the machines and number of units per machine that will be allocated to a request |
AllotmentTable |
BrokerWorstFitMultiplePoolsPolicyPlugin.findAllotment(ResourceEntry request,
ResourceTable table,
int unitsNeeded,
AllotmentTable allotment,
int minIndex,
BrokerReservation r,
int extendedUnits)
Recursively determines the machines and number of units per machine that will be allocated to a request |
protected long |
BrokerSimplePolicyPlugin.getAllocation(BrokerReservation reservation)
Returns the allocation time for this reservation |
protected Term |
BrokerSimplePolicyPlugin.getApprovedTerm(BrokerReservation reservation)
Determine the approved term of a reservation |
protected java.lang.String |
BrokerWorstFitMultiplePoolsPolicyPlugin.getCurrentPoolID(BrokerReservation r)
|
protected java.lang.String |
BrokerWorstFitMultiplePoolsPolicyPlugin.getRequestedPoolID(BrokerReservation r)
|
protected long[] |
BrokerBestFitPolicyPlugin.growResources(AllotmentTable allotment,
ResourceEntry minRequest,
long[] maxRequest,
BrokerReservation r)
Determines how far we can grow the minimum request, but not exceed the maximum request |
protected long[] |
BrokerWorstFitPolicyPlugin.growResources(AllotmentTable allotment,
ResourceEntry minRequest,
long[] maxRequest,
BrokerReservation r)
Determines how far we can grow the minimum request, but not exceed the maximum request |
protected long[] |
BrokerWorstFitMultiplePoolsPolicyPlugin.growResources(AllotmentTable allotment,
ResourceEntry minRequest,
long[] maxRequest,
BrokerReservation r)
Determines how far we can grow the minimum request, but not exceed the maximum request |
protected void |
BrokerBestFitPolicyPlugin.issueTicket(BrokerReservation r,
AllotmentTable allotment,
long[] maxResources,
long start,
long end)
Reserves the allotment being allocated to the ticket from the agent's inventory and creates the ticket to be given to the request. |
protected void |
BrokerWorstFitPolicyPlugin.issueTicket(BrokerReservation r,
AllotmentTable allotment,
long[] maxResources,
long start,
long end)
Reserves the allotment being allocated to the ticket from the agent's inventory and creates the ticket to be given to the request. |
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.issueTicket(LogicalInventory inventory,
BrokerReservation r,
AllotmentTable allotment,
long[] maxResources,
long start,
long end)
Reserves the allotment being allocated to the ticket from the agent's inventory and creates the ticket to be given to the request. |
void |
BrokerBasePolicyPlugin.notApprove(BrokerReservation r)
Do not approve a reservation. |
protected void |
BrokerBasePolicyPlugin.release(BrokerReservation r)
Release resources associated with a client reservation. |
protected void |
BrokerBestFitPolicyPlugin.release(BrokerReservation r)
|
protected void |
BrokerWorstFitPolicyPlugin.release(BrokerReservation r)
|
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.release(BrokerReservation r)
|
protected void |
BrokerBasePolicyPlugin.releaseNotApproved(BrokerReservation r)
Release the resources for a reservation that is not approved. |
protected void |
BrokerBestFitPolicyPlugin.releaseNotApproved(BrokerReservation r)
|
protected void |
BrokerWorstFitPolicyPlugin.releaseNotApproved(BrokerReservation r)
|
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.releaseNotApproved(BrokerReservation r)
|
protected void |
BrokerBasePolicyPlugin.removeForApproval(BrokerReservation r)
Remove a reservation from the approval list |
protected void |
BrokerBasePolicyPlugin.revisitServer(BrokerReservation r)
Recovers a client reservation. |
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.revisitServer(BrokerReservation reservation)
|
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.revisitTicketed(BrokerReservation reservation)
|
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.revisitTicketedNone(BrokerReservation reservation)
|
protected void |
BrokerWorstFitMultiplePoolsPolicyPlugin.revisitTicketedPriming(BrokerReservation reservation)
|
protected void |
BrokerSimplePolicyPlugin.satisfyAllocation(BrokerReservation reservation,
ReservationClient source,
long resourceShare,
long startResTime)
Performs all of the checks and necessary functions to allocate a ticket to a reservation from a source. |
protected boolean |
BrokerBestFitPolicyPlugin.ticket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Issue a new ticket to a request. This is the first request for a ticket We try to satisfy the request for the lower bound of requested resources per dimension. |
protected boolean |
BrokerQueuedWorstFitPolicyPlugin.ticket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Do not fail a reservation because we may put it on the queue if it's elastic Issue a new ticket to a request. This is the first request for a ticket We try to satisfy the request for the lower bound of requested resources per dimension. |
protected boolean |
BrokerWorstFitPolicyPlugin.ticket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Issue a new ticket to a request. This is the first request for a ticket We try to satisfy the request for the lower bound of requested resources per dimension. |
protected boolean |
AgentQueuedBestFitPolicyPlugin.ticket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Do not fail a reservation because we may put it on the queue if it's elastic Issue a new ticket to a request. This is the first request for a ticket We try to satisfy the request for the lower bound of requested resources per dimension. |
protected boolean |
BrokerWorstFitMultiplePoolsPolicyPlugin.ticket(BrokerReservation r,
ResourceTable table,
long start,
long end)
Issue a new ticket to a request. This is the first request for a ticket We try to satisfy the request for the lower bound of requested resources per dimension. |
protected boolean |
BrokerSimplePolicyPlugin.verifyWantedResources(BrokerReservation reservation,
ReservationClient source,
long startTime,
int wanted)
Ensure that there are sufficient resources to allocate the number of requested resources |
| Uses of BrokerReservation in orca.policy.core.util |
|---|
| Fields in orca.policy.core.util with type parameters of type BrokerReservation | |
|---|---|
protected java.util.Vector<BrokerReservation> |
FIFOQueue.queue
|
| Methods in orca.policy.core.util that return BrokerReservation | |
|---|---|
BrokerReservation |
FIFOQueue.firstElement()
|
BrokerReservation |
QueueWrapper.firstElement()
Get the first element of the queue |
BrokerReservation |
DeadlinePriorityQueue.firstElement()
|
| Methods in orca.policy.core.util that return types with arguments of type BrokerReservation | |
|---|---|
java.util.Iterator<BrokerReservation> |
FIFOQueue.iterator()
|
java.util.Iterator<BrokerReservation> |
QueueWrapper.iterator()
Return an Iterator |
java.util.Iterator<BrokerReservation> |
DeadlinePriorityQueue.iterator()
Should not use this method - elements are returned in no particular order |
| Methods in orca.policy.core.util with parameters of type BrokerReservation | |
|---|---|
void |
FIFOQueue.add(BrokerReservation r)
|
void |
QueueWrapper.add(BrokerReservation r)
Add an element to the queue |
void |
DeadlinePriorityQueue.add(BrokerReservation r)
|
int |
DeadlineCompare.compare(BrokerReservation a,
BrokerReservation b)
|
boolean |
FIFOQueue.contains(BrokerReservation r)
|
boolean |
QueueWrapper.contains(BrokerReservation r)
See if the queue contains this element |
boolean |
DeadlinePriorityQueue.contains(BrokerReservation r)
|
void |
FIFOQueue.remove(BrokerReservation r)
|
void |
QueueWrapper.remove(BrokerReservation r)
Remove an element from a queue |
void |
DeadlinePriorityQueue.remove(BrokerReservation r)
|
| Uses of BrokerReservation in orca.shirako.api |
|---|
| Methods in orca.shirako.api with parameters of type BrokerReservation | |
|---|---|
boolean |
IServerPolicy.bind(BrokerReservation reservation)
Handles an incoming request to allocate resources and issue a ticket for the reservation. |
void |
IKernelWrapper.claimRequest(BrokerReservation reservation,
AuthToken caller,
IClientCallbackProxy callback)
Processes a request to claim a pre-reserved "will call" ticket. |
void |
IServerActor.export(BrokerReservation reservation,
AuthToken client)
Exports the resources described by the reservation to the client. |
void |
IKernelWrapper.export(BrokerReservation reservation,
AuthToken client)
Initiates a ticket export. |
boolean |
IServerPolicy.extend(BrokerReservation r)
Handles an incoming request to extend previously allocated resources and issue a ticket for the reservation. |
void |
IBroker.extendTicket(BrokerReservation reservation)
Processes an extend ticket request for the reservation. |
void |
IKernelWrapper.extendTicketRequest(BrokerReservation reservation,
AuthToken caller,
boolean compareSequenceNumbers)
Processes an incoming request for a ticket extension. |
void |
IBroker.ticket(BrokerReservation reservation)
Processes a ticket request for the reservation. |
void |
IKernelWrapper.ticketRequest(BrokerReservation reservation,
AuthToken caller,
IClientCallbackProxy callback,
boolean compareSequenceNumbers)
Processes an incoming request for a new ticket. |
| Uses of BrokerReservation in orca.shirako.core |
|---|
| Methods in orca.shirako.core with parameters of type BrokerReservation | |
|---|---|
boolean |
BrokerPolicy.bind(BrokerReservation reservation)
|
boolean |
AuthorityPolicy.bind(BrokerReservation reservation)
|
void |
Broker.export(BrokerReservation reservation,
AuthToken client)
|
void |
Authority.export(BrokerReservation reservation,
AuthToken client)
|
boolean |
BrokerPolicy.extend(BrokerReservation reservation)
|
boolean |
AuthorityPolicy.extend(BrokerReservation reservation)
|
void |
Broker.extendTicket(BrokerReservation reservation)
|
void |
Broker.ticket(BrokerReservation reservation)
|
| Uses of BrokerReservation in orca.shirako.kernel |
|---|
| Methods in orca.shirako.kernel with parameters of type BrokerReservation | |
|---|---|
protected void |
Kernel.claim(BrokerReservation reservation)
Processes a requests to claim new ticket for previously exported resources (broker role). |
void |
KernelWrapper.claimRequest(BrokerReservation reservation,
AuthToken caller,
IClientCallbackProxy callback)
|
void |
KernelWrapper.export(BrokerReservation reservation,
AuthToken client)
|
void |
KernelWrapper.extendTicketRequest(BrokerReservation reservation,
AuthToken caller,
boolean compareSequenceNumbers)
|
protected void |
AuthorityPolicyRecoverer.revisitAgent(BrokerReservation r)
|
protected void |
BrokerPolicyRecoverer.revisitServer(BrokerReservation r)
Performs recovery for BrokerReservations |
void |
KernelWrapper.ticketRequest(BrokerReservation reservation,
AuthToken caller,
IClientCallbackProxy callback,
boolean compareSequenceNumbers)
|
| Uses of BrokerReservation in orca.shirako.proxies.local |
|---|
| Methods in orca.shirako.proxies.local that return BrokerReservation | |
|---|---|
protected BrokerReservation |
LocalBroker.passReservation(ReservationClient r,
AuthToken auth)
Converts a reservation to be passed from one actor to another |
| Uses of BrokerReservation in orca.shirako.proxies.soap.services |
|---|
| Methods in orca.shirako.proxies.soap.services that return BrokerReservation | |
|---|---|
protected BrokerReservation |
AgentServiceImpl.passAgent(Reservation reservation)
Convert a SOAP reservation to an AgentReservation |
| Uses of BrokerReservation in orca.shirako.time.calendar |
|---|
| Methods in orca.shirako.time.calendar with parameters of type BrokerReservation | |
|---|---|
void |
BrokerCalendar.addRequest(BrokerReservation reservation,
long cycle)
Add a client request |
void |
BrokerCalendar.removeRequest(BrokerReservation reservation)
|
void |
BrokerCalendar.removeRequest(BrokerReservation reservation,
long cycle)
|
void |
BrokerCalendar.removeRequest(ResourceReservation source,
BrokerReservation request)
|
| Uses of BrokerReservation in orca.tests.unit.main |
|---|
| Fields in orca.tests.unit.main declared as BrokerReservation | |
|---|---|
protected BrokerReservation |
ReservationTestTool.currentReservationAgent
The agent reservation. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||