Merge remote-tracking branch 'origin/jetty-9.4.x'

This commit is contained in:
Jan Bartel 2016-09-22 17:17:52 +10:00
commit 076918ffab
132 changed files with 346 additions and 183 deletions

View File

@ -108,11 +108,6 @@ public class GCloudSessionDataStore extends AbstractSessionDataStore
protected String _maxInactive = MAXINACTIVE; protected String _maxInactive = MAXINACTIVE;
protected String _attributes = ATTRIBUTES; protected String _attributes = ATTRIBUTES;
public EntityDataModel()
{
System.err.println("NEW CALLED");
}
private void checkNotNull(String s) private void checkNotNull(String s)
{ {

View File

@ -16,4 +16,4 @@ etc/sessions/id-manager.xml
#jetty.sessionIdManager.workerName=node1 #jetty.sessionIdManager.workerName=node1
## Period between runs of the session scavenger (in seconds) ## Period between runs of the session scavenger (in seconds)
#jetty.sessionScavengeInterval.seconds=60 #jetty.sessionScavengeInterval.seconds=600

View File

@ -46,6 +46,7 @@ public class HouseKeeper extends AbstractLifeCycle
protected boolean _ownScheduler = false; protected boolean _ownScheduler = false;
private long _intervalMs = DEFAULT_PERIOD_MS; private long _intervalMs = DEFAULT_PERIOD_MS;
@ -93,27 +94,86 @@ public class HouseKeeper extends AbstractLifeCycle
if (_sessionIdManager == null) if (_sessionIdManager == null)
throw new IllegalStateException ("No SessionIdManager for Housekeeper"); throw new IllegalStateException ("No SessionIdManager for Housekeeper");
if (_sessionIdManager instanceof DefaultSessionIdManager)
{
//try and use a common scheduler, fallback to own
_scheduler = ((DefaultSessionIdManager)_sessionIdManager).getServer().getBean(Scheduler.class);
}
if (_scheduler == null)
{
_scheduler = new ScheduledExecutorScheduler();
_ownScheduler = true;
_scheduler.start();
}
else if (!_scheduler.isStarted())
throw new IllegalStateException("Shared scheduler not started");
setIntervalSec(getIntervalSec()); setIntervalSec(getIntervalSec());
super.doStart(); super.doStart();
} }
/**
* Get a scheduler. First try a common scheduler, failing that
* create our own.
*
* @throws Exception
*/
protected void findScheduler () throws Exception
{
if (_scheduler == null)
{
if (_sessionIdManager instanceof DefaultSessionIdManager)
{
//try and use a common scheduler, fallback to own
_scheduler = ((DefaultSessionIdManager)_sessionIdManager).getServer().getBean(Scheduler.class);
}
if (_scheduler == null)
{
_scheduler = new ScheduledExecutorScheduler();
_ownScheduler = true;
_scheduler.start();
if (LOG.isDebugEnabled()) LOG.debug("Using own scheduler for scavenging");
}
else if (!_scheduler.isStarted())
throw new IllegalStateException("Shared scheduler not started");
}
}
/**
* If scavenging is not scheduled, schedule it.
* @throws Exception
*/
protected void startScavenging() throws Exception
{
synchronized (this)
{
if (_scheduler != null)
{
//cancel any previous task
if (_task!=null)
_task.cancel();
if (_runner == null)
_runner = new Runner();
LOG.info("Scavenging every {}ms", _intervalMs);
_task = _scheduler.schedule(_runner,_intervalMs,TimeUnit.MILLISECONDS);
}
}
}
/**
* If scavenging is scheduled, stop it.
*
* @throws Exception
*/
protected void stopScavenging() throws Exception
{
synchronized (this)
{
if (_task!=null)
{
_task.cancel();
LOG.info("Stopped scavenging");
}
_task = null;
if (_ownScheduler)
{
_scheduler.stop();
_scheduler = null;
}
}
_runner = null;
}
/** /**
* @see org.eclipse.jetty.util.component.AbstractLifeCycle#doStop() * @see org.eclipse.jetty.util.component.AbstractLifeCycle#doStop()
*/ */
@ -122,13 +182,8 @@ public class HouseKeeper extends AbstractLifeCycle
{ {
synchronized(this) synchronized(this)
{ {
if (_task != null) stopScavenging();
_task.cancel();
_task=null;
if (_ownScheduler && _scheduler !=null)
_scheduler.stop();
_scheduler = null; _scheduler = null;
_runner = null;
} }
super.doStop(); super.doStop();
} }
@ -137,37 +192,43 @@ public class HouseKeeper extends AbstractLifeCycle
/** /**
* Set the period between scavenge cycles * Set the period between scavenge cycles
* @param sec the interval (in seconds) * @param sec the interval (in seconds)
* @throws Exception
*/ */
public void setIntervalSec (long sec) public void setIntervalSec (long sec) throws Exception
{ {
if (sec<=0) if (isStarted() || isStarting())
sec=60;
long old_period=_intervalMs;
long period=sec*1000L;
_intervalMs=period;
//add a bit of variability into the scavenge time so that not all
//nodes with the same scavenge interval sync up
long tenPercent = _intervalMs/10;
if ((System.currentTimeMillis()%2) == 0)
_intervalMs += tenPercent;
if (LOG.isDebugEnabled())
LOG.debug("Scavenging every "+_intervalMs+" ms");
synchronized (this)
{ {
if (_scheduler != null && (period!=old_period || _task==null)) if (sec <= 0)
{ {
if (_task!=null) _intervalMs = 0L;
_task.cancel(); LOG.info("Scavenging disabled");
if (_runner == null) stopScavenging();
_runner = new Runner(); }
_task = _scheduler.schedule(_runner,_intervalMs,TimeUnit.MILLISECONDS); else
{
if (sec < 10)
LOG.warn("Short interval of {}sec for session scavenging.", sec);
_intervalMs=sec*1000L;
//add a bit of variability into the scavenge time so that not all
//nodes with the same scavenge interval sync up
long tenPercent = _intervalMs/10;
if ((System.currentTimeMillis()%2) == 0)
_intervalMs += tenPercent;
if (isStarting() || isStarted())
{
findScheduler();
startScavenging();
}
} }
} }
else
{
_intervalMs=sec*1000L;
}
} }
@ -183,6 +244,8 @@ public class HouseKeeper extends AbstractLifeCycle
} }
/** /**
* Periodically do session housekeeping * Periodically do session housekeeping

View File

@ -546,7 +546,6 @@ public class JDBCSessionDataStore extends AbstractSessionDataStore
//make the session table if necessary //make the session table if necessary
String tableName = _dbAdaptor.convertIdentifier(getTableName()); String tableName = _dbAdaptor.convertIdentifier(getTableName());
String schemaName = _dbAdaptor.convertIdentifier(getSchemaName()); String schemaName = _dbAdaptor.convertIdentifier(getSchemaName());
System.err.println ("Tablename: "+tableName+" SchemaName:"+schemaName);
try (ResultSet result = metaData.getTables(null, schemaName, tableName, null)) try (ResultSet result = metaData.getTables(null, schemaName, tableName, null))
{ {
if (!result.next()) if (!result.next())

View File

@ -37,6 +37,7 @@ public class NullSessionCache extends AbstractSessionCache
public NullSessionCache(SessionHandler handler) public NullSessionCache(SessionHandler handler)
{ {
super(handler); super(handler);
super.setEvictionPolicy(EVICT_ON_SESSION_EXIT);
} }
/** /**
@ -104,4 +105,15 @@ public class NullSessionCache extends AbstractSessionCache
return null; return null;
} }
/**
* @see org.eclipse.jetty.server.session.AbstractSessionCache#setEvictionPolicy(int)
*/
@Override
public void setEvictionPolicy(int evictionTimeout)
{
LOG.warn("Ignoring eviction setting:"+evictionTimeout);
}
} }

