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

Class StrictPromiseHandler

java.lang.Object

org.brutusin.wava.core.plug.PromiseHandler

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

public final class StrictPromiseHandler
extends PromiseHandler

Disallow continuing executing jobs with failed promises

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
StrictPromiseHandler()

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

StrictPromiseHandler

public StrictPromiseHandler()

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