PandacubeFr/BungeeCord
1
0
Fork 0
Code Releases Activity

#2622: Let ThrottleTest work independently of real time

Browse Source
This commit is contained in:
killme 2019-04-13 13:18:19 +02:00 committed by md_5
parent 191afb6a6c
commit 9bce83704a
2 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
proxy/src/main/java/net/md_5/bungee/ConnectionThrottle.java
View File

@ -1,5 +1,7 @@
package net.md_5.bungee;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Ticker;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
@ -13,8 +15,15 @@ public class ConnectionThrottle
private final int throttleLimit;
public ConnectionThrottle(int throttleTime, int throttleLimit)
{
this(Ticker.systemTicker(), throttleTime, throttleLimit);
}
@VisibleForTesting
ConnectionThrottle(Ticker ticker, int throttleTime, int throttleLimit)
{
this.throttle = CacheBuilder.newBuilder()
.ticker(ticker)
.concurrencyLevel( Runtime.getRuntime().availableProcessors() )
.initialCapacity( 100 )
.expireAfterWrite( throttleTime, TimeUnit.MILLISECONDS )

19
proxy/src/test/java/net/md_5/bungee/ThrottleTest.java
View File

@ -1,17 +1,32 @@
package net.md_5.bungee;
import com.google.common.base.Ticker;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.concurrent.TimeUnit;
import org.junit.Assert;
import org.junit.Test;
public class ThrottleTest
{
private class FixedTicker extends Ticker
{
private long value;
@Override
public long read()
{
return value;
}
}
@Test
public void testThrottle() throws InterruptedException, UnknownHostException
{
ConnectionThrottle throttle = new ConnectionThrottle( 10, 3 );
FixedTicker ticker = new FixedTicker();
ConnectionThrottle throttle = new ConnectionThrottle( ticker, 10, 3 );
InetAddress address;
try
@ -33,7 +48,7 @@ public class ThrottleTest
Assert.assertTrue( "Address should be throttled", throttle.throttle( address ) ); // 4
// Now test expiration
Thread.sleep( 50 );
ticker.value += TimeUnit.MILLISECONDS.toNanos( 50 );
Assert.assertFalse( "Address should not be throttled", throttle.throttle( address ) );
}
}