Package io.grpc.internal

Class ManagedChannelImpl.UncommittedRetriableStreamsRegistry

java.lang.Object

io.grpc.internal.ManagedChannelImpl.UncommittedRetriableStreamsRegistry

Enclosing class:

ManagedChannelImpl

private final class ManagedChannelImpl.UncommittedRetriableStreamsRegistry
extends java.lang.Object

A registry that prevents channel shutdown from killing existing retry attempts that are in backoff.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) java.lang.Object	lock
(package private) Status	shutdownStatus
(package private) java.util.Collection<ClientStream>	uncommittedRetriableStreams

Constructor Summary

Constructors

Modifier	Constructor	Description
private	UncommittedRetriableStreamsRegistry()

Method Summary

Modifier and Type	Method	Description
(package private) Status	add(RetriableStream<?> retriableStream)	Registers a RetriableStream and return null if not shutdown, otherwise just returns the shutdown Status.
(package private) void	onShutdown(Status reason)
(package private) void	onShutdownNow(Status reason)
(package private) void	remove(RetriableStream<?> retriableStream)

Methods inherited from class java.lang.Object

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

Field Detail

lock

final java.lang.Object lock

uncommittedRetriableStreams

java.util.Collection<ClientStream> uncommittedRetriableStreams

shutdownStatus

Status shutdownStatus

Constructor Detail

UncommittedRetriableStreamsRegistry

private UncommittedRetriableStreamsRegistry()

Method Detail

onShutdown

void onShutdown(Status reason)

onShutdownNow

void onShutdownNow(Status reason)

add

@Nullable
Status add(RetriableStream<?> retriableStream)

Registers a RetriableStream and return null if not shutdown, otherwise just returns the shutdown Status.

remove

void remove(RetriableStream<?> retriableStream)