You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2016/12/07 12:10:29 UTC
tinkerpop git commit: minor tweaks for show and tell.
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 8c4c915c0 -> 0462411f1
minor tweaks for show and tell.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/0462411f
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/0462411f
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/0462411f
Branch: refs/heads/TINKERPOP-1564
Commit: 0462411f1d1ad6fab9d3e6e58e5e158c9bb3f207
Parents: 8c4c915
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Dec 7 05:10:25 2016 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Dec 7 05:10:25 2016 -0700
----------------------------------------------------------------------
.../gremlin/tinkergraph/process/akka/MasterTraversalActor.java | 2 +-
.../gremlin/tinkergraph/process/akka/TinkerActorSystem.java | 2 ++
.../gremlin/tinkergraph/process/akka/WorkerTraversalActor.java | 4 ++--
3 files changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/0462411f/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/MasterTraversalActor.java
----------------------------------------------------------------------
diff --git a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/MasterTraversalActor.java b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/MasterTraversalActor.java
index 4ee2494..e0472d2 100644
--- a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/MasterTraversalActor.java
+++ b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/MasterTraversalActor.java
@@ -68,7 +68,7 @@ public final class MasterTraversalActor extends AbstractActor {
this.workers.add(worker.path());
}
for (final ActorPath worker : this.workers) {
- context().actorSelection(worker).tell(true, self());
+ context().actorSelection(worker).tell(TinkerActorSystem.State.START, self());
}
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/0462411f/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/TinkerActorSystem.java
----------------------------------------------------------------------
diff --git a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/TinkerActorSystem.java b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/TinkerActorSystem.java
index a7f4dd2..87b519c 100644
--- a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/TinkerActorSystem.java
+++ b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/TinkerActorSystem.java
@@ -35,6 +35,8 @@ import static org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__.as;
*/
public final class TinkerActorSystem {
+ public static enum State { START }
+
private final ActorSystem system;
public TinkerActorSystem(final Traversal.Admin<?, ?> traversal) {
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/0462411f/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/WorkerTraversalActor.java
----------------------------------------------------------------------
diff --git a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/WorkerTraversalActor.java b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/WorkerTraversalActor.java
index 339647f..ff65d70 100644
--- a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/WorkerTraversalActor.java
+++ b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/process/akka/WorkerTraversalActor.java
@@ -48,10 +48,10 @@ public final class WorkerTraversalActor extends AbstractActor {
receive(ReceiveBuilder.
- match(Boolean.class, bool -> {
+ match(TinkerActorSystem.State.class, state -> {
final GraphStep step = (GraphStep) this.matrix.getTraversal().getStartStep();
while (step.hasNext()) {
- self().tell(step.next(), self());
+ this.processTraverser(step.next());
}
}).
match(Traverser.Admin.class, this::processTraverser).build()