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

HBASE-5026 Add coprocessor hook to HRegionServer.ScannerListener.leaseExpired() 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1214431 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2011-12-14 19:57:42 +00:00
parent bade2361c9
commit e85d2d45d3
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -456,6 +456,7 @@ Release 0.92.0 - Unreleased
HBASE-4610 Port HBASE-3380 (Master failover can split logs of live servers) to 92/trunk
HBASE-4946 HTable.coprocessorExec (and possibly coprocessorProxy) does not work with
dynamically loaded coprocessors (Andrei Dragomir)
HBASE-5026 Add coprocessor hook to HRegionServer.ScannerListener.leaseExpired()
TESTS
HBASE-4450 test for number of blocks read: to serve as baseline for expected

11
src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
View File

@ -2421,9 +2421,18 @@ public class HRegionServer implements HRegionInterface, HBaseRPCErrorHandler,
RegionScanner s = scanners.remove(this.scannerName);
if (s != null) {
try {
HRegion region = getRegion(s.getRegionInfo().getRegionName());
if (region != null && region.getCoprocessorHost() != null) {
region.getCoprocessorHost().preScannerClose(s);
}
s.close();
if (region != null && region.getCoprocessorHost() != null) {
region.getCoprocessorHost().postScannerClose(s);
}
} catch (IOException e) {
LOG.error("Closing scanner", e);
LOG.error("Closing scanner for "
+ s.getRegionInfo().getRegionNameAsString(), e);
}
}
}