View File

@ -43,7 +43,8 @@ public class SessionContext
public SessionContext (String workerName, ContextHandler.Context context) public SessionContext (String workerName, ContextHandler.Context context)
{ {
_sessionHandler = context.getContextHandler().getChildHandlerByClass(SessionHandler.class); if (context != null)
_sessionHandler = context.getContextHandler().getChildHandlerByClass(SessionHandler.class);
_workerName = workerName; _workerName = workerName;
_context = context; _context = context;
_canonicalContextPath = canonicalizeContextPath(_context); _canonicalContextPath = canonicalizeContextPath(_context);

View File

@ -42,7 +42,7 @@ public class ClientCrossContextSessionTest extends AbstractClientCrossContextSes
@Override @Override
public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -122,7 +122,7 @@ public class FileTestServer extends AbstractTestServer
public FileTestServer(int port, int maxInactivePeriod, int scavengePeriod, int idlePassivatePeriod) public FileTestServer(int port, int maxInactivePeriod, int scavengePeriod, int idlePassivatePeriod) throws Exception
{ {
super(port, maxInactivePeriod, scavengePeriod, idlePassivatePeriod); super(port, maxInactivePeriod, scavengePeriod, idlePassivatePeriod);
} }

View File

@ -45,7 +45,7 @@ public class ForwardedSessionTest extends AbstractForwardedSessionTest
@Override @Override
public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -47,7 +47,7 @@ public class IdleSessionTest extends AbstractIdleSessionTest
* @see org.eclipse.jetty.server.session.AbstractIdleSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractIdleSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -43,7 +43,7 @@ public class ImmediateSaveTest extends AbstractImmediateSaveTest
} }
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ return new FileTestServer(port, max, scavenge, evictionPolicy) { return new FileTestServer(port, max, scavenge, evictionPolicy)
{ {
public SessionHandler newSessionHandler() public SessionHandler newSessionHandler()

View File

@ -37,7 +37,7 @@ public class ImmortalSessionTest extends AbstractImmortalSessionTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -40,7 +40,7 @@ public class NewSessionTest extends AbstractNewSessionTest
FileTestServer.teardown(); FileTestServer.teardown();
} }
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge,evictionPolicy); return new FileTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -39,7 +39,7 @@ public class OrphanedSessionTest extends AbstractOrphanedSessionTest
FileTestServer.teardown(); FileTestServer.teardown();
} }
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge,evictionPolicy); return new FileTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -50,7 +50,7 @@ public class ProxySerializationTest extends AbstractProxySerializationTest
* @see org.eclipse.jetty.server.session.AbstractProxySerializationTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractProxySerializationTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy ) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy ) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -41,7 +41,7 @@ public class ReentrantRequestSessionTest extends AbstractReentrantRequestSession
} }
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new FileTestServer(port, max, scavenge, evictionPolicy); return new FileTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -38,7 +38,7 @@ public class RemoveSessionTest extends AbstractRemoveSessionTest
} }
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge,evictionPolicy); return new FileTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -43,7 +43,7 @@ public class ScatterGunLoadTest extends AbstractScatterGunLoadTest
@Override @Override
public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -40,7 +40,7 @@ public class ServerCrossContextSessionTest extends AbstractServerCrossContextSes
@Override @Override
public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) public AbstractTestServer createServer(final int port, final int max, final int scavenge, final int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge, evictionPolicy); return new FileTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -40,7 +40,7 @@ public class SessionCookieTest extends AbstractSessionCookieTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port, max, scavenge,evictionPolicy); return new FileTestServer(port, max, scavenge,evictionPolicy);
} }

