apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From david...@apache.org
Subject [1/2] incubator-apex-malhar git commit: - MLHR-1887 #resolve made shutdown field volatile since it is written and read by separate threads.
Date Mon, 02 Nov 2015 19:15:25 GMT
Repository: incubator-apex-malhar
Updated Branches:
  refs/heads/devel-3 83f297ee8 -> 6bbe17f34


- MLHR-1887 #resolve made shutdown field volatile since it is written and read by separate
threads.


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/a113bc9e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/a113bc9e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/a113bc9e

Branch: refs/heads/devel-3
Commit: a113bc9e2d1af1d0e9874b81204bd9511fe6b75f
Parents: 2805d61
Author: Timothy Farkas <tim@datatorrent.com>
Authored: Fri Oct 30 16:55:53 2015 -0700
Committer: Timothy Farkas <tim@datatorrent.com>
Committed: Fri Oct 30 16:55:53 2015 -0700

----------------------------------------------------------------------
 .../main/java/com/datatorrent/lib/io/WebSocketInputOperator.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a113bc9e/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
index 3d7bc7a..fcd0398 100644
--- a/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
@@ -62,7 +62,7 @@ public class WebSocketInputOperator<T> extends SimpleSinglePortInputOperator<T>
   protected transient final ObjectMapper mapper = new ObjectMapper(jsonFactory);
   protected transient WebSocket connection;
   private transient boolean connectionClosed = false;
-  private transient boolean shutdown = false;
+  private transient volatile boolean shutdown = false;
   private int ioThreadMultiplier = 1;
   protected boolean skipNull = false;
 


Mime
View raw message