Package io.grpc.internal

Class ManagedChannelImpl.UncommittedRetriableStreamsRegistry

java.lang.Object

io.grpc.internal.ManagedChannelImpl.UncommittedRetriableStreamsRegistry

Enclosing class:

ManagedChannelImpl

private final class ManagedChannelImpl.UncommittedRetriableStreamsRegistry
extends 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) final Object	lock
(package private) Status	shutdownStatus
(package private) 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 Details

lock

final Object lock

uncommittedRetriableStreams

Collection<ClientStream> uncommittedRetriableStreams

shutdownStatus

Status shutdownStatus

Constructor Details

UncommittedRetriableStreamsRegistry

private UncommittedRetriableStreamsRegistry()

Method Details

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)