io.parallec.core.actor

Class OperationWorker

java.lang.Object

akka.actor.UntypedActor

io.parallec.core.actor.OperationWorker

All Implemented Interfaces:

akka.actor.Actor

public class OperationWorker
extends akka.actor.UntypedActor

AHC based.

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
private int	actorMaxOperationTimeoutSec The actor max operation timeout sec.
private akka.actor.ActorRef	asyncWorker The async worker.
private com.ning.http.client.AsyncHttpClient	client The client.
private HttpPollerProcessor	httpPollerProcessor The http poller processor.
private static org.slf4j.Logger	logger The logger.
private PollerData	pollerData Http Poller.
private int	pollingErrorCount The polling error count.
private akka.actor.Cancellable	pollMessageCancellable The poll message cancellable.
private TaskRequest	request The request.
private ResponseOnSingleTask	response The response.
private akka.actor.ActorRef	sender The sender.
private boolean	sentReply The sent reply.
private long	startTimeMillis The start time millis.
private scala.concurrent.duration.FiniteDuration	timeoutDuration The timeout duration.
private akka.actor.Cancellable	timeoutMessageCancellable The timeout message cancellable.
private java.lang.String	trueTargetNode The true target node.

Constructor Summary

Constructors

Constructor and Description
OperationWorker(TaskRequest request, com.ning.http.client.AsyncHttpClient client, HttpPollerProcessor httpPollerProcessor) Instantiates a new operation worker.

Method Summary

Modifier and Type	Method and Description
private void	cancel() Cancel.
private void	cancelCancellable() Cancel cancellable.
private void	cancelExistingIfAnyAndScheduleTimeoutCall() 201412: now consider the poller.
private void	handleHttpWorkerResponse(ResponseOnSingeRequest respOnSingleReq) Handle http worker response.
void	onReceive(java.lang.Object message)
private void	operationTimeout() will trigger workers to cancel then wait for it to report back.
private void	pollProgress() Poller.
private void	processMainRequest() the 1st request from the manager.
private void	reply(boolean error, java.lang.String errorMessage, java.lang.String stackTrace, java.lang.String statusCode, int statusCodeInt, java.lang.String receiveTime, java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders) Reply.
private void	replyErrors(java.lang.String errorMessage, java.lang.String stackTrace, java.lang.String statusCode, int statusCodeInt) Reply used in error cases.

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

client

private final com.ning.http.client.AsyncHttpClient client

The client.

logger

private static org.slf4j.Logger logger

The logger.

pollingErrorCount

private int pollingErrorCount

The polling error count.

request

private final TaskRequest request

The request.

response

private ResponseOnSingleTask response

The response.

asyncWorker

private akka.actor.ActorRef asyncWorker

The async worker.

sender

private akka.actor.ActorRef sender

The sender.

timeoutMessageCancellable

private akka.actor.Cancellable timeoutMessageCancellable

The timeout message cancellable.

pollMessageCancellable

private akka.actor.Cancellable pollMessageCancellable

The poll message cancellable.

timeoutDuration

private scala.concurrent.duration.FiniteDuration timeoutDuration

The timeout duration.

actorMaxOperationTimeoutSec

private int actorMaxOperationTimeoutSec

The actor max operation timeout sec.

startTimeMillis

private long startTimeMillis

The start time millis.

sentReply

private boolean sentReply

The sent reply.

trueTargetNode

private java.lang.String trueTargetNode

The true target node.

pollerData

private PollerData pollerData

Http Poller.

httpPollerProcessor

private HttpPollerProcessor httpPollerProcessor

The http poller processor.

Constructor Detail

OperationWorker

public OperationWorker(TaskRequest request,
                       com.ning.http.client.AsyncHttpClient client,
                       HttpPollerProcessor httpPollerProcessor)

Instantiates a new operation worker.

Parameters:

request - the request

client - the client

httpPollerProcessor - the http poller processor

Method Detail

onReceive

public void onReceive(java.lang.Object message)
               throws java.lang.Exception

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception

pollProgress

private final void pollProgress()

Poller.

handleHttpWorkerResponse

private final void handleHttpWorkerResponse(ResponseOnSingeRequest respOnSingleReq)
                                     throws java.lang.Exception

Handle http worker response.

Parameters:

respOnSingleReq - the my response

Throws:

java.lang.Exception - the exception

processMainRequest

private final void processMainRequest()

the 1st request from the manager.

cancelExistingIfAnyAndScheduleTimeoutCall

private void cancelExistingIfAnyAndScheduleTimeoutCall()

201412: now consider the poller. With poller, will cancel this future task and reschedule

operationTimeout

private final void operationTimeout()

will trigger workers to cancel then wait for it to report back.

cancel

private final void cancel()

Cancel.

cancelCancellable

private final void cancelCancellable()

Cancel cancellable.

replyErrors

private final void replyErrors(java.lang.String errorMessage,
                               java.lang.String stackTrace,
                               java.lang.String statusCode,
                               int statusCodeInt)

Reply used in error cases. set the response header as null.

Parameters:

errorMessage - the error message

stackTrace - the stack trace

statusCode - the status code

statusCodeInt - the status code int

reply

private final void reply(boolean error,
                         java.lang.String errorMessage,
                         java.lang.String stackTrace,
                         java.lang.String statusCode,
                         int statusCodeInt,
                         java.lang.String receiveTime,
                         java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders)

Reply.

Parameters:

error - the error

errorMessage - the error message

stackTrace - the stack trace

statusCode - the status code

statusCodeInt - the status code int

receiveTime - the receive time

responseHeaders - the response headers