View File

@ -38,7 +38,7 @@ public class SessionInvalidateAndCreateTest extends AbstractSessionInvalidateAnd
} }
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge,evictionPolicy); return new FileTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -40,7 +40,7 @@ public class SessionRenewTest extends AbstractSessionRenewTest
} }
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port, max, scavenge,evictionPolicy); return new FileTestServer(port, max, scavenge,evictionPolicy);
} }

View File

@ -38,7 +38,7 @@ public class SessionValueSharedSaving extends AbstractSessionValueSavingTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new FileTestServer(port,max,scavenge,evictionPolicy); return new FileTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -41,7 +41,7 @@ public class ClientCrossContextSessionTest extends AbstractClientCrossContextSes
} }
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -41,7 +41,7 @@ public class ForwardedSessionTest extends AbstractForwardedSessionTest
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -36,8 +36,9 @@ public class GCloudTestServer extends AbstractTestServer
* @param maxInactivePeriod * @param maxInactivePeriod
* @param scavengePeriod * @param scavengePeriod
* @param evictionPolicy * @param evictionPolicy
* @throws Exception TODO
*/ */
public GCloudTestServer(int port, int maxInactivePeriod, int scavengePeriod, int evictionPolicy) public GCloudTestServer(int port, int maxInactivePeriod, int scavengePeriod, int evictionPolicy) throws Exception
{ {
super(port, maxInactivePeriod, scavengePeriod, evictionPolicy); super(port, maxInactivePeriod, scavengePeriod, evictionPolicy);
} }

