org.brutusin.wava.core.plug

Class PromiseHandler

java.lang.Object

org.brutusin.wava.core.plug.PromiseHandler

Direct Known Subclasses:

LaxPromiseHandler, StrictPromiseHandler

public abstract class PromiseHandler
extends Object

Author:

Ignacio del Valle Alles idelvall@brutusin.org

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PromiseHandler.FailingAction

Constructor Summary

Constructors

Constructor and Description
PromiseHandler()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PromiseHandler

public PromiseHandler()

Method Detail

getInstance

public static PromiseHandler getInstance()

promiseFailed

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

Parameters:

availableMemory - non allocated memory

pi -

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