Changeset dfc4948


Ignore:
Timestamp:
Jul 5, 2013 6:21:42 PM (7 years ago)
Author:
zab2 <zab2@…>
Branches:
master
Children:
76de4fa
Parents:
ba0e58e6
Message:

cleanup & sync

File:
1 edited

Legend:

Unmodified
Added
Removed
  • apps/streaming/java/src/net/i2p/client/streaming/TCBShare.java

    rba0e58e6 rdfc4948  
    3737        _context = ctx;
    3838        _log = ctx.logManager().getLog(TCBShare.class);
    39         _cache = new ConcurrentHashMap(4);
     39        _cache = new ConcurrentHashMap<Destination,Entry>(4);
    4040        _cleaner = new CleanEvent(timer);
    4141        _cleaner.schedule(CLEAN_TIME);
     
    112112            _updated = _context.clock().now();
    113113        }
    114         public int getRTT() { return _rtt; }
    115         public void setRTT(int ms) {
     114        public synchronized int getRTT() { return _rtt; }
     115        public synchronized void setRTT(int ms) {
    116116            _rtt = (int)(RTT_DAMPENING*_rtt + (1-RTT_DAMPENING)*ms);       
    117117            if (_rtt > MAX_RTT)
     
    119119            _updated = _context.clock().now();
    120120        }
    121         public int getWindowSize() { return _wdw; }
    122         public void setWindowSize(int wdw) {
     121        public synchronized int getWindowSize() { return _wdw; }
     122        public synchronized void setWindowSize(int wdw) {
    123123            _wdw = (int)(0.5 + WDW_DAMPENING*_wdw + (1-WDW_DAMPENING)*wdw);       
    124124            if (_wdw > MAX_WINDOW_SIZE)
     
    126126            _updated = _context.clock().now();
    127127        }
    128         public boolean isExpired() {
     128        public synchronized boolean isExpired() {
    129129            return _updated < _context.clock().now() - EXPIRE_TIME;
    130130        }
Note: See TracChangeset for help on using the changeset viewer.