View File

@ -46,7 +46,7 @@ public class ImmediateSaveTest extends AbstractImmediateSaveTest
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy) return new GCloudTestServer(port, max, scavenge, evictionPolicy)
{ {

View File

@ -43,7 +43,7 @@ public class ImmortalSessionTest extends AbstractImmortalSessionTest
* @see org.eclipse.jetty.server.session.AbstractImmortalSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractImmortalSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -45,7 +45,7 @@ public class InvalidationSessionTest extends AbstractInvalidationSessionTest
* @see org.eclipse.jetty.server.session.AbstractInvalidationSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractInvalidationSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) throws Exception
{ {
GCloudTestServer server = new GCloudTestServer(port, maxInactive, scavengeInterval, evictionPolicy) GCloudTestServer server = new GCloudTestServer(port, maxInactive, scavengeInterval, evictionPolicy)
{ {

View File

@ -42,7 +42,7 @@ public class LastAccessTimeTest extends AbstractLastAccessTimeTest
* @see org.eclipse.jetty.server.session.AbstractLastAccessTimeTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractLastAccessTimeTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -43,7 +43,7 @@ public class LocalSessionScavengingTest extends AbstractLocalSessionScavengingTe
* @see org.eclipse.jetty.server.session.AbstractLocalSessionScavengingTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractLocalSessionScavengingTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -50,7 +50,7 @@ public class NewSessionTest extends AbstractNewSessionTest
* @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -44,7 +44,7 @@ public class OrphanedSessionTest extends AbstractOrphanedSessionTest
* @see org.eclipse.jetty.server.session.AbstractOrphanedSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractOrphanedSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -43,7 +43,7 @@ public class ReentrantRequestSessionTest extends AbstractReentrantRequestSession
* @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port,int max, int scavengePeriod,int evictionPolicy) public AbstractTestServer createServer(int port,int max, int scavengePeriod,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavengePeriod, evictionPolicy); return new GCloudTestServer(port, max, scavengePeriod, evictionPolicy);
} }

View File

@ -46,7 +46,7 @@ public class RemoveSessionTest extends AbstractRemoveSessionTest
* @see org.eclipse.jetty.server.session.AbstractRemoveSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractRemoveSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -44,7 +44,7 @@ public class SameNodeLoadTest extends AbstractSameNodeLoadTest
* @see org.eclipse.jetty.server.session.AbstractSameNodeLoadTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSameNodeLoadTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -39,7 +39,7 @@ public class ServerCrossContextSessionTest extends AbstractServerCrossContextSes
} }
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -48,7 +48,7 @@ public class SessionExpiryTest extends AbstractSessionExpiryTest
* @see org.eclipse.jetty.server.session.AbstractSessionExpiryTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionExpiryTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -43,7 +43,7 @@ public class SessionInvalidateAndCreateTest extends AbstractSessionInvalidateAnd
* @see org.eclipse.jetty.server.session.AbstractSessionInvalidateAndCreateTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionInvalidateAndCreateTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -43,7 +43,7 @@ public class SessionMigrationTest extends AbstractSessionMigrationTest
* @see org.eclipse.jetty.server.session.AbstractSessionMigrationTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionMigrationTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -47,7 +47,7 @@ public class SessionRenewTest extends AbstractSessionRenewTest
* @see org.eclipse.jetty.server.session.AbstractSessionRenewTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionRenewTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port,max, scavenge, evictionPolicy); return new GCloudTestServer(port,max, scavenge, evictionPolicy);
} }

