You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ca...@apache.org on 2016/02/03 15:46:17 UTC

[3/6] cassandra git commit: ninja-fix propagate usage

ninja-fix propagate usage


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

Branch: refs/heads/trunk
Commit: b9bdd9ec648ad42d88b1377fe0e1e4ff3d162a91
Parents: 5f1e4bc
Author: Carl Yeksigian <ca...@apache.org>
Authored: Wed Feb 3 09:42:18 2016 -0500
Committer: Carl Yeksigian <ca...@apache.org>
Committed: Wed Feb 3 09:42:18 2016 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/db/Mutation.java                    | 2 +-
 src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java | 2 +-
 src/java/org/apache/cassandra/service/paxos/PaxosState.java       | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/b9bdd9ec/src/java/org/apache/cassandra/db/Mutation.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/Mutation.java b/src/java/org/apache/cassandra/db/Mutation.java
index 9a26456..c6ad9b8 100644
--- a/src/java/org/apache/cassandra/db/Mutation.java
+++ b/src/java/org/apache/cassandra/db/Mutation.java
@@ -218,7 +218,7 @@ public class Mutation implements IMutation
         }
         catch (ExecutionException e)
         {
-            Throwables.propagate(e.getCause());
+            throw Throwables.propagate(e.getCause());
         }
     }
 

http://git-wip-us.apache.org/repos/asf/cassandra/blob/b9bdd9ec/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java b/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
index 33750f8..7169b2f 100644
--- a/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
+++ b/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
@@ -611,7 +611,7 @@ public class CommitLogReplayer
                     }
                     catch (ExecutionException e)
                     {
-                        Throwables.propagate(e.getCause());
+                        throw Throwables.propagate(e.getCause());
                     }
 
                     keyspacesRecovered.add(keyspace);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/b9bdd9ec/src/java/org/apache/cassandra/service/paxos/PaxosState.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/paxos/PaxosState.java b/src/java/org/apache/cassandra/service/paxos/PaxosState.java
index d4fed51..0b3af8f 100644
--- a/src/java/org/apache/cassandra/service/paxos/PaxosState.java
+++ b/src/java/org/apache/cassandra/service/paxos/PaxosState.java
@@ -146,7 +146,7 @@ public class PaxosState
                 }
                 catch (ExecutionException e)
                 {
-                    Throwables.propagate(e.getCause());
+                    throw Throwables.propagate(e.getCause());
                 }
             }
             else