| commit | ecfbeb60b71383446912600237bb792679c8da6c | [log] [tgz] |
|---|---|---|
| author | Sho SHIMIZU <sshimizu@us.fujitsu.com> | Thu Aug 18 11:37:17 2016 -0700 |
| committer | Sho SHIMIZU <sshimizu@us.fujitsu.com> | Tue Aug 30 13:34:42 2016 -0700 |
| tree | 49c18ad81ab4e34249b701b06a070bfce0caf890 | |
| parent | d21c4ddaeeffc63ffe04986c520eac4b2b42bce6 [diff] |
Read the latest value of lastSink Multiple threads could access the field, lastSink, then they should read the latest value of lastSink Change-Id: I279ed6fa3db357008603cde5cb2c57671e66b33c
diff --git a/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java b/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java index 26a89d4..e44709c 100644 --- a/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java +++ b/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java
@@ -73,7 +73,7 @@ // Means to detect long-running sinks private TimerTask watchdog; - private EventSink lastSink; + private volatile EventSink lastSink; private final Stopwatch stopwatch = Stopwatch.createUnstarted(); private volatile Future<?> dispatchFuture;