View File

@ -42,7 +42,7 @@ public class SessionValueSavingTest extends AbstractSessionValueSavingTest
* @see org.eclipse.jetty.server.session.AbstractSessionValueSavingTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionValueSavingTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, max, scavenge, evictionPolicy); return new GCloudTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -60,7 +60,7 @@ public class StopSessionManagerPreserveSessionTest extends AbstractStopSessionMa
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs,int evictionPolicy) throws Exception
{ {
return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new GCloudTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -37,7 +37,7 @@ public class ClientCrossContextSessionTest extends AbstractClientCrossContextSes
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -31,7 +31,7 @@ public class EvictionFailureTest extends AbstractSessionEvictionFailureTest
* @see org.eclipse.jetty.server.session.AbstractTestBase#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractTestBase#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port, maxInactive, scavengeInterval, evictionPolicy); return new HashTestServer(port, maxInactive, scavengeInterval, evictionPolicy);
} }

View File

@ -25,7 +25,7 @@ public class HashTestServer extends AbstractTestServer
{ {
public HashTestServer(int port, int maxInactivePeriod, int scavengePeriod, int evictionPolicy) public HashTestServer(int port, int maxInactivePeriod, int scavengePeriod, int evictionPolicy) throws Exception
{ {
super(port, maxInactivePeriod, scavengePeriod, evictionPolicy); super(port, maxInactivePeriod, scavengePeriod, evictionPolicy);
} }

View File

@ -22,7 +22,7 @@ public class ImmortalSessionTest extends AbstractImmortalSessionTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -26,7 +26,7 @@ import org.junit.Test;
public class NewSessionTest extends AbstractNewSessionTest public class NewSessionTest extends AbstractNewSessionTest
{ {
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -30,7 +30,7 @@ public class ReentrantRequestSessionTest extends AbstractReentrantRequestSession
* @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port, max, scavenge, evictionPolicy); return new HashTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -34,7 +34,7 @@ public class RemoveSessionTest extends AbstractRemoveSessionTest
* @see org.eclipse.jetty.server.session.AbstractRemoveSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractRemoveSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer (port, max, scavenge, evictionPolicy); return new HashTestServer (port, max, scavenge, evictionPolicy);
} }

View File

@ -27,7 +27,7 @@ public class ScatterGunLoadTest extends AbstractScatterGunLoadTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -23,7 +23,7 @@ import org.junit.Test;
public class ServerCrossContextSessionTest extends AbstractServerCrossContextSessionTest public class ServerCrossContextSessionTest extends AbstractServerCrossContextSessionTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -22,7 +22,7 @@ public class SessionCookieTest extends AbstractSessionCookieTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port, max, scavenge, evictionPolicy); return new HashTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -24,7 +24,7 @@ public class SessionInvalidateAndCreateTest extends AbstractSessionInvalidateAnd
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -31,7 +31,7 @@ public class SessionRenewTest extends AbstractSessionRenewTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port, max, scavenge,evictionPolicy); return new HashTestServer(port, max, scavenge,evictionPolicy);
} }

View File

