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

better loading from cache

Browse Source
This commit is contained in:
zab2
2013-07-18 01:52:46 +00:00
parent 1e2fb4bea5
commit 018098b8ef
2 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -572,21 +572,23 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
/** used in TCB @since 0.9.8 */
int getRTTDev() { return _rttDev; }
/** used in TCB @since 0.9.8 */
void setRTTDev(int rttDev) { _rttDev = rttDev; }
private void setRTTDev(int rttDev) { _rttDev = rttDev; }
/**
* mark these options as loaded from cache.
* affects the calculation of RTO
* Loads options from TCB cache.
*/
synchronized void loadedFromCache() {
synchronized void loadFromCache(int rtt, int rttDev, int wdw) {
_initState = AckInit.STEADY;
setRTT(rtt);
setRTTDev(rttDev);
setWindowSize(wdw);
computeRTO();
}
/**
* computes RTO based on formula in RFC
*/
synchronized void computeRTO() {
private synchronized void computeRTO() {
switch(_initState) {
case INIT :
throw new IllegalStateException();

6
apps/streaming/java/src/net/i2p/client/streaming/TCBShare.java
View File

@ -99,11 +99,7 @@ class TCBShare {
" RTTDev: "+ rttDev +
" wdw: " + wdw );
}
opts.loadedFromCache();
opts.setRTT(rtt);
opts.setRTTDev(rttDev);
opts.setWindowSize(wdw);
opts.computeRTO();
opts.loadFromCache(rtt,rttDev,wdw);
}
/** store to cache */