You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ti...@apache.org on 2015/11/28 02:48:14 UTC
incubator-apex-malhar git commit: - MLHR-1887 #resolve made shutdown
field volatile since it is written and read by separate threads.
Repository: incubator-apex-malhar
Updated Branches:
refs/heads/release-3.2 0804c611c -> 58bf4061e
- 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/58bf4061
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/58bf4061
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/58bf4061
Branch: refs/heads/release-3.2
Commit: 58bf4061e0f569e101093fdda75e03eed5bf9e11
Parents: 0804c61
Author: Timothy Farkas <ti...@datatorrent.com>
Authored: Fri Oct 30 16:55:53 2015 -0700
Committer: Timothy Farkas <ti...@datatorrent.com>
Committed: Fri Nov 27 17:45:14 2015 -0800
----------------------------------------------------------------------
.../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/58bf4061/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;