[jboss-cvs] JBossAS SVN: r75528 - projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Jul 9 03:47:17 EDT 2008
Author: alesj
Date: 2008-07-09 03:47:17 -0400 (Wed, 09 Jul 2008)
New Revision: 75528
Added:
projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/LRUPolicyCachingBasicKernelMetaDataRepository.java
projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/PolicyCachingBasicKernelMetaDataRepository.java
projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/TimedPolicyCachingBasicKernelMetaDataRepository.java
Log:
[JBMICROCONT-312]; add caching kernel metadata repository impls.
Added: projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/LRUPolicyCachingBasicKernelMetaDataRepository.java
===================================================================
--- projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/LRUPolicyCachingBasicKernelMetaDataRepository.java (rev 0)
+++ projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/LRUPolicyCachingBasicKernelMetaDataRepository.java 2008-07-09 07:47:17 UTC (rev 75528)
@@ -0,0 +1,79 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2006, JBoss Inc., and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* This is free software; you can redistribute it and/or modify it
+* under the terms of the GNU Lesser General Public License as
+* published by the Free Software Foundation; either version 2.1 of
+* the License, or (at your option) any later version.
+*
+* This software is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+* Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public
+* License along with this software; if not, write to the Free
+* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+*/
+package org.jboss.kernel.plugins.metadata.basic;
+
+import org.jboss.metadata.plugins.cache.CachePolicyFactory;
+import org.jboss.metadata.plugins.cache.ConcurrentLRUCachePolicyFactory;
+
+/**
+ * LRUPolicyCachingBasicKernelMetaDataRepository.
+ *
+ * @author <a href="ales.justin at jboss.com">Ales Justin</a>
+ */
+public class LRUPolicyCachingBasicKernelMetaDataRepository extends PolicyCachingBasicKernelMetaDataRepository
+{
+ private Integer min;
+ private Integer max;
+
+ public LRUPolicyCachingBasicKernelMetaDataRepository()
+ {
+ }
+
+ public LRUPolicyCachingBasicKernelMetaDataRepository(Integer min, Integer max)
+ {
+ this.min = min;
+ this.max = max;
+ }
+
+ protected CachePolicyFactory createCachePolicyFactory()
+ {
+ if (min == null)
+ min = parseInteger(readSystemProperty("LRUPolicyCaching.min", null));
+ if (max == null)
+ max = parseInteger(readSystemProperty("LRUPolicyCaching.max", null));
+
+ if (min == null || max == null)
+ throw new IllegalArgumentException("Missing min (" + min + ") or max (" + max + ").");
+
+ return new ConcurrentLRUCachePolicyFactory(min, max);
+ }
+
+ /**
+ * Set min.
+ *
+ * @param min the min
+ */
+ public void setMin(Integer min)
+ {
+ this.min = min;
+ }
+
+ /**
+ * set max.
+ *
+ * @param max the max
+ */
+ public void setMax(Integer max)
+ {
+ this.max = max;
+ }
+}
\ No newline at end of file
Copied: projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/PolicyCachingBasicKernelMetaDataRepository.java (from rev 75340, projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/CachingBasicKernelMetaDataRepository.java)
===================================================================
--- projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/PolicyCachingBasicKernelMetaDataRepository.java (rev 0)
+++ projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/PolicyCachingBasicKernelMetaDataRepository.java 2008-07-09 07:47:17 UTC (rev 75528)
@@ -0,0 +1,85 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2006, JBoss Inc., and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* This is free software; you can redistribute it and/or modify it
+* under the terms of the GNU Lesser General Public License as
+* published by the Free Software Foundation; either version 2.1 of
+* the License, or (at your option) any later version.
+*
+* This software is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+* Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public
+* License along with this software; if not, write to the Free
+* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+*/
+package org.jboss.kernel.plugins.metadata.basic;
+
+import java.security.AccessController;
+import java.security.PrivilegedAction;
+
+import org.jboss.metadata.plugins.cache.CacheFactory;
+import org.jboss.metadata.plugins.cache.CachePolicyCacheFactory;
+import org.jboss.metadata.plugins.cache.CachePolicyFactory;
+
+/**
+ * PolicyCachingBasicKernelMetaDataRepository.
+ *
+ * @author <a href="ales.justin at jboss.com">Ales Justin</a>
+ */
+public abstract class PolicyCachingBasicKernelMetaDataRepository extends CachingBasicKernelMetaDataRepository
+{
+ protected CacheFactory createCacheFactory()
+ {
+ return new CachePolicyCacheFactory(createCachePolicyFactory());
+ }
+
+ /**
+ * Create cache policy factory.
+ *
+ * @return the cache policy factory
+ */
+ protected abstract CachePolicyFactory createCachePolicyFactory();
+
+ /**
+ * Read system property.
+ *
+ * @param key the property key
+ * @param defaultValue the default value
+ * @return system property or default value
+ */
+ protected static String readSystemProperty(final String key, final String defaultValue)
+ {
+ SecurityManager sm = System.getSecurityManager();
+ if (sm == null)
+ return System.getProperty(key, defaultValue);
+ else
+ return AccessController.doPrivileged(new PrivilegedAction<String>()
+ {
+ public String run()
+ {
+ return System.getProperty(key, defaultValue);
+ }
+ });
+ }
+
+ /**
+ * Parse integer.
+ *
+ * @param value the string int value
+ * @return integer value of null
+ */
+ protected static Integer parseInteger(String value)
+ {
+ if (value == null)
+ return null;
+
+ return Integer.parseInt(value);
+ }
+}
\ No newline at end of file
Added: projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/TimedPolicyCachingBasicKernelMetaDataRepository.java
===================================================================
--- projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/TimedPolicyCachingBasicKernelMetaDataRepository.java (rev 0)
+++ projects/microcontainer/trunk/kernel/src/main/org/jboss/kernel/plugins/metadata/basic/TimedPolicyCachingBasicKernelMetaDataRepository.java 2008-07-09 07:47:17 UTC (rev 75528)
@@ -0,0 +1,100 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2006, JBoss Inc., and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* This is free software; you can redistribute it and/or modify it
+* under the terms of the GNU Lesser General Public License as
+* published by the Free Software Foundation; either version 2.1 of
+* the License, or (at your option) any later version.
+*
+* This software is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+* Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public
+* License along with this software; if not, write to the Free
+* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+*/
+package org.jboss.kernel.plugins.metadata.basic;
+
+import org.jboss.metadata.plugins.cache.CachePolicyFactory;
+import org.jboss.metadata.plugins.cache.TimedCachePolicyFactory;
+
+/**
+ * TimedPolicyCachingBasicKernelMetaDataRepository.
+ *
+ * @author <a href="ales.justin at jboss.com">Ales Justin</a>
+ */
+public class TimedPolicyCachingBasicKernelMetaDataRepository extends PolicyCachingBasicKernelMetaDataRepository
+{
+ private Integer defaultLifetime;
+ private Boolean threadSafe;
+ private Integer resolution;
+
+ public TimedPolicyCachingBasicKernelMetaDataRepository()
+ {
+ }
+
+ public TimedPolicyCachingBasicKernelMetaDataRepository(Integer defaultLifetime)
+ {
+ this(defaultLifetime, null, null);
+ }
+
+ public TimedPolicyCachingBasicKernelMetaDataRepository(Integer defaultLifetime, Boolean threadSafe, Integer resolution)
+ {
+ this.defaultLifetime = defaultLifetime;
+ this.threadSafe = threadSafe;
+ this.resolution = resolution;
+ }
+
+ protected CachePolicyFactory createCachePolicyFactory()
+ {
+ if (defaultLifetime == null)
+ defaultLifetime = parseInteger(readSystemProperty("TimedPolicyCaching.lifetime", null));
+ if (threadSafe == null)
+ threadSafe = Boolean.valueOf(readSystemProperty("TimedPolicyCaching.threadSafe", Boolean.TRUE.toString()));
+ if (resolution == null)
+ resolution = parseInteger(readSystemProperty("TimedPolicyCaching.resolution", null));
+
+ if (defaultLifetime == null)
+ return new TimedCachePolicyFactory();
+ else if (resolution != null)
+ return new TimedCachePolicyFactory(defaultLifetime, threadSafe, resolution);
+ else
+ return new TimedCachePolicyFactory(defaultLifetime);
+ }
+
+ /**
+ * Set default lifetime.
+ *
+ * @param defaultLifetime the default lifetime
+ */
+ public void setDefaultLifetime(Integer defaultLifetime)
+ {
+ this.defaultLifetime = defaultLifetime;
+ }
+
+ /**
+ * Set threadsafe flag.
+ *
+ * @param threadSafe the threadsafe flag
+ */
+ public void setThreadSafe(Boolean threadSafe)
+ {
+ this.threadSafe = threadSafe;
+ }
+
+ /**
+ * The resollution.
+ *
+ * @param resolution the resolution
+ */
+ public void setResolution(Integer resolution)
+ {
+ this.resolution = resolution;
+ }
+}
\ No newline at end of file
More information about the jboss-cvs-commits
mailing list