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 <[email protected]> Authored: Fri Oct 30 16:55:53 2015 -0700 Committer: Timothy Farkas <[email protected]> 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;
