org.brutusin.wava.core.plug.impl.promise

Class LaxPromiseHandler

java.lang.Object

org.brutusin.wava.core.plug.PromiseHandler

org.brutusin.wava.core.plug.impl.promise.LaxPromiseHandler

public final class LaxPromiseHandler
extends PromiseHandler

Allows the execution of promise-failing jobs as long as the total-max-RSS and max-RSS-per-job thresholds are not overpassed.

Author:

Ignacio del Valle Alles idelvall@brutusin.org

Nested Class Summary

Nested classes/interfaces inherited from class org.brutusin.wava.core.plug.PromiseHandler

PromiseHandler.FailingAction

Constructor Summary

Constructors

Constructor and Description
LaxPromiseHandler()

Method Summary

Modifier and Type	Method and Description
PromiseHandler.FailingAction	promiseFailed(long availableMemory, Scheduler.ProcessInfo pi, long currentTotalUsedRss, long schedulerManagedRss)

Methods inherited from class org.brutusin.wava.core.plug.PromiseHandler

getInstance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LaxPromiseHandler

public LaxPromiseHandler()

Method Detail

promiseFailed

public PromiseHandler.FailingAction promiseFailed(long availableMemory,
                                                  Scheduler.ProcessInfo pi,
                                                  long currentTotalUsedRss,
                                                  long schedulerManagedRss)
                                           throws IOException,
                                                  InterruptedException

Specified by:

promiseFailed in class PromiseHandler

Parameters:

availableMemory - non allocated memory

currentTotalUsedRss - currently used memory by all jobs

schedulerManagedRss - maximum memory managed by scheduler schedulerManagedRss

Returns:

true if the process is allowed to continue executing, false otherwise

Throws:

IOException

InterruptedException