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

HBASE-10745 Access ShutdownHook#fsShutdownHooks should be synchronized 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1577588 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
jxiang 2014-03-14 15:56:43 +00:00
parent 47e3864ee0
commit 221bd54ba2
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ShutdownHook.java
View File

@ -198,12 +198,12 @@ public class ShutdownHook {
if (hdfsClientFinalizer == null) { if (hdfsClientFinalizer == null) {
throw new RuntimeException("Client finalizer is null, can't suppress!"); throw new RuntimeException("Client finalizer is null, can't suppress!");
} }
if (!fsShutdownHooks.containsKey(hdfsClientFinalizer) &&
!ShutdownHookManager.deleteShutdownHook(hdfsClientFinalizer)) {
throw new RuntimeException("Failed suppression of fs shutdown hook: " +
hdfsClientFinalizer);
}
synchronized (fsShutdownHooks) { synchronized (fsShutdownHooks) {
if (!fsShutdownHooks.containsKey(hdfsClientFinalizer) &&
!ShutdownHookManager.deleteShutdownHook(hdfsClientFinalizer)) {
throw new RuntimeException("Failed suppression of fs shutdown hook: " +
hdfsClientFinalizer);
}
Integer refs = fsShutdownHooks.get(hdfsClientFinalizer); Integer refs = fsShutdownHooks.get(hdfsClientFinalizer);
fsShutdownHooks.put(hdfsClientFinalizer, refs == null ? 1 : refs + 1); fsShutdownHooks.put(hdfsClientFinalizer, refs == null ? 1 : refs + 1);
} }