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 2017/01/10 16:11:55 UTC
[47/50] [abbrv] tinkerpop git commit: smarter distribution of initial
GraphStep traversers.
smarter distribution of initial GraphStep traversers.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/dcfc3fdd
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/dcfc3fdd
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/dcfc3fdd
Branch: refs/heads/TINKERPOP-1564
Commit: dcfc3fdd097f31ab102f6637740daf19296cc886
Parents: f058f61
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Jan 4 15:18:37 2017 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Jan 10 08:25:53 2017 -0700
----------------------------------------------------------------------
.../process/actors/traversal/TraversalWorkerProgram.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/dcfc3fdd/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actors/traversal/TraversalWorkerProgram.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actors/traversal/TraversalWorkerProgram.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actors/traversal/TraversalWorkerProgram.java
index 2aaa7b5..127322f 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actors/traversal/TraversalWorkerProgram.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actors/traversal/TraversalWorkerProgram.java
@@ -99,9 +99,10 @@ final class TraversalWorkerProgram implements ActorProgram.Worker<Object> {
//System.out.println(message + "::" + this.isLeader);
if (message instanceof StartMessage) {
// initial message from master that says: "start processing"
- final GraphStep step = (GraphStep) this.matrix.getTraversal().getStartStep();
+ final GraphStep<?,?> step = (GraphStep) this.matrix.getTraversal().getStartStep();
while (step.hasNext()) {
- this.sendTraverser(step.next());
+ final Traverser.Admin<? extends Element> traverser = step.next();
+ this.self.send(traverser.isHalted() ? this.self.master() : this.self.address(), traverser);
}
} else if (message instanceof Traverser.Admin) {
this.processTraverser((Traverser.Admin) message);