You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2012/11/06 07:59:10 UTC
svn commit: r1406058 - in /giraph/trunk: CHANGELOG
giraph/src/main/java/org/apache/giraph/graph/GraphMapper.java
Author: maja
Date: Tue Nov 6 06:59:09 2012
New Revision: 1406058
URL: http://svn.apache.org/viewvc?rev=1406058&view=rev
Log:
GIRAPH-412: Checkstyle error from Giraph-403
Modified:
giraph/trunk/CHANGELOG
giraph/trunk/giraph/src/main/java/org/apache/giraph/graph/GraphMapper.java
Modified: giraph/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/giraph/trunk/CHANGELOG?rev=1406058&r1=1406057&r2=1406058&view=diff
==============================================================================
--- giraph/trunk/CHANGELOG (original)
+++ giraph/trunk/CHANGELOG Tue Nov 6 06:59:09 2012
@@ -1,6 +1,8 @@
Giraph Change Log
Release 0.2.0 - unreleased
+ GIRAPH-412: Checkstyle error from Giraph-403 (majakabiljo)
+
GIRAPH-403: GraphMapper.notiftySentMessages need to be thread-safe
(nitay via majakabiljo)
Modified: giraph/trunk/giraph/src/main/java/org/apache/giraph/graph/GraphMapper.java
URL: http://svn.apache.org/viewvc/giraph/trunk/giraph/src/main/java/org/apache/giraph/graph/GraphMapper.java?rev=1406058&r1=1406057&r2=1406058&view=diff
==============================================================================
--- giraph/trunk/giraph/src/main/java/org/apache/giraph/graph/GraphMapper.java (original)
+++ giraph/trunk/giraph/src/main/java/org/apache/giraph/graph/GraphMapper.java Tue Nov 6 06:59:09 2012
@@ -443,7 +443,8 @@ public class GraphMapper<I extends Writa
public void notifySentMessages() {
// We are tracking the time between when the compute started and the first
// message get sent. We use null to flag that we have already recorded it.
- if (timeToFirstMessageContext != null) {
+ TimerContext tmp = timeToFirstMessageContext;
+ if (tmp != null) {
synchronized (notifySentMsgLock) {
if (timeToFirstMessageContext != null) {
timeToFirstMessageContext.stop();