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 2015/09/23 01:28:23 UTC
incubator-tinkerpop git commit: forgot we needed a method for Giraph
-- not only did I not run the full test suite,
I didn't even compile. @dkuppitz fault.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/tp30 9f304e724 -> 3bcbb2126
forgot we needed a method for Giraph -- not only did I not run the full test suite, I didn't even compile. @dkuppitz fault.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/3bcbb212
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/3bcbb212
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/3bcbb212
Branch: refs/heads/tp30
Commit: 3bcbb2126ba994689fe7cedbc45c750e3110921b
Parents: 9f304e7
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Sep 22 17:28:18 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Sep 22 17:28:18 2015 -0600
----------------------------------------------------------------------
.../process/computer/util/VertexProgramPool.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/3bcbb212/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
index 4c85387..b77c310 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
@@ -54,4 +54,16 @@ public final class VertexProgramPool {
throw new IllegalStateException(e.getMessage(), e);
}
}
+
+ public synchronized void workerIterationStart(final Memory memory) {
+ for (final VertexProgram<?> vertexProgram : this.pool) {
+ vertexProgram.workerIterationStart(memory);
+ }
+ }
+
+ public synchronized void workerIterationEnd(final Memory memory) {
+ for (final VertexProgram<?> vertexProgram : this.pool) {
+ vertexProgram.workerIterationEnd(memory);
+ }
+ }
}