echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sync getters

Browse Source
This commit is contained in:
zab2
2013-07-18 15:52:40 +00:00
parent 018098b8ef
commit ae347c4fa1
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
apps/streaming/java/src/net/i2p/client/streaming/ConnectionOptions.java
View File

@ -550,7 +550,7 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
* What to set the round trip time estimate to (in milliseconds) * What to set the round trip time estimate to (in milliseconds)
* @return round trip time estimate in ms * @return round trip time estimate in ms
*/ */
public int getRTT() { return _rtt; } public synchronized int getRTT() { return _rtt; }
public void setRTT(int ms) { public void setRTT(int ms) {
synchronized (_trend) { synchronized (_trend) {
_trend[0] = _trend[1]; _trend[0] = _trend[1];
@ -563,16 +563,18 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
_trend[2] = 0; _trend[2] = 0;
} }
synchronized(this) {
_rtt = ms; _rtt = ms;
if (_rtt > 60*1000) if (_rtt > 60*1000)
_rtt = 60*1000; _rtt = 60*1000;
} }
}
public int getRTO() { return _rto; } public synchronized int getRTO() { return _rto; }
/** used in TCB @since 0.9.8 */ /** used in TCB @since 0.9.8 */
int getRTTDev() { return _rttDev; } synchronized int getRTTDev() { return _rttDev; }
private void setRTTDev(int rttDev) { _rttDev = rttDev; } private synchronized void setRTTDev(int rttDev) { _rttDev = rttDev; }
/** /**
* Loads options from TCB cache. * Loads options from TCB cache.