andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Also record retain() and release()

Browse Source
This commit is contained in:
Trustin Lee 2013-12-06 13:44:59 +09:00
parent 6554b8c395
commit d21568b962
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
buffer/src/main/java/io/netty/buffer/AdvancedLeakAwareByteBuf.java
View File

@ -671,11 +671,25 @@ final class AdvancedLeakAwareByteBuf extends WrappedByteBuf {
return super.toString(index, length, charset); return super.toString(index, length, charset);
} }
@Override
public ByteBuf retain() {
leak.record();
return super.retain();
}
@Override
public ByteBuf retain(int increment) {
leak.record();
return super.retain(increment);
}
@Override @Override
public boolean release() { public boolean release() {
boolean deallocated = super.release(); boolean deallocated = super.release();
if (deallocated) { if (deallocated) {
leak.close(); leak.close();
} else{
leak.record();
} }
return deallocated; return deallocated;
} }
@ -685,6 +699,8 @@ final class AdvancedLeakAwareByteBuf extends WrappedByteBuf {
boolean deallocated = super.release(decrement); boolean deallocated = super.release(decrement);
if (deallocated) { if (deallocated) {
leak.close(); leak.close();
} else {
leak.record();
} }
return deallocated; return deallocated;
} }