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