You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2015/06/03 13:08:02 UTC
incubator-tinkerpop git commit: Synchronize access to altering the
read/write and close actions on AbstractTransaction.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master 85877f721 -> 1f5b7f715
Synchronize access to altering the read/write and close actions on AbstractTransaction.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/1f5b7f71
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/1f5b7f71
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/1f5b7f71
Branch: refs/heads/master
Commit: 1f5b7f7157b49ce74aa1b18c92b6eaf12faebeb9
Parents: 85877f7
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Wed Jun 3 07:07:32 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Wed Jun 3 07:07:32 2015 -0400
----------------------------------------------------------------------
.../tinkerpop/gremlin/structure/util/AbstractTransaction.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/1f5b7f71/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/util/AbstractTransaction.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/util/AbstractTransaction.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/util/AbstractTransaction.java
index 9fb8e2f..3b6c522 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/util/AbstractTransaction.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/util/AbstractTransaction.java
@@ -132,13 +132,13 @@ public abstract class AbstractTransaction implements Transaction {
}
@Override
- public Transaction onReadWrite(final Consumer<Transaction> consumer) {
+ public synchronized Transaction onReadWrite(final Consumer<Transaction> consumer) {
readWriteConsumer = Optional.ofNullable(consumer).orElseThrow(Transaction.Exceptions::onReadWriteBehaviorCannotBeNull);
return this;
}
@Override
- public Transaction onClose(final Consumer<Transaction> consumer) {
+ public synchronized Transaction onClose(final Consumer<Transaction> consumer) {
closeConsumer = Optional.ofNullable(consumer).orElseThrow(Transaction.Exceptions::onCloseBehaviorCannotBeNull);
return this;
}