Package com.linkedin.alpini.router

Class ScatterGatherRequestHandlerImpl<H,P extends ResourcePath<K>,K,R,CHC,BHS extends BasicRequest,HR,HRS extends io.netty.handler.codec.http.HttpResponseStatus,SCATTER_GATHER_HELPER extends ScatterGatherHelper<H,P,K,R,BHS,HR,HRS>>

java.lang.Object

com.linkedin.alpini.router.ScatterGatherRequestHandler<H,P,K,R>

com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl<H,P,K,R,CHC,BHS,HR,HRS,SCATTER_GATHER_HELPER>

Direct Known Subclasses:

ScatterGatherRequestHandler4

public abstract class ScatterGatherRequestHandlerImpl<H,P extends ResourcePath<K>,K,R,CHC,BHS extends BasicRequest,HR,HRS extends io.netty.handler.codec.http.HttpResponseStatus,SCATTER_GATHER_HELPER extends ScatterGatherHelper<H,P,K,R,BHS,HR,HRS>>
extends ScatterGatherRequestHandler<H,P,K,R>

Field Summary

Fields inherited from class com.linkedin.alpini.router.ScatterGatherRequestHandler

_timeoutProcessor, LOG, NOP

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ScatterGatherRequestHandlerImpl(SCATTER_GATHER_HELPER scatterGatherHelper, TimeoutProcessor timeoutProcessor)
protected	ScatterGatherRequestHandlerImpl(SCATTER_GATHER_HELPER scatterGatherHelper, RouterTimeoutProcessor timeoutProcessor)

Method Summary

Modifier and Type	Method	Description
protected void	appendError(BHS request, List<HR> responses, HRS status, String contentMessage, Throwable ex)
protected CompletionStage<?>	appendErrorForEveryKey(BHS request, List<HR> responses, HRS status, String contentMessage, Throwable ex, ResourcePathParser<P,K> pathParser, ScatterGatherRequest<H,K> part, P basePath)
protected void	appendErrorsForOfflinePartitions(BHS request, Scatter<H,P,K> scatter, List<AsyncFuture<List<HR>>> responseFutures)
protected abstract HRS	badRequest()
protected abstract HR	buildErrorResponse(BHS request, HRS status, String contentMessage, Throwable ex)
protected HR	buildExceptionResponse(BHS request, Throwable cause)
protected abstract HR	buildResponse(BHS request, Metrics metrics, List<HR> gatheredResponses)
protected final void	dispatch(Scatter<H,P,K> scatter, ScatterGatherRequest<H,K> part, P path, BHS request, AsyncPromise<H> hostSelected, AsyncPromise<List<HR>> responseFuture, AsyncPromise<HRS> retryFuture, AsyncFuture<Void> timeoutFuture, Executor contextExecutor)
protected abstract Executor	executor(CHC ctx)
protected abstract HRS	gatewayTimeout()
protected abstract String	getReasonPhrase(HRS status)
protected abstract int	getResponseCode(HR response)
protected abstract Headers	getResponseHeaders(HR response)
protected abstract int	getResponseReadable(HR response)
final SCATTER_GATHER_HELPER	getScatterGatherHelper()
protected AsyncFuture<HR>	handler(CHC ctx, BHS request)
protected abstract boolean	hasErrorInStorageNodeResponse(HR response)
protected void	incrementTotalRetries(ScatterGatherStats.Delta stats)
protected void	incrementTotalRetriesError(ScatterGatherStats.Delta stats)
protected void	incrementTotalRetriesWinner(ScatterGatherStats.Delta stats)
protected abstract HRS	internalServerError()
protected boolean	isLastAttempt(HRS status)
protected abstract boolean	isRequestRetriable(P path, R role, HRS status)
protected abstract boolean	isSuccessStatus(HRS status)
protected abstract boolean	isTooLongFrameException(Throwable cause)
protected abstract HRS	multiStatus()
protected BHS	prepareRequest(BHS value)
protected AsyncFutureListener<HRS>	prepareRetry(AsyncFuture<H> hostFuture, P path, BHS requestRef, R role, AsyncPromise<List<HR>> responseFuture, AsyncFuture<Void> timeoutFuture, Executor contextExecutor, HostHealthMonitor<H> hostHealthMonitor, ScatterGatherStats.Delta stats, Metrics m)
protected boolean	releaseRequest(BHS value)
protected boolean	releaseResponse(HR value)
protected BHS	retainRequest(BHS value)
protected abstract HRS	serviceUnavailable()
protected abstract void	setKeepAlive(HR response, boolean keepAlive)
static void	setMetric(Metrics metric, MetricNames metricName, long value)
protected abstract HRS	statusOf(int code)
protected abstract Runnable	timeout(CHC ctx, Runnable task)
protected Runnable	timeout(CHC ctx, String msg, AsyncPromise<Void> timeoutFuture)
protected <T> Runnable	timeout(CHC ctx, String msg, AsyncPromise<T> timeoutFuture, T value)
protected static Throwable	unwrapCompletion(Throwable ex)

Methods inherited from class com.linkedin.alpini.router.ScatterGatherRequestHandler

make, make

Methods inherited from class java.lang.Object

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

Constructor Details

ScatterGatherRequestHandlerImpl

protected ScatterGatherRequestHandlerImpl(@Nonnull
 SCATTER_GATHER_HELPER scatterGatherHelper,
 @Nonnull
 TimeoutProcessor timeoutProcessor)

ScatterGatherRequestHandlerImpl

protected ScatterGatherRequestHandlerImpl(@Nonnull
 SCATTER_GATHER_HELPER scatterGatherHelper,
 @Nonnull
 RouterTimeoutProcessor timeoutProcessor)

