org.apache.reef.runtime.common.evaluator.context

Class ContextManager

java.lang.Object

org.apache.reef.runtime.common.evaluator.context.ContextManager

All Implemented Interfaces:

AutoCloseable

public final class ContextManager
extends Object
implements AutoCloseable

Manages the stack of context in the Evaluator.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Shuts down.
boolean	contextStackIsEmpty()
Collection<ReefServiceProtos.ContextStatusProto>	getContextStatusCollection()
Optional<ReefServiceProtos.TaskStatusProto>	getTaskStatus()
void	handleContextControlProtocol(EvaluatorRuntimeProtocol.ContextControlProto controlMessage) Processes the given ContextControlProto to launch / close / suspend Tasks and Contexts.
void	start() Start the context manager.

Methods inherited from class java.lang.Object

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

Method Detail

start

public void start()
           throws ContextClientCodeException

Start the context manager. This initiates the root context.

Throws:

ContextClientCodeException - if the root context can't be instantiated.

close

public void close()

Shuts down. This forecefully kills the Task if there is one and then shuts down all Contexts on the stack, starting at the top.

Specified by:

close in interface AutoCloseable

contextStackIsEmpty

public boolean contextStackIsEmpty()

Returns:

true if there is no context.

handleContextControlProtocol

public void handleContextControlProtocol(EvaluatorRuntimeProtocol.ContextControlProto controlMessage)

Processes the given ContextControlProto to launch / close / suspend Tasks and Contexts.

This also triggers the HeartBeatManager to send a heartbeat with the result of this operation.

Parameters:

controlMessage - the message to process

getTaskStatus

public Optional<ReefServiceProtos.TaskStatusProto> getTaskStatus()

Returns:

the TaskStatusProto of the currently running task, if there is any

getContextStatusCollection

public Collection<ReefServiceProtos.ContextStatusProto> getContextStatusCollection()

Returns:

the status of all context in the stack.