@ -22,7 +22,7 @@ public class SessionValueSharedSaving extends AbstractSessionValueSavingTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new HashTestServer(port,max,scavenge,evictionPolicy); return new HashTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -46,7 +46,7 @@ public class ClientCrossContextSessionTest extends AbstractClientCrossContextSes
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -51,7 +51,7 @@ public class ForwardedSessionTest extends AbstractForwardedSessionTest
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -47,7 +47,7 @@ public class ImmediateSaveTest extends AbstractImmediateSaveTest
} }
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
_server = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()) _server = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache())
{ {

View File

@ -56,7 +56,7 @@ public class ImmortalSessionTest extends AbstractImmortalSessionTest
* @see org.eclipse.jetty.server.session.AbstractImmortalSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractImmortalSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -31,7 +31,7 @@ public class InfinispanTestSessionServer extends AbstractTestServer
public InfinispanTestSessionServer(int port, int maxInactivePeriod, int scavengePeriod, int evictionPolicy, BasicCache config) public InfinispanTestSessionServer(int port, int maxInactivePeriod, int scavengePeriod, int evictionPolicy, BasicCache config) throws Exception
{ {
super(port, maxInactivePeriod, scavengePeriod, evictionPolicy, config); super(port, maxInactivePeriod, scavengePeriod, evictionPolicy, config);
} }

View File

@ -42,7 +42,7 @@ public class LastAccessTimeTest extends AbstractLastAccessTimeTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -51,7 +51,7 @@ public class LocalSessionScavengingTest extends AbstractLocalSessionScavengingTe
* @see org.eclipse.jetty.server.session.AbstractLocalSessionScavengingTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractLocalSessionScavengingTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -50,7 +50,7 @@ public class NewSessionTest extends AbstractNewSessionTest
* @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -49,7 +49,7 @@ public class ReentrantRequestSessionTest extends AbstractReentrantRequestSession
* @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port,int maxInactive, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port,int maxInactive, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactive, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactive, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -43,7 +43,7 @@ public class RemoveSessionTest extends AbstractRemoveSessionTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
InfinispanTestSessionServer s = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); InfinispanTestSessionServer s = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
return s; return s;

View File

@ -51,7 +51,7 @@ public class SameNodeLoadTest extends AbstractSameNodeLoadTest
* @see org.eclipse.jetty.server.session.AbstractSameNodeLoadTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSameNodeLoadTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port,int maxInactive, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port,int maxInactive, int scavenge, int evictionPolicy) throws Exception
{ {
InfinispanTestSessionServer server = new InfinispanTestSessionServer(port,maxInactive, scavenge, evictionPolicy, __testSupport.getCache()); InfinispanTestSessionServer server = new InfinispanTestSessionServer(port,maxInactive, scavenge, evictionPolicy, __testSupport.getCache());
return server; return server;

View File

@ -42,7 +42,7 @@ public class SessionExpiryTest extends AbstractSessionExpiryTest
} }
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
InfinispanTestSessionServer server = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); InfinispanTestSessionServer server = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
return server; return server;

View File

@ -50,7 +50,7 @@ public class SessionInvalidateAndCreateTest extends AbstractSessionInvalidateAnd
* @see org.eclipse.jetty.server.session.AbstractSessionInvalidateAndCreateTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionInvalidateAndCreateTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -48,7 +48,7 @@ public class SessionMigrationTest extends AbstractSessionMigrationTest
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -57,7 +57,7 @@ public class SessionRenewTest extends AbstractSessionRenewTest
* @see org.eclipse.jetty.server.session.AbstractSessionRenewTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionRenewTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -55,7 +55,7 @@ public class RemoteClientCrossContextSessionTest extends AbstractClientCrossCont
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -53,7 +53,7 @@ public class RemoteForwardedSessionTest extends AbstractForwardedSessionTest
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -50,7 +50,7 @@ public class RemoteImmediateSaveTest extends AbstractImmediateSaveTest
__testSupport.teardown(); __testSupport.teardown();
} }
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()) return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache())
{ {

View File

@ -59,7 +59,7 @@ public class RemoteImmortalSessionTest extends AbstractImmortalSessionTest
* @see org.eclipse.jetty.server.session.AbstractImmortalSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractImmortalSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -56,7 +56,7 @@ public class RemoteInvalidationSessionTest extends AbstractInvalidationSessionTe
* @see org.eclipse.jetty.server.session.AbstractInvalidationSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractInvalidationSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInterval, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInterval, int scavengeInterval, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInterval, scavengeInterval, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInterval, scavengeInterval, evictionPolicy, __testSupport.getCache());
} }

