Repository: drill Updated Branches: refs/heads/master 04c01bded -> e78e28661
Add synchronization to DrillBuf.retain() to avoid contention issues. Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/e78e2866 Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/e78e2866 Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/e78e2866 Branch: refs/heads/master Commit: e78e28661e921c6bd07ba7bb95d91f9adeb5a247 Parents: 9826215 Author: Jacques Nadeau <[email protected]> Authored: Fri Nov 6 19:09:19 2015 -0800 Committer: Jacques Nadeau <[email protected]> Committed: Fri Nov 6 21:41:07 2015 -0800 ---------------------------------------------------------------------- exec/java-exec/src/main/java/io/netty/buffer/DrillBuf.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/drill/blob/e78e2866/exec/java-exec/src/main/java/io/netty/buffer/DrillBuf.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/io/netty/buffer/DrillBuf.java b/exec/java-exec/src/main/java/io/netty/buffer/DrillBuf.java index 3ec6b3e..5e437b2 100644 --- a/exec/java-exec/src/main/java/io/netty/buffer/DrillBuf.java +++ b/exec/java-exec/src/main/java/io/netty/buffer/DrillBuf.java @@ -445,7 +445,7 @@ public final class DrillBuf extends AbstractByteBuf implements AutoCloseable { } @Override - public ByteBuf retain(int increment) { + public synchronized ByteBuf retain(int increment) { if(rootBuffer){ this.rootRefCnt.addAndGet(increment); }else{
