Package org.apache.hadoop.ozone.container.replication

Class GrpcContainerUploader.WrappedRequestStreamObserver<T>

java.lang.Object

org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

org.apache.hadoop.ozone.container.replication.GrpcContainerUploader.WrappedRequestStreamObserver<T>

All Implemented Interfaces:

org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<T>

Enclosing class:

GrpcContainerUploader

public static class GrpcContainerUploader.WrappedRequestStreamObserver<T>
extends org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

this class wrap the request stream observer and handle error reported by ratis to response handler.

Constructor Summary

Constructors

Constructor	Description
WrappedRequestStreamObserver(org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver observer, GrpcContainerUploader.SendContainerResponseStreamObserver responseObserver)

Method Summary

Modifier and Type	Method	Description
void	disableAutoInboundFlowControl()
boolean	isReady()
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(T sendContainerResponse)
void	request(int i)
void	setMessageCompression(boolean b)
void	setOnReadyHandler(Runnable runnable)

Methods inherited from class java.lang.Object

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

Constructor Details

WrappedRequestStreamObserver

public WrappedRequestStreamObserver(org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver observer,
 GrpcContainerUploader.SendContainerResponseStreamObserver responseObserver)

Method Details

isReady

public boolean isReady()

Specified by:

isReady in class org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

setOnReadyHandler

public void setOnReadyHandler(Runnable runnable)

Specified by:

setOnReadyHandler in class org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

disableAutoInboundFlowControl

public void disableAutoInboundFlowControl()

Specified by:

disableAutoInboundFlowControl in class org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

request

public void request(int i)

Specified by:

request in class org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

setMessageCompression

public void setMessageCompression(boolean b)

Specified by:

setMessageCompression in class org.apache.ratis.thirdparty.io.grpc.stub.CallStreamObserver<T>

onNext

public void onNext(T sendContainerResponse)

onError

public void onError(Throwable throwable)

onCompleted

public void onCompleted()