View File

@ -52,7 +52,7 @@ public class RemoteLastAccessTimeTest extends AbstractLastAccessTimeTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -53,7 +53,7 @@ public class RemoteLocalSessionScavengingTest extends AbstractLocalSessionScaven
* @see org.eclipse.jetty.server.session.AbstractLocalSessionScavengingTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractLocalSessionScavengingTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -53,7 +53,7 @@ public class RemoteNewSessionTest extends AbstractNewSessionTest
* @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -52,7 +52,7 @@ public class RemoteReentrantRequestSessionTest extends AbstractReentrantRequestS
* @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractReentrantRequestSessionTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactive, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactive, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -46,7 +46,7 @@ public class RemoteRemoveSessionTest extends AbstractRemoveSessionTest
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
InfinispanTestSessionServer s = new InfinispanTestSessionServer(port, max, scavenge,evictionPolicy, __testSupport.getCache()); InfinispanTestSessionServer s = new InfinispanTestSessionServer(port, max, scavenge,evictionPolicy, __testSupport.getCache());
return s; return s;

View File

@ -54,7 +54,7 @@ public class RemoteSameNodeLoadTest extends AbstractSameNodeLoadTest
* @see org.eclipse.jetty.server.session.AbstractSameNodeLoadTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSameNodeLoadTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavenge, int evictionPolicy) throws Exception
{ {
InfinispanTestSessionServer server = new InfinispanTestSessionServer(port, maxInactive, scavenge,evictionPolicy, __testSupport.getCache()); InfinispanTestSessionServer server = new InfinispanTestSessionServer(port, maxInactive, scavenge,evictionPolicy, __testSupport.getCache());
return server; return server;

View File

@ -45,7 +45,7 @@ public class RemoteSessionExpiryTest extends AbstractSessionExpiryTest
} }
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
InfinispanTestSessionServer server = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); InfinispanTestSessionServer server = new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
return server; return server;

View File

@ -53,7 +53,7 @@ public class RemoteSessionInvalidateAndCreateTest extends AbstractSessionInvalid
* @see org.eclipse.jetty.server.session.AbstractSessionInvalidateAndCreateTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionInvalidateAndCreateTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -51,7 +51,7 @@ public class RemoteSessionMigrationTest extends AbstractSessionMigrationTest
@Override @Override
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, maxInactiveMs, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -56,7 +56,7 @@ public class RemoteSessionRenewTest extends AbstractSessionRenewTest
* @see org.eclipse.jetty.server.session.AbstractSessionRenewTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionRenewTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache()); return new InfinispanTestSessionServer(port, max, scavenge, evictionPolicy, __testSupport.getCache());
} }

View File

@ -31,7 +31,7 @@ public class ClientCrossContextSessionTest extends AbstractClientCrossContextSes
{ {
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy); return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy);
} }

View File

@ -31,7 +31,7 @@ public class ForwardedSessionTest extends AbstractForwardedSessionTest
{ {
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy); return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy);
} }

View File

@ -39,7 +39,7 @@ public class ImmediateSaveTest extends AbstractImmediateSaveTest
} }
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
_server = new JdbcTestServer(port, max, scavenge, evictionPolicy) _server = new JdbcTestServer(port, max, scavenge, evictionPolicy)
{ {

View File

@ -29,7 +29,7 @@ import org.junit.Test;
public class ImmortalSessionTest extends AbstractImmortalSessionTest public class ImmortalSessionTest extends AbstractImmortalSessionTest
{ {
public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactiveMs, int scavengeMs, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy); return new JdbcTestServer(port, maxInactiveMs, scavengeMs, evictionPolicy);
} }

View File

@ -28,7 +28,7 @@ import org.junit.Test;
public class InvalidationSessionTest extends AbstractInvalidationSessionTest public class InvalidationSessionTest extends AbstractInvalidationSessionTest
{ {
public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy); return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy);
} }

View File

