Package io.grpc.internal

Class ManagedChannelOrphanWrapper.ManagedChannelReference

java.lang.Object

java.lang.ref.Reference<ManagedChannelOrphanWrapper>

java.lang.ref.WeakReference<ManagedChannelOrphanWrapper>

io.grpc.internal.ManagedChannelOrphanWrapper.ManagedChannelReference

Enclosing class:

ManagedChannelOrphanWrapper

static final class ManagedChannelOrphanWrapper.ManagedChannelReference
extends WeakReference<ManagedChannelOrphanWrapper>

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	ALLOCATION_SITE_PROPERTY_NAME
private final Reference<RuntimeException>	allocationSite
private final String	channelStr
private static final boolean	ENABLE_ALLOCATION_TRACKING
private static final RuntimeException	missingCallSite
private final ReferenceQueue<ManagedChannelOrphanWrapper>	refqueue
private final ConcurrentMap<ManagedChannelOrphanWrapper.ManagedChannelReference,ManagedChannelOrphanWrapper.ManagedChannelReference>	refs
private final AtomicBoolean	shutdown

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) static int	cleanQueue(ReferenceQueue<ManagedChannelOrphanWrapper> refqueue)
void	clear()	This clear() is *not* called automatically by the JVM.
private void	clearInternal()
private void	clearSafely()	Safe to call concurrently.
private static RuntimeException	missingCallSite()

Methods inherited from class java.lang.ref.Reference

enqueue, get, isEnqueued

Methods inherited from class java.lang.Object

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

Field Details

ALLOCATION_SITE_PROPERTY_NAME

private static final String ALLOCATION_SITE_PROPERTY_NAME

See Also:

• Constant Field Values

ENABLE_ALLOCATION_TRACKING

private static final boolean ENABLE_ALLOCATION_TRACKING

missingCallSite

private static final RuntimeException missingCallSite

refqueue

private final ReferenceQueue<ManagedChannelOrphanWrapper> refqueue

refs

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

channelStr

private final String channelStr

allocationSite

private final Reference<RuntimeException> allocationSite

shutdown

private final AtomicBoolean shutdown

Constructor Details

ManagedChannelReference

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

Method Details

clear

public void clear()

This clear() is *not* called automatically by the JVM. As this is a weak ref, the reference will be cleared automatically by the JVM, but will not be removed from refs. We do it here to avoid this ending up on the reference queue.

Overrides:

clear in class Reference<ManagedChannelOrphanWrapper>

clearSafely

private void clearSafely()

Safe to call concurrently.

clearInternal

private void clearInternal()

missingCallSite

private static RuntimeException missingCallSite()

cleanQueue

static int cleanQueue(ReferenceQueue<ManagedChannelOrphanWrapper> refqueue)