You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tephra.apache.org by po...@apache.org on 2016/09/13 01:54:45 UTC
incubator-tephra git commit: Add methods to help testing Transaction
Manager
Repository: incubator-tephra
Updated Branches:
refs/heads/master 14858e4af -> 66354786d
Add methods to help testing Transaction Manager
This closes #11
Signed-off-by: poorna <po...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/incubator-tephra/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tephra/commit/66354786
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tephra/tree/66354786
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tephra/diff/66354786
Branch: refs/heads/master
Commit: 66354786dab76b9c4b7ce3922c9288baad2c07c7
Parents: 14858e4
Author: poorna <po...@cask.co>
Authored: Mon Sep 12 18:25:49 2016 -0700
Committer: poorna <po...@apache.org>
Committed: Mon Sep 12 18:54:23 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/tephra/TransactionManager.java | 7 +++++++
.../org/apache/tephra/distributed/TransactionService.java | 8 ++++++++
2 files changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/66354786/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java b/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java
index cfefc83..e3cd2f8 100644
--- a/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java
+++ b/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java
@@ -18,6 +18,7 @@
package org.apache.tephra;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Objects;
import com.google.common.base.Preconditions;
import com.google.common.base.Stopwatch;
@@ -1265,6 +1266,12 @@ public class TransactionManager extends AbstractService {
", committed = " + committedChangeSets.size());
}
+ @SuppressWarnings("unused")
+ @VisibleForTesting
+ public TransactionStateStorage getTransactionStateStorage() {
+ return persistor;
+ }
+
private abstract static class DaemonThreadExecutor extends Thread {
private AtomicBoolean stopped = new AtomicBoolean(false);
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/66354786/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java b/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java
index 6fbf926..4061c4d 100644
--- a/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java
+++ b/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java
@@ -42,6 +42,7 @@ import java.net.UnknownHostException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
+import javax.annotation.Nullable;
/**
*
@@ -153,4 +154,11 @@ public final class TransactionService extends InMemoryTransactionService {
}
}
}
+
+ @SuppressWarnings({"WeakerAccess", "unused"})
+ @VisibleForTesting
+ @Nullable
+ public TransactionManager getTransactionManager() {
+ return txManager;
+ }
}