+++ /dev/null
-/*******************************************************************************\r
- * ============LICENSE_START====================================================\r
- * * org.onap.aaf\r
- * * ===========================================================================\r
- * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
- * * ===========================================================================\r
- * * Licensed under the Apache License, Version 2.0 (the "License");\r
- * * you may not use this file except in compliance with the License.\r
- * * You may obtain a copy of the License at\r
- * * \r
- * * http://www.apache.org/licenses/LICENSE-2.0\r
- * * \r
- * * Unless required by applicable law or agreed to in writing, software\r
- * * distributed under the License is distributed on an "AS IS" BASIS,\r
- * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * * See the License for the specific language governing permissions and\r
- * * limitations under the License.\r
- * * ============LICENSE_END====================================================\r
- * *\r
- * * ECOMP is a trademark and service mark of AT&T Intellectual Property.\r
- * *\r
- ******************************************************************************/\r
-package org.onap.aaf.cache;\r
-\r
-import java.util.ArrayList;\r
-import java.util.Date;\r
-import java.util.HashMap;\r
-import java.util.HashSet;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.Set;\r
-import java.util.Timer;\r
-import java.util.TimerTask;\r
-import java.util.concurrent.ConcurrentHashMap;\r
-import java.util.logging.Level;\r
-\r
-import org.onap.aaf.inno.env.Env;\r
-import org.onap.aaf.inno.env.Trans;\r
-\r
-/**\r
- * Create and maintain a Map of Maps used for Caching\r
- * \r
- *\r
- * @param <TRANS>\r
- * @param <DATA>\r
- */\r
-public class Cache<TRANS extends Trans, DATA> {\r
- private static Clean clean;\r
- private static Timer cleanseTimer;\r
-\r
- public static final String CACHE_HIGH_COUNT = "CACHE_HIGH_COUNT";\r
- public static final String CACHE_CLEAN_INTERVAL = "CACHE_CLEAN_INTERVAL";\r
-// public static final String CACHE_MIN_REFRESH_INTERVAL = "CACHE_MIN_REFRESH_INTERVAL";\r
-\r
- private static final Map<String,Map<String,Dated>> cacheMap;\r
-\r
- static {\r
- cacheMap = new HashMap<String,Map<String,Dated>>();\r
- }\r
-\r
- /**\r
- * Dated Class - store any Data with timestamp\r
- * \r
- *\r
- */\r
- public final static class Dated { \r
- public Date timestamp;\r
- public List<?> data;\r
- \r
- public Dated(List<?> data) {\r
- timestamp = new Date();\r
- this.data = data;\r
- }\r
-\r
- public <T> Dated(T t) {\r
- timestamp = new Date();\r
- ArrayList<T> al = new ArrayList<T>(1);\r
- al.add(t);\r
- data = al;\r
- }\r
-\r
- public void touch() {\r
- timestamp = new Date();\r
- }\r
- }\r
- \r
- public static Map<String,Dated> obtain(String key) {\r
- Map<String, Dated> m = cacheMap.get(key);\r
- if(m==null) {\r
- m = new ConcurrentHashMap<String, Dated>();\r
- synchronized(cacheMap) {\r
- cacheMap.put(key, m);\r
- }\r
- }\r
- return m;\r
- }\r
-\r
- /**\r
- * Clean will examine resources, and remove those that have expired.\r
- * \r
- * If "highs" have been exceeded, then we'll expire 10% more the next time. This will adjust after each run\r
- * without checking contents more than once, making a good average "high" in the minimum speed.\r
- * \r
- *\r
- */\r
- private final static class Clean extends TimerTask {\r
- private final Env env;\r
- private Set<String> set;\r
- \r
- // The idea here is to not be too restrictive on a high, but to Expire more items by \r
- // shortening the time to expire. This is done by judiciously incrementing "advance"\r
- // when the "highs" are exceeded. This effectively reduces numbers of cached items quickly.\r
- private final int high;\r
- private long advance;\r
- private final long timeInterval;\r
- \r
- public Clean(Env env, long cleanInterval, int highCount) {\r
- this.env = env;\r
- high = highCount;\r
- timeInterval = cleanInterval;\r
- advance = 0;\r
- set = new HashSet<String>();\r
- }\r
- \r
- public synchronized void add(String key) {\r
- set.add(key);\r
- }\r
-\r
- public void run() {\r
- int count = 0;\r
- int total = 0;\r
- // look at now. If we need to expire more by increasing "now" by "advance"\r
- Date now = new Date(System.currentTimeMillis() + advance);\r
- \r
- \r
- for(String name : set) {\r
- Map<String,Dated> map = cacheMap.get(name);\r
- if(map!=null) for(Map.Entry<String,Dated> me : map.entrySet()) {\r
- ++total;\r
- if(me.getValue().timestamp.before(now)) {\r
- map.remove(me.getKey());\r
- ++count;\r
- }\r
- }\r
-// if(count>0) {\r
-// env.info().log(Level.INFO, "Cache removed",count,"expired",name,"Elements");\r
-// }\r
- }\r
- \r
- if(count>0) {\r
- env.info().log(Level.INFO, "Cache removed",count,"expired Cached Elements out of", total);\r
- }\r
-\r
- // If High (total) is reached during this period, increase the number of expired services removed for next time.\r
- // There's no point doing it again here, as there should have been cleaned items.\r
- if(total>high) {\r
- // advance cleanup by 10%, without getting greater than timeInterval.\r
- advance = Math.min(timeInterval, advance+(timeInterval/10));\r
- } else {\r
- // reduce advance by 10%, without getting lower than 0.\r
- advance = Math.max(0, advance-(timeInterval/10));\r
- }\r
- }\r
- }\r
-\r
- public static synchronized void startCleansing(Env env, String ... keys) {\r
- if(cleanseTimer==null) {\r
- cleanseTimer = new Timer("Cache Cleanup Timer");\r
- int cleanInterval = Integer.parseInt(env.getProperty(CACHE_CLEAN_INTERVAL,"60000")); // 1 minute clean cycles \r
- int highCount = Integer.parseInt(env.getProperty(CACHE_HIGH_COUNT,"5000"));\r
- cleanseTimer.schedule(clean = new Clean(env, cleanInterval, highCount), cleanInterval, cleanInterval);\r
- }\r
- \r
- for(String key : keys) {\r
- clean.add(key);\r
- }\r
- }\r
-\r
- public static void stopTimer() {\r
- if(cleanseTimer!=null) {\r
- cleanseTimer.cancel();\r
- cleanseTimer = null;\r
- }\r
- }\r
-\r
- public static void addShutdownHook() {\r
- Runtime.getRuntime().addShutdownHook(new Thread() {\r
- @Override\r
- public void run() {\r
- Cache.stopTimer();\r
- }\r
- }); \r
- }\r
-\r
-}\r
Code Review / aaf / authz.git / blobdiff