You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by jg...@apache.org on 2012/06/28 21:18:37 UTC

svn commit: r1355119 - in /giraph/trunk: CHANGELOG src/main/java/org/apache/giraph/graph/BasicVertex.java

Author: jghoman
Date: Thu Jun 28 19:18:36 2012
New Revision: 1355119

URL: http://svn.apache.org/viewvc?rev=1355119&view=rev
Log:
GIRAPH-220: Default implementation of BasicVertex#sendMsgToAllEdges(). Contributed by Alessandro Presta.

Modified:
    giraph/trunk/CHANGELOG
    giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java

Modified: giraph/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/giraph/trunk/CHANGELOG?rev=1355119&r1=1355118&r2=1355119&view=diff
==============================================================================
--- giraph/trunk/CHANGELOG (original)
+++ giraph/trunk/CHANGELOG Thu Jun 28 19:18:36 2012
@@ -2,6 +2,9 @@ Giraph Change Log
 
 Release 0.2.0 - unreleased
 
+  GIRAPH-220: Default implementation of BasicVertex#sendMsgToAllEdges().
+  (Alessandro Presta via jghoman)
+
   GIRAPH-217: Add SimpleTriangleClosingVertex to Giraph examples. 
   (Eli Reisman via jghoman)  
 

Modified: giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java
URL: http://svn.apache.org/viewvc/giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java?rev=1355119&r1=1355118&r2=1355119&view=diff
==============================================================================
--- giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java (original)
+++ giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java Thu Jun 28 19:18:36 2012
@@ -174,7 +174,11 @@ public abstract class BasicVertex<I exte
    *
    * @param msg Message sent to all edges.
    */
-  public abstract void sendMsgToAllEdges(M msg);
+  public void sendMsgToAllEdges(M msg) {
+    for (Iterator<I> edges = iterator(); edges.hasNext();) {
+      sendMsg(edges.next(), msg);
+    }
+  }
 
   /**
    * After this is called, the compute() code will no longer be called for