@ -79,12 +79,12 @@ public class JdbcTestServer extends AbstractTestServer
} }
public JdbcTestServer(int port, int maxInactivePeriod, int scavengePeriod, int idlePassivatePeriod, String connectionUrl) public JdbcTestServer(int port, int maxInactivePeriod, int scavengePeriod, int idlePassivatePeriod, String connectionUrl) throws Exception
{ {
super(port, maxInactivePeriod, scavengePeriod, idlePassivatePeriod); super(port, maxInactivePeriod, scavengePeriod, idlePassivatePeriod);
} }
public JdbcTestServer(int port, int maxInactivePeriod, int scavengePeriod, int idlePassivatePeriod) public JdbcTestServer(int port, int maxInactivePeriod, int scavengePeriod, int idlePassivatePeriod) throws Exception
{ {
super(port, maxInactivePeriod, scavengePeriod, idlePassivatePeriod); super(port, maxInactivePeriod, scavengePeriod, idlePassivatePeriod);
} }

View File

@ -26,7 +26,7 @@ import org.junit.Test;
*/ */
public class LastAccessTimeTest extends AbstractLastAccessTimeTest public class LastAccessTimeTest extends AbstractLastAccessTimeTest
{ {
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port,max,scavenge, evictionPolicy); return new JdbcTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -43,11 +43,18 @@ public class LocalSessionScavengingTest extends AbstractLocalSessionScavengingTe
} }
} }
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port,max,scavenge, evictionPolicy); return new JdbcTestServer(port,max,scavenge, evictionPolicy);
} }
@Test
public void testNoScavenging() throws Exception
{
super.testNoScavenging();
}
@Test @Test
public void testLocalSessionsScavenging() throws Exception public void testLocalSessionsScavenging() throws Exception
{ {

View File

@ -29,7 +29,7 @@ public class NewSessionTest extends AbstractNewSessionTest
/** /**
* @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractNewSessionTest#createServer(int, int, int, int)
*/ */
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port,max,scavenge, evictionPolicy); return new JdbcTestServer(port,max,scavenge, evictionPolicy);
} }

View File

@ -26,7 +26,7 @@ import org.junit.Test;
*/ */
public class OrphanedSessionTest extends AbstractOrphanedSessionTest public class OrphanedSessionTest extends AbstractOrphanedSessionTest
{ {
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port,max,scavenge,evictionPolicy); return new JdbcTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -35,7 +35,7 @@ public class ProxySerializationTest extends AbstractProxySerializationTest
* @see org.eclipse.jetty.server.session.AbstractProxySerializationTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractProxySerializationTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port, max, scavenge, evictionPolicy); return new JdbcTestServer(port, max, scavenge, evictionPolicy);
} }

View File

@ -28,7 +28,7 @@ import org.junit.Test;
public class ReentrantRequestSessionTest extends AbstractReentrantRequestSessionTest public class ReentrantRequestSessionTest extends AbstractReentrantRequestSessionTest
{ {
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port,max,scavenge,evictionPolicy); return new JdbcTestServer(port,max,scavenge,evictionPolicy);
} }

View File

@ -28,7 +28,7 @@ public class ServerCrossContextSessionTest extends AbstractServerCrossContextSes
{ {
@Override @Override
public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) public AbstractTestServer createServer(int port, int maxInactive, int scavengeInterval, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy); return new JdbcTestServer(port, maxInactive, scavengeInterval, evictionPolicy);
} }

View File

@ -36,7 +36,7 @@ public class SessionExpiryTest extends AbstractSessionExpiryTest
* @see org.eclipse.jetty.server.session.AbstractSessionExpiryTest#createServer(int, int, int, int) * @see org.eclipse.jetty.server.session.AbstractSessionExpiryTest#createServer(int, int, int, int)
*/ */
@Override @Override
public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) public AbstractTestServer createServer(int port, int max, int scavenge, int evictionPolicy) throws Exception
{ {
return new JdbcTestServer(port,max,scavenge, evictionPolicy); return new JdbcTestServer(port,max,scavenge, evictionPolicy);
} }

Some files were not shown because too many files have changed in this diff Show More