Class CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport

java.lang.Object

io.grpc.internal.ForwardingConnectionClientTransport

io.grpc.internal.CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport

All Implemented Interfaces:

ClientTransport, ConnectionClientTransport, ManagedClientTransport, InternalInstrumented<InternalChannelz.SocketStats>, InternalWithLogId

Enclosing class:

CallCredentialsApplyingTransportFactory

private class CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport
extends ForwardingConnectionClientTransport

Nested Class Summary

Nested classes/interfaces inherited from interface ClientTransport

ClientTransport.PingCallback

Nested classes/interfaces inherited from interface ManagedClientTransport

ManagedClientTransport.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private final MetadataApplierImpl.MetadataApplierListener	applierListener
private final String	authority
private final ConnectionClientTransport	delegate
private final AtomicInteger	pendingApplier
private Status	savedShutdownNowStatus
private Status	savedShutdownStatus
private Status	shutdownStatus

Constructor Summary

Constructors

Constructor	Description
CallCredentialsApplyingTransport(ConnectionClientTransport delegate, String authority)

Method Summary

Modifier and Type	Method	Description
protected ConnectionClientTransport	delegate()
private void	maybeShutdown()
ClientStream	newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)	Creates a new stream for sending messages to a remote end-point.
void	shutdown(Status status)	Initiates an orderly shutdown of the transport.
void	shutdownNow(Status status)	Initiates a forceful shutdown in which preexisting and new calls are closed.

Methods inherited from class ForwardingConnectionClientTransport

getAttributes, getLogId, getStats, ping, start, toString

Methods inherited from class Object

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

Field Details

delegate

private final ConnectionClientTransport delegate

authority

private final String authority

pendingApplier

private final AtomicInteger pendingApplier

shutdownStatus

private volatile Status shutdownStatus

savedShutdownStatus

private Status savedShutdownStatus

savedShutdownNowStatus

private Status savedShutdownNowStatus

applierListener

private final MetadataApplierImpl.MetadataApplierListener applierListener

Constructor Details

CallCredentialsApplyingTransport

CallCredentialsApplyingTransport(ConnectionClientTransport delegate,
 String authority)

Method Details

delegate

protected ConnectionClientTransport delegate()

Specified by:

delegate in class ForwardingConnectionClientTransport

newStream

public ClientStream newStream(MethodDescriptor<?,?> method,
 Metadata headers,
 CallOptions callOptions,
 ClientStreamTracer[] tracers)

Description copied from interface: ClientTransport

Creates a new stream for sending messages to a remote end-point.

This method returns immediately and does not wait for any validation of the request. If creation fails for any reason, ClientStreamListener.closed(Status, ClientStreamListener.RpcProgress, Metadata) will be called to provide the error information. Any sent messages for this stream will be buffered until creation has completed (either successfully or unsuccessfully).

This method is called under the Context of the ClientCall.

Specified by:

newStream in interface ClientTransport

Overrides:

newStream in class ForwardingConnectionClientTransport

Parameters:

method - the descriptor of the remote method to be called for this stream.

headers - to send at the beginning of the call

callOptions - runtime options of the call

tracers - a non-empty array of tracers. The last element in it is reserved to be set by the load balancer's pick result and otherwise is a no-op tracer.

Returns:

the newly created stream.

shutdown

public void shutdown(Status status)

Description copied from interface: ManagedClientTransport

Initiates an orderly shutdown of the transport. Existing streams continue, but the transport will not own any new streams. New streams will either fail (once ManagedClientTransport.Listener.transportShutdown(Status) callback called), or be transferred off this transport (in which case they may succeed). This method may only be called once.

Specified by:

shutdown in interface ManagedClientTransport

Overrides:

shutdown in class ForwardingConnectionClientTransport

shutdownNow

public void shutdownNow(Status status)

Description copied from interface: ManagedClientTransport

Initiates a forceful shutdown in which preexisting and new calls are closed. Existing calls should be closed with the provided reason.

Specified by:

shutdownNow in interface ManagedClientTransport

Overrides:

shutdownNow in class ForwardingConnectionClientTransport

maybeShutdown

private void maybeShutdown()