Package io.grpc.internal

Class ManagedChannelOrphanWrapper

java.lang.Object

io.grpc.Channel

io.grpc.ManagedChannel

io.grpc.internal.ForwardingManagedChannel

io.grpc.internal.ManagedChannelOrphanWrapper

final class ManagedChannelOrphanWrapper
extends ForwardingManagedChannel

Best effort detecting channels that has not been properly cleaned up. Use WeakReference to avoid keeping the channel alive and retaining too much memory. Check lost references only on new channel creation and log message to indicate the previous channel (id and target) that has not been shutdown. This is done to avoid Object finalizers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ManagedChannelOrphanWrapper.ManagedChannelReference

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	logger
private final ManagedChannelOrphanWrapper.ManagedChannelReference	phantom
private static final ReferenceQueue<ManagedChannelOrphanWrapper>	refqueue
private static final ConcurrentMap<ManagedChannelOrphanWrapper.ManagedChannelReference,ManagedChannelOrphanWrapper.ManagedChannelReference>	refs

Constructor Summary

Constructors

Constructor	Description
ManagedChannelOrphanWrapper(ManagedChannel delegate)
ManagedChannelOrphanWrapper(ManagedChannel delegate, ReferenceQueue<ManagedChannelOrphanWrapper> refqueue, ConcurrentMap<ManagedChannelOrphanWrapper.ManagedChannelReference,ManagedChannelOrphanWrapper.ManagedChannelReference> refs)

Method Summary

Modifier and Type	Method	Description
ManagedChannel	shutdown()	Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately cancelled.
ManagedChannel	shutdownNow()	Initiates a forceful shutdown in which preexisting and new calls are cancelled.

Methods inherited from class io.grpc.internal.ForwardingManagedChannel

authority, awaitTermination, enterIdle, getState, isShutdown, isTerminated, newCall, notifyWhenStateChanged, resetConnectBackoff, toString

Methods inherited from class java.lang.Object

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

Field Details

refqueue

private static final ReferenceQueue<ManagedChannelOrphanWrapper> refqueue

refs

private static final ConcurrentMap<ManagedChannelOrphanWrapper.ManagedChannelReference,ManagedChannelOrphanWrapper.ManagedChannelReference> refs

logger

private static final Logger logger

phantom

private final ManagedChannelOrphanWrapper.ManagedChannelReference phantom

Constructor Details

ManagedChannelOrphanWrapper

ManagedChannelOrphanWrapper(ManagedChannel delegate)

ManagedChannelOrphanWrapper

ManagedChannelOrphanWrapper(ManagedChannel delegate,
 ReferenceQueue<ManagedChannelOrphanWrapper> refqueue,
 ConcurrentMap<ManagedChannelOrphanWrapper.ManagedChannelReference,ManagedChannelOrphanWrapper.ManagedChannelReference> refs)

Method Details

shutdown

public ManagedChannel shutdown()

Description copied from class: ManagedChannel

Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately cancelled.

Overrides:

shutdown in class ForwardingManagedChannel

Returns:

this

shutdownNow

public ManagedChannel shutdownNow()

Description copied from class: ManagedChannel

Initiates a forceful shutdown in which preexisting and new calls are cancelled. Although forceful, the shutdown process is still not instantaneous; ManagedChannel.isTerminated() will likely return false immediately after this method returns.

Overrides:

shutdownNow in class ForwardingManagedChannel

Returns:

this