Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-10117 Avoid synchronization in HRegionScannerImpl.isFilterDone 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1549920 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
larsh 2013-12-10 18:24:35 +00:00
parent e7c1acfecc
commit 4b89daa019
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
View File

@ -3526,7 +3526,7 @@ public class HRegion implements HeapSize { // , Writable{
// KeyValue indicating that limit is reached when scanning // KeyValue indicating that limit is reached when scanning
private final KeyValue KV_LIMIT = new KeyValue(); private final KeyValue KV_LIMIT = new KeyValue();
protected final byte[] stopRow; protected final byte[] stopRow;
private Filter filter; private final Filter filter;
private int batch; private int batch;
protected int isScan; protected int isScan;
private boolean filterClosed = false; private boolean filterClosed = false;
@ -3666,7 +3666,7 @@ public class HRegion implements HeapSize { // , Writable{
outResults.addAll(tmpList); outResults.addAll(tmpList);
} }
resetFilters(); resetFilters();
if (isFilterDone()) { if (isFilterDoneInternal()) {
return false; return false;
} }
if (region != null && region.metricsRegion != null) { if (region != null && region.metricsRegion != null) {
@ -3726,6 +3726,10 @@ public class HRegion implements HeapSize { // , Writable{
*/ */
@Override @Override
public synchronized boolean isFilterDone() throws IOException { public synchronized boolean isFilterDone() throws IOException {
return isFilterDoneInternal();
}
private boolean isFilterDoneInternal() throws IOException {
return this.filter != null && this.filter.filterAllRemaining(); return this.filter != null && this.filter.filterAllRemaining();
} }