forked from I2P_Developers/i2p.i2p
* Streaming: Randomize end of first conn limit period
to prevent correlation
This commit is contained in:
@ -4,6 +4,7 @@ import java.util.concurrent.atomic.AtomicInteger;
|
|||||||
|
|
||||||
import net.i2p.data.Hash;
|
import net.i2p.data.Hash;
|
||||||
import net.i2p.util.ObjectCounter;
|
import net.i2p.util.ObjectCounter;
|
||||||
|
import net.i2p.util.RandomSource;
|
||||||
import net.i2p.util.SimpleScheduler;
|
import net.i2p.util.SimpleScheduler;
|
||||||
import net.i2p.util.SimpleTimer;
|
import net.i2p.util.SimpleTimer;
|
||||||
|
|
||||||
@ -29,7 +30,12 @@ class ConnThrottler {
|
|||||||
_totalMax = totalMax;
|
_totalMax = totalMax;
|
||||||
this.counter = new ObjectCounter<Hash>();
|
this.counter = new ObjectCounter<Hash>();
|
||||||
_currentTotal = new AtomicInteger();
|
_currentTotal = new AtomicInteger();
|
||||||
SimpleScheduler.getInstance().addPeriodicEvent(new Cleaner(), period);
|
// shorten the initial period by a random amount,mpleScheduler.getInstance().addPeriodicEvent(new Cleaner(),
|
||||||
|
// to prevent correlation across destinations
|
||||||
|
// and identification of router startup time
|
||||||
|
SimpleScheduler.getInstance().addPeriodicEvent(new Cleaner(),
|
||||||
|
RandomSource.getInstance().nextLong(period),
|
||||||
|
period);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
Reference in New Issue
Block a user