Method Details

getScatterGatherHelper

@Nonnull
public final SCATTER_GATHER_HELPER getScatterGatherHelper()

Specified by:

getScatterGatherHelper in class ScatterGatherRequestHandler<H,P extends ResourcePath<K>,K,R>

setMetric

public static void setMetric(Metrics metric,
 @Nonnull
 MetricNames metricName,
 long value)

timeout

protected abstract Runnable timeout(CHC ctx,
 Runnable task)

timeout

protected Runnable timeout(CHC ctx,
 String msg,
 AsyncPromise<Void> timeoutFuture)

timeout

protected <T> Runnable timeout(CHC ctx,
 String msg,
 AsyncPromise<T> timeoutFuture,
 T value)

executor

protected abstract Executor executor(CHC ctx)

handler

@Nonnull
protected AsyncFuture<HR> handler(@Nonnull
 CHC ctx,
 @Nonnull
 BHS request)
                           throws Exception

Throws:

Exception

unwrapCompletion

protected static Throwable unwrapCompletion(Throwable ex)

statusOf

protected abstract HRS statusOf(int code)

multiStatus

protected abstract HRS multiStatus()

badRequest

protected abstract HRS badRequest()

gatewayTimeout

protected abstract HRS gatewayTimeout()

serviceUnavailable

protected abstract HRS serviceUnavailable()

internalServerError

protected abstract HRS internalServerError()

isSuccessStatus

protected abstract boolean isSuccessStatus(HRS status)

isRequestRetriable

protected abstract boolean isRequestRetriable(P path,
 R role,
 HRS status)

getReasonPhrase

protected abstract String getReasonPhrase(HRS status)

prepareRequest

@Nonnull
protected BHS prepareRequest(@Nonnull
 BHS value)

retainRequest

@Nonnull
protected BHS retainRequest(@Nonnull
 BHS value)

releaseRequest

protected boolean releaseRequest(BHS value)

releaseResponse

protected boolean releaseResponse(HR value)

isLastAttempt

protected boolean isLastAttempt(HRS status)

prepareRetry

@Nonnull
protected AsyncFutureListener<HRS> prepareRetry(@Nonnull
 AsyncFuture<H> hostFuture,
 @Nonnull
 P path,
 @Nonnull
 BHS requestRef,
 @Nonnull
 R role,
 @Nonnull
 AsyncPromise<List<HR>> responseFuture,
 @Nonnull
 AsyncFuture<Void> timeoutFuture,
 @Nonnull
 Executor contextExecutor,
 @Nonnull
 HostHealthMonitor<H> hostHealthMonitor,
 @Nonnull
 ScatterGatherStats.Delta stats,
 Metrics m)

incrementTotalRetries

protected void incrementTotalRetries(ScatterGatherStats.Delta stats)

incrementTotalRetriesError

protected void incrementTotalRetriesError(ScatterGatherStats.Delta stats)

incrementTotalRetriesWinner

protected void incrementTotalRetriesWinner(ScatterGatherStats.Delta stats)

getResponseCode

protected abstract int getResponseCode(HR response)

getResponseReadable

protected abstract int getResponseReadable(HR response)

hasErrorInStorageNodeResponse

protected abstract boolean hasErrorInStorageNodeResponse(HR response)

getResponseHeaders

protected abstract Headers getResponseHeaders(HR response)

setKeepAlive

protected abstract void setKeepAlive(HR response,
 boolean keepAlive)

buildResponse

@Nonnull
protected abstract HR buildResponse(@Nonnull
 BHS request,
 Metrics metrics,
 @Nonnull
 List<HR> gatheredResponses)

appendErrorsForOfflinePartitions

protected void appendErrorsForOfflinePartitions(@Nonnull
 BHS request,
 @Nonnull
 Scatter<H,P,K> scatter,
 @Nonnull
 List<AsyncFuture<List<HR>>> responseFutures)

appendErrorForEveryKey

protected CompletionStage<?> appendErrorForEveryKey(@Nonnull
 BHS request,
 @Nonnull
 List<HR> responses,
 @Nonnull
 HRS status,
 String contentMessage,
 Throwable ex,
 @Nonnull
 ResourcePathParser<P,K> pathParser,
 @Nonnull
 ScatterGatherRequest<H,K> part,
 @Nonnull
 P basePath)

appendError

protected void appendError(@Nonnull
 BHS request,
 @Nonnull
 List<HR> responses,
 @Nonnull
 HRS status,
 String contentMessage,
 Throwable ex)

isTooLongFrameException

protected abstract boolean isTooLongFrameException(Throwable cause)

Specified by:

isTooLongFrameException in class ScatterGatherRequestHandler<H,P extends ResourcePath<K>,K,R>

buildExceptionResponse

@Nonnull
protected HR buildExceptionResponse(@Nonnull
 BHS request,
 @Nonnull
 Throwable cause)

buildErrorResponse

@Nonnull
protected abstract HR buildErrorResponse(@Nonnull
 BHS request,
 @Nonnull
 HRS status,
 String contentMessage,
 Throwable ex)

dispatch

protected final void dispatch(@Nonnull
 Scatter<H,P,K> scatter,
 @Nonnull
 ScatterGatherRequest<H,K> part,
 @Nonnull
 P path,
 @Nonnull
 BHS request,
 @Nonnull
 AsyncPromise<H> hostSelected,
 @Nonnull
 AsyncPromise<List<HR>> responseFuture,
 @Nonnull
 AsyncPromise<HRS> retryFuture,
 @Nonnull
 AsyncFuture<Void> timeoutFuture,
 @Nonnull
 Executor contextExecutor)