Author: aching
Date: Wed Jan 18 23:04:46 2012
New Revision: 1233107

URL: http://svn.apache.org/viewvc?rev=1233107&view=rev
Log:
GIRAPH-125: Bug in LongDoubleFloatDoubleVertex.sendMsgToAllEdges().
(humming80 via aching)

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

Modified: incubator/giraph/trunk/CHANGELOG
URL: 
http://svn.apache.org/viewvc/incubator/giraph/trunk/CHANGELOG?rev=1233107&r1=1233106&r2=1233107&view=diff
==============================================================================
--- incubator/giraph/trunk/CHANGELOG (original)
+++ incubator/giraph/trunk/CHANGELOG Wed Jan 18 23:04:46 2012
@@ -1,10 +1,13 @@
 Giraph Change Log
 
 Release 0.1.0 - unreleased
+  
+  GIRAPH-125: Bug in LongDoubleFloatDoubleVertex.sendMsgToAllEdges().
+  (humming80 via aching)
 
-  GIRAPH-122. Roll version back to 0.1. (jghoman)
+  GIRAPH-122: Roll version back to 0.1. (jghoman)
 
-  GIRAPH-118: Clarify messages behavior in BasicVertex (claudio)
+  GIRAPH-118: Clarify messages behavior in BasicVertex. (claudio)
 
   GIRAPH-119: VertexCombiner should work on Iterable<M> instead of 
   List<M>. (claudio)

Modified: 
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
URL: 
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java?rev=1233107&r1=1233106&r2=1233107&view=diff
==============================================================================
--- 
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
 (original)
+++ 
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
 Wed Jan 18 23:04:46 2012
@@ -134,14 +134,12 @@ public abstract class LongDoubleFloatDou
             throw new IllegalArgumentException(
                 "sendMsgToAllEdges: Cannot send null message to all edges");
         }
-        final LongWritable destVertex = new LongWritable();
         final MutableVertex<LongWritable, DoubleWritable, FloatWritable,
             DoubleWritable> vertex = this;
         verticesWithEdgeValues.forEachKey(new LongProcedure() {
             @Override
             public boolean apply(long destVertexId) {
-                destVertex.set(destVertexId);
-                vertex.sendMsg(destVertex, msg);
+                vertex.sendMsg(new LongWritable(destVertexId), msg);
                 return true;
             }
         });


Reply via email to