org.apache.hadoop.hbase.monitoring

Class TaskMonitor.TaskAndWeakRefPair

java.lang.Object

org.apache.hadoop.hbase.monitoring.TaskMonitor.TaskAndWeakRefPair

Enclosing class:

TaskMonitor

private static class TaskMonitor.TaskAndWeakRefPair
extends Object

This class encapsulates an object as well as a weak reference to a proxy that passes through calls to that object. In art form:

     Proxy  <------------------
       |                       \
       v                        \
 PassthroughInvocationHandler   |  weak reference
       |                       /
 MonitoredTaskImpl            /
       |                     /
 StatAndWeakRefProxy  ------/
 

Since we only return the Proxy to the creator of the MonitorableStatus, this means that they can leak that object, and we'll detect it since our weak reference will go null. But, we still have the actual object, so we can log it and display it as a leaked (incomplete) action.

Field Summary

Fields

Modifier and Type	Field and Description
private MonitoredTask	impl
private WeakReference<MonitoredTask>	weakProxy

Constructor Summary

Constructors

Constructor and Description
TaskAndWeakRefPair(MonitoredTask stat, MonitoredTask proxy)

Method Summary

Modifier and Type	Method and Description
MonitoredTask	get()
boolean	isDead()

Methods inherited from class java.lang.Object

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

Field Detail

impl

private MonitoredTask impl

weakProxy

private WeakReference<MonitoredTask> weakProxy

Constructor Detail

TaskAndWeakRefPair

public TaskAndWeakRefPair(MonitoredTask stat,
                          MonitoredTask proxy)

Method Detail

get

public MonitoredTask get()

isDead

public boolean isDead()