User: biorn_steedom
Date: 01/04/20 16:11:57
Added: src/main/org/jboss/ejb/plugins
LRUStatefulContextCachePolicy.java
Log:
A new LRU cache policy specialized for stateful bean, with feature of removal of
timed out beans.
Revision Changes Path
1.1
jboss/src/main/org/jboss/ejb/plugins/LRUStatefulContextCachePolicy.java
Index: LRUStatefulContextCachePolicy.java
===================================================================
/*
* JBoss, the OpenSource EJB server
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.ejb.plugins;
import java.util.Iterator;
import org.jboss.util.TimerTask;
import org.jboss.ejb.DeploymentException;
import org.jboss.metadata.MetaData;
import org.w3c.dom.Element;
/**
* Least Recently Used cache policy for StatefulSessionEnterpriseContexts.
*
* @author Simone Bordet ([EMAIL PROTECTED])
* @version $Revision: 1.1 $
*/
public class LRUStatefulContextCachePolicy extends LRUEnterpriseContextCachePolicy
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/* The age after which a bean is automatically removed */
private long m_maxBeanLife;
/* The remover timer task */
private TimerTask m_remover;
/* The period of the remover's runs */
private long m_removerPeriod;
/* The stateful cache */
private StatefulSessionInstanceCache m_cache;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
/**
* Creates a LRU cache policy object given the instance cache that use
* this policy object.
*/
public LRUStatefulContextCachePolicy(AbstractInstanceCache eic)
{
super(eic);
m_cache = (StatefulSessionInstanceCache)eic;
}
// Public --------------------------------------------------------
// Monitorable implementation ------------------------------------
// Z implementation ----------------------------------------------
public void start() throws Exception
{
super.start();
if (m_maxBeanLife > 0)
{
m_remover = new RemoverTask(m_removerPeriod);
scheduler.schedule(m_remover, (long)(Math.random() *
m_removerPeriod));
}
}
public void stop()
{
if (m_remover != null) {m_remover.cancel();}
super.stop();
}
/**
* Reads from the configuration the parameters for this cache policy, that are
* all optionals.
*/
public void importXml(Element element) throws DeploymentException
{
super.importXml(element);
String rp =
MetaData.getElementContent(MetaData.getOptionalChild(element, "remover-period"));
String ml =
MetaData.getElementContent(MetaData.getOptionalChild(element, "max-bean-life"));
try
{
if (rp != null)
{
int p = Integer.parseInt(rp);
if (p <= 0) {throw new DeploymentException("Remover
period can't be <= 0");}
m_removerPeriod = p * 1000;
}
if (ml != null)
{
int a = Integer.parseInt(ml);
if (a <= 0) {throw new DeploymentException("Max bean
life can't be <= 0");}
m_maxBeanLife = a * 1000;
}
}
catch (NumberFormatException x)
{
throw new DeploymentException("Can't parse policy
configuration", x);
}
}
// Y overrides ---------------------------------------------------
// Package protected ---------------------------------------------
// Protected -----------------------------------------------------
// Private -------------------------------------------------------
// Inner classes -------------------------------------------------
/**
* This TimerTask removes beans that have not been called for a while.
*/
protected class RemoverTask extends OveragerTask
{
protected RemoverTask(long period)
{
super(period);
}
protected String getTaskLogMessage() {return "Removing from cache
bean";}
protected String getJMSTaskType() {return "REMOVER";}
protected void kickOut(LRUCacheEntry entry) {remove(entry.m_key);}
protected long getMaxAge() {return m_maxBeanLife;}
public void execute()
{
synchronized (m_cache.getCacheLock())
{
// Remove beans from cache, if present
super.execute();
// Now remove passivated beans
m_cache.removePassivated(getMaxAge() -
super.getMaxAge());
}
}
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
