forked from I2P_Developers/i2p.i2p
old TimerTask cleanup
This commit is contained in:
@ -24,7 +24,6 @@ import java.util.ArrayList;
|
|||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Random;
|
import java.util.Random;
|
||||||
import java.util.TimerTask;
|
|
||||||
|
|
||||||
import net.i2p.I2PAppContext;
|
import net.i2p.I2PAppContext;
|
||||||
|
|
||||||
@ -32,7 +31,7 @@ import net.i2p.I2PAppContext;
|
|||||||
* TimerTask that checks for good/bad up/downloader. Works together
|
* TimerTask that checks for good/bad up/downloader. Works together
|
||||||
* with the PeerCoordinator to select which Peers get (un)choked.
|
* with the PeerCoordinator to select which Peers get (un)choked.
|
||||||
*/
|
*/
|
||||||
class PeerCheckerTask extends TimerTask
|
class PeerCheckerTask implements Runnable
|
||||||
{
|
{
|
||||||
private static final long KILOPERSECOND = 1024*(PeerCoordinator.CHECK_PERIOD/1000);
|
private static final long KILOPERSECOND = 1024*(PeerCoordinator.CHECK_PERIOD/1000);
|
||||||
|
|
||||||
@ -54,8 +53,6 @@ class PeerCheckerTask extends TimerTask
|
|||||||
List<Peer> peerList = coordinator.peerList();
|
List<Peer> peerList = coordinator.peerList();
|
||||||
if (peerList.isEmpty() || coordinator.halted()) {
|
if (peerList.isEmpty() || coordinator.halted()) {
|
||||||
coordinator.setRateHistory(0, 0);
|
coordinator.setRateHistory(0, 0);
|
||||||
if (coordinator.halted())
|
|
||||||
cancel();
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -21,7 +21,6 @@
|
|||||||
package org.klomp.snark;
|
package org.klomp.snark;
|
||||||
|
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.TimerTask;
|
|
||||||
|
|
||||||
import net.i2p.data.DataHelper;
|
import net.i2p.data.DataHelper;
|
||||||
|
|
||||||
@ -29,7 +28,7 @@ import net.i2p.data.DataHelper;
|
|||||||
* TimerTask that monitors the peers and total up/download speeds.
|
* TimerTask that monitors the peers and total up/download speeds.
|
||||||
* Works together with the main Snark class to report periodical statistics.
|
* Works together with the main Snark class to report periodical statistics.
|
||||||
*/
|
*/
|
||||||
class PeerMonitorTask extends TimerTask
|
class PeerMonitorTask implements Runnable
|
||||||
{
|
{
|
||||||
final static long MONITOR_PERIOD = 10 * 1000; // Ten seconds.
|
final static long MONITOR_PERIOD = 10 * 1000; // Ten seconds.
|
||||||
private static final long KILOPERSECOND = 1024 * (MONITOR_PERIOD / 1000);
|
private static final long KILOPERSECOND = 1024 * (MONITOR_PERIOD / 1000);
|
||||||
|
@ -32,8 +32,6 @@ import java.util.List;
|
|||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
import java.util.Random;
|
import java.util.Random;
|
||||||
import java.util.StringTokenizer;
|
import java.util.StringTokenizer;
|
||||||
import java.util.Timer;
|
|
||||||
import java.util.TimerTask;
|
|
||||||
|
|
||||||
import net.i2p.I2PAppContext;
|
import net.i2p.I2PAppContext;
|
||||||
import net.i2p.client.streaming.I2PServerSocket;
|
import net.i2p.client.streaming.I2PServerSocket;
|
||||||
|
Reference in New Issue
Block a user