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
All Methods Instance Methods Concrete Methods 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)
-
-
-
Field Detail
-
lock
final java.lang.Object lock
-
uncommittedRetriableStreams
java.util.Collection<ClientStream> uncommittedRetriableStreams
-
shutdownStatus
Status shutdownStatus
-
-
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)
-
-