Package 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	Description
private MonitoredTask	impl
private WeakReference<MonitoredTask>	weakProxy

Constructor Summary

Constructors

Constructor	Description
TaskAndWeakRefPair(MonitoredTask stat, MonitoredTask proxy)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

impl

private MonitoredTask impl

weakProxy

private WeakReference<MonitoredTask> weakProxy

Constructor Details

TaskAndWeakRefPair

public TaskAndWeakRefPair(MonitoredTask stat,
 MonitoredTask proxy)

Method Details

get

public MonitoredTask get()

isDead

public boolean isDead()