[Bigdata-commit] SF.net SVN: bigdata:[7669] branches/MGC_1_3_0/bigdata/src/java/com/bigdata/ ha/QuorumPipelineImpl.java

[<tho...@us...>]

Revision: 7669
          http://bigdata.svn.sourceforge.net/bigdata/?rev=7669&view=rev
Author:   thompsonbry
Date:     2013-12-17 18:03:37 +0000 (Tue, 17 Dec 2013)
Log Message:
-----------
Bug fix to code looking for root cause of interrupted exception in launder throwable. It was examining the wrong stack trace.

Modified Paths:
--------------
    branches/MGC_1_3_0/bigdata/src/java/com/bigdata/ha/QuorumPipelineImpl.java

Modified: branches/MGC_1_3_0/bigdata/src/java/com/bigdata/ha/QuorumPipelineImpl.java
===================================================================
--- branches/MGC_1_3_0/bigdata/src/java/com/bigdata/ha/QuorumPipelineImpl.java	2013-12-17 18:00:44 UTC (rev 7668)
+++ branches/MGC_1_3_0/bigdata/src/java/com/bigdata/ha/QuorumPipelineImpl.java	2013-12-17 18:03:37 UTC (rev 7669)
@@ -1939,7 +1939,7 @@
                 // Log and continue.
                 log.error("Problem on node removal", e);
                 
-                if(InnerCause.isInnerCause(t, InterruptedException.class)) {
+                if(InnerCause.isInnerCause(e, InterruptedException.class)) {
                     // Propagate interrupt.
                     Thread.currentThread().interrupt();
                 }
@@ -1970,7 +1970,7 @@
                 // Log and continue.
                 log.error("Problem on reset pipeline", e);
 
-                if(InnerCause.isInnerCause(t, InterruptedException.class)) {
+                if(InnerCause.isInnerCause(e, InterruptedException.class)) {
                     // Propagate interrupt.
                     Thread.currentThread().interrupt();
                 }

This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.