accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject git commit: ACCUMULO-1812 translate ClosedChannelException into LogClosedException
Date Thu, 24 Oct 2013 15:07:44 GMT
Updated Branches:
  refs/heads/master 069fb1afd -> b2adcaa3e


ACCUMULO-1812 translate ClosedChannelException into LogClosedException


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b2adcaa3
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b2adcaa3
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b2adcaa3

Branch: refs/heads/master
Commit: b2adcaa3e405041ce300dc5b157c473cf91211fb
Parents: 069fb1a
Author: Eric Newton <eric.newton@gmail.com>
Authored: Thu Oct 24 11:07:34 2013 -0400
Committer: Eric Newton <eric.newton@gmail.com>
Committed: Thu Oct 24 11:07:48 2013 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/server/tabletserver/log/DfsLogger.java    | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/b2adcaa3/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
b/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
index 6d574b9..0b64d42 100644
--- a/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
+++ b/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
@@ -26,6 +26,7 @@ import java.io.DataOutputStream;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.lang.reflect.Method;
+import java.nio.channels.ClosedChannelException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -407,6 +408,8 @@ public class DfsLogger {
           value.mutations = tabletMutations.getMutations();
           write(key, value);
         }
+      } catch (ClosedChannelException ex) {
+        throw new LogClosedException();
       } catch (Exception e) {
         log.error(e, e);
         work.exception = e;


Mime
View raw message