org.apache.hadoop.hbase.nio

Class RefCnt

java.lang.Object

org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

org.apache.hadoop.hbase.nio.RefCnt

All Implemented Interfaces:

org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

@InterfaceAudience.Private
public class RefCnt
extends org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

Maintain an reference count integer inside to track life cycle of ByteBuff, if the reference count become 0, it'll call ByteBuffAllocator.Recycler.free() exactly once.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hbase.thirdparty.io.netty.util.ResourceLeakDetector<RefCnt>	detector
private org.apache.hbase.thirdparty.io.netty.util.ResourceLeakTracker<RefCnt>	leak
private ByteBuffAllocator.Recycler	recycler

Constructor Summary

Constructors

Constructor and Description
RefCnt(ByteBuffAllocator.Recycler recycler)

Method Summary

Modifier and Type	Method and Description
static RefCnt	create() Create an RefCnt with an initial reference count = 1.
static RefCnt	create(ByteBuffAllocator.Recycler recycler)
protected void	deallocate()
ByteBuffAllocator.Recycler	getRecycler()
private void	maybeRecord()
private void	maybeRecord(Object hint)
boolean	release()
boolean	release(int decrement)
org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted	retain()
org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted	retain(int increment)
RefCnt	touch()
org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted	touch(Object hint)

Methods inherited from class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

refCnt, setRefCnt

Methods inherited from class java.lang.Object

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

Field Detail

detector

private static final org.apache.hbase.thirdparty.io.netty.util.ResourceLeakDetector<RefCnt> detector

recycler

private final ByteBuffAllocator.Recycler recycler

leak

private final org.apache.hbase.thirdparty.io.netty.util.ResourceLeakTracker<RefCnt> leak

Constructor Detail

RefCnt

public RefCnt(ByteBuffAllocator.Recycler recycler)

Method Detail

create

public static RefCnt create()

Create an RefCnt with an initial reference count = 1. If the reference count become zero, the recycler will do nothing. Usually, an Heap ByteBuff will use this kind of refCnt to track its life cycle, it help to abstract the code path although it's not really needed to track on heap ByteBuff.

create

public static RefCnt create(ByteBuffAllocator.Recycler recycler)

retain

public org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted retain()

Specified by:

retain in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

Overrides:

retain in class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

retain

public org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted retain(int increment)

Specified by:

retain in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

Overrides:

retain in class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

release

public boolean release()

Specified by:

release in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

Overrides:

release in class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

release

public boolean release(int decrement)

Specified by:

release in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

Overrides:

release in class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

deallocate

protected final void deallocate()

Specified by:

deallocate in class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

touch

public RefCnt touch()

Specified by:

touch in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

Overrides:

touch in class org.apache.hbase.thirdparty.io.netty.util.AbstractReferenceCounted

touch

public final org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted touch(Object hint)

getRecycler

public ByteBuffAllocator.Recycler getRecycler()

maybeRecord

private void maybeRecord()

maybeRecord

private void maybeRecord(Object hint)