io.parallec.core.actor

Class ExecutionManager

java.lang.Object

akka.actor.UntypedActor

io.parallec.core.actor.ExecutionManager

All Implemented Interfaces:

akka.actor.Actor

public class ExecutionManager
extends akka.actor.UntypedActor

This is the Akka Actor that executes the ParallelTask. Will create a list of operation workers to match each of the target hosts.

Author:

Yuanteng (Jeff) Pei

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
protected com.ning.http.client.AsyncHttpClient	asyncHttpClientGlobal The async http client global.
protected akka.actor.ActorRef	batchSenderAsstManager The batch sender asst manager.
protected akka.actor.ActorRef	director The director.
protected long	endTime The end time.
protected HttpMeta	httpMeta The command metadata.
private static org.slf4j.Logger	logger The logger.
static int	REDUCE_LEN The Constant REDUCE_LEN.
protected int	requestCount The request count.
protected int	responseCount The response count.
protected java.util.Map<java.lang.String,ResponseOnSingleTask>	responseMap The response map.
protected long	startTime The start time.
protected TargetHostMeta	targetHostMeta The node group metadata.
protected ParallelTask	task The parallel task.
protected java.lang.String	taskId The task id.
protected java.lang.String	taskIdTrim The task id trim.
protected akka.actor.Cancellable	timeoutMessageCancellable The timeout message cancellable.
protected boolean	wasIssuedCancel The was issued cancel.
protected java.util.Map<java.lang.String,akka.actor.ActorRef>	workers The workers.

Constructor Summary

Constructors

Constructor and Description
ExecutionManager(ParallelTask task) Instantiates a new command manager.

Method Summary

Modifier and Type	Method and Description
private void	cancelRequestAndWorkerOnHost(java.util.List<java.lang.String> targetHosts) Cancel request and worker on host.
private void	cancelRequestAndWorkers() Cancel request and workers.
void	onReceive(java.lang.Object message)
private void	reply(ParallelTaskState state, java.lang.Exception t) reply will terminal the actor and return the results.

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static org.slf4j.Logger logger

The logger.

responseCount

protected int responseCount

The response count.

requestCount

protected int requestCount

The request count.

startTime

protected long startTime

The start time.

wasIssuedCancel

protected boolean wasIssuedCancel

The was issued cancel.

endTime

protected long endTime

The end time.

director

protected akka.actor.ActorRef director

The director.

workers

protected final java.util.Map<java.lang.String,akka.actor.ActorRef> workers

The workers.

batchSenderAsstManager

protected akka.actor.ActorRef batchSenderAsstManager

The batch sender asst manager.

responseMap

protected final java.util.Map<java.lang.String,ResponseOnSingleTask> responseMap

The response map.

taskId

protected java.lang.String taskId

The task id.

taskIdTrim

protected java.lang.String taskIdTrim

The task id trim.

timeoutMessageCancellable

protected akka.actor.Cancellable timeoutMessageCancellable

The timeout message cancellable.

asyncHttpClientGlobal

protected com.ning.http.client.AsyncHttpClient asyncHttpClientGlobal

The async http client global.

task

protected ParallelTask task

The parallel task.

httpMeta

protected HttpMeta httpMeta

The command metadata.

targetHostMeta

protected TargetHostMeta targetHostMeta

The node group metadata.

REDUCE_LEN

public static final int REDUCE_LEN

The Constant REDUCE_LEN.

See Also:

Constant Field Values

Constructor Detail

ExecutionManager

public ExecutionManager(ParallelTask task)

Instantiates a new command manager.

Parameters:

task - the task

Method Detail

onReceive

public void onReceive(java.lang.Object message)

Specified by:

onReceive in class akka.actor.UntypedActor

reply

private void reply(ParallelTaskState state,
                   java.lang.Exception t)

reply will terminal the actor and return the results.

Parameters:

state - the state

t - the exception

cancelRequestAndWorkers

private void cancelRequestAndWorkers()

Cancel request and workers.

cancelRequestAndWorkerOnHost

private void cancelRequestAndWorkerOnHost(java.util.List<java.lang.String> targetHosts)

Cancel request and worker on host.

Parameters:

targetHosts - the target hosts