better sync

2013-07-05 18:29:00 +00:00
parent dfc4948a6f
commit 76de4faf62
1 changed files with 6 additions and 4 deletions
--- a/apps/streaming/java/src/net/i2p/client/streaming/TCBShare.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/TCBShare.java
@@ -87,11 +87,13 @@ class TCBShare {
            e = new Entry(opts.getRTT(), opts.getWindowSize());
            _cache.put(dest, e);
        } else {
+            synchronized(e) {
                old = e.getRTT();
                oldw = e.getWindowSize();
                e.setRTT(opts.getRTT());
                e.setWindowSize(opts.getWindowSize());
            }
+        }
        if (_log.shouldLog(Log.DEBUG))
            _log.debug("To cache: " +
                       con.getSession().getMyDestination().calculateHash().toBase64().substring(0, 4) +