-/*-\r
- * ================================================================================\r
- * ECOMP Portal\r
- * ================================================================================\r
- * Copyright (C) 2017 AT&T Intellectual Property\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
- * ================================================================================\r
- */\r
-package org.openecomp.portalapp.portal.service;\r
-\r
-import java.util.HashMap;\r
-import java.util.List;\r
-import java.util.Map;\r
-\r
-import javax.annotation.PostConstruct;\r
-\r
-import org.springframework.beans.factory.annotation.Autowired;\r
-import org.springframework.context.annotation.EnableAspectJAutoProxy;\r
-import org.springframework.stereotype.Service;\r
-\r
-import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;\r
-import org.openecomp.portalapp.portal.domain.EPApp;\r
-import org.openecomp.portalapp.portal.logging.aop.EPMetricsLog;\r
-\r
-@Service("appsCacheService")\r
-@org.springframework.context.annotation.Configuration\r
-@EnableAspectJAutoProxy\r
-@EPMetricsLog\r
-public class AppsCacheServiceImple implements AppsCacheService {\r
- @Autowired\r
- EPAppService appsService;\r
- \r
- EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(AppsCacheServiceImple.class);\r
- \r
- final class CacheConfiguration {\r
- \r
- private long updateTime = 0;\r
- private int updateInterval = 10;\r
- \r
- public CacheConfiguration (long _updateTime, int _updateInterval) {\r
- updateTime = _updateTime;\r
- updateInterval = _updateInterval;\r
- }\r
- }\r
- \r
- CacheConfiguration appConf = null;\r
- CacheConfiguration analyticsAppConf = null;\r
- \r
- \r
- private static volatile Map<Long, EPApp> appsMap;\r
- private static volatile Map<String, EPApp> anlyticsAppsMap;\r
- \r
- @PostConstruct\r
- public void init() {\r
- appConf = new CacheConfiguration(0, 10);\r
- analyticsAppConf = new CacheConfiguration(0, 3600);\r
- \r
- this.refreshAppsMap(appConf);\r
- }\r
-\r
- private Map<Long, EPApp> refreshAppsMap(CacheConfiguration conf) {\r
- long now = System.currentTimeMillis();\r
- \r
- if(noNeedToUpdate(now, conf))\r
- return null;\r
- \r
- synchronized (this) {\r
- if(noNeedToUpdate(now, conf))\r
- return null;\r
- List<EPApp> allApps = appsService.getAppsFullList();\r
- Map<Long, EPApp> newAppsMap = new HashMap<Long, EPApp>();\r
- for (EPApp app : allApps) {\r
- newAppsMap.put(app.getId(), app);\r
- }\r
- \r
- Map<String, EPApp> newAnalyticsAppsMap = new HashMap<String, EPApp>();\r
- for (EPApp app : allApps) {\r
- newAnalyticsAppsMap.put(app.getUebKey(), app);\r
- }\r
- // Switch cache with the new one.\r
- appsMap = newAppsMap;\r
- anlyticsAppsMap = newAnalyticsAppsMap;\r
- conf.updateTime = now;\r
- }\r
- \r
- return appsMap;\r
- }\r
-\r
- private boolean noNeedToUpdate(long now, CacheConfiguration conf) {\r
- long secondsPassed = (now - conf.updateTime)/1000;\r
- if(secondsPassed < conf.updateInterval){\r
- logger.debug(EELFLoggerDelegate.debugLogger, "no need to refresh yet, seconds since last refresh: " + secondsPassed + ", refresh interval (sec) = " + conf.updateInterval);\r
- return true; // no need to update cache\r
- }\r
- return false; // its time to update\r
- }\r
-\r
- @Override\r
- public String getAppEndpoint(Long appId) {\r
- refreshAppsMap(appConf);\r
- EPApp app = appsMap.get(appId);\r
- if(app != null)\r
- return app.getAppRestEndpoint();\r
- return null;\r
- }\r
- \r
- @Override\r
- public EPApp getApp(Long appId) {\r
- refreshAppsMap(appConf);\r
- EPApp app = appsMap.get(appId);\r
- if(app != null)\r
- return app;\r
- return null; \r
- }\r
- \r
- @Override\r
- public EPApp getAppForAnalytics(String appKey) {\r
- refreshAppsMap(analyticsAppConf);\r
- EPApp app = anlyticsAppsMap.get(appKey);\r
- if(app != null)\r
- return app;\r
- return null; \r
- }\r
-\r
-}\r
+/*-
+ * ================================================================================
+ * ECOMP Portal
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ================================================================================
+ */
+package org.openecomp.portalapp.portal.service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
+import org.springframework.stereotype.Service;
+
+import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
+import org.openecomp.portalapp.portal.domain.EPApp;
+import org.openecomp.portalapp.portal.logging.aop.EPMetricsLog;
+
+@Service("appsCacheService")
+@org.springframework.context.annotation.Configuration
+@EnableAspectJAutoProxy
+@EPMetricsLog
+public class AppsCacheServiceImple implements AppsCacheService {
+ @Autowired
+ EPAppService appsService;
+
+ EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(AppsCacheServiceImple.class);
+
+ final class CacheConfiguration {
+
+ private long updateTime = 0;
+ private int updateInterval = 10;
+
+ public CacheConfiguration (long _updateTime, int _updateInterval) {
+ updateTime = _updateTime;
+ updateInterval = _updateInterval;
+ }
+ }
+
+ CacheConfiguration appConf = null;
+ CacheConfiguration analyticsAppConf = null;
+
+
+ private static volatile Map<Long, EPApp> appsMap;
+ private static volatile Map<String, EPApp> anlyticsAppsMap;
+
+ @PostConstruct
+ public void init() {
+ appConf = new CacheConfiguration(0, 10);
+ analyticsAppConf = new CacheConfiguration(0, 3600);
+
+ this.refreshAppsMap(appConf);
+ }
+
+ private Map<Long, EPApp> refreshAppsMap(CacheConfiguration conf) {
+ long now = System.currentTimeMillis();
+
+ if(noNeedToUpdate(now, conf))
+ return null;
+
+ synchronized (this) {
+ if(noNeedToUpdate(now, conf))
+ return null;
+ List<EPApp> allApps = appsService.getAppsFullList();
+ Map<Long, EPApp> newAppsMap = new HashMap<Long, EPApp>();
+ for (EPApp app : allApps) {
+ newAppsMap.put(app.getId(), app);
+ }
+
+ Map<String, EPApp> newAnalyticsAppsMap = new HashMap<String, EPApp>();
+ for (EPApp app : allApps) {
+ newAnalyticsAppsMap.put(app.getUebKey(), app);
+ }
+ // Switch cache with the new one.
+ appsMap = newAppsMap;
+ anlyticsAppsMap = newAnalyticsAppsMap;
+ conf.updateTime = now;
+ }
+
+ return appsMap;
+ }
+
+ private boolean noNeedToUpdate(long now, CacheConfiguration conf) {
+ long secondsPassed = (now - conf.updateTime)/1000;
+ if(secondsPassed < conf.updateInterval){
+ logger.debug(EELFLoggerDelegate.debugLogger, "no need to refresh yet, seconds since last refresh: " + secondsPassed + ", refresh interval (sec) = " + conf.updateInterval);
+ return true; // no need to update cache
+ }
+ return false; // its time to update
+ }
+
+ @Override
+ public String getAppEndpoint(Long appId) {
+ refreshAppsMap(appConf);
+ EPApp app = appsMap.get(appId);
+ if(app != null)
+ return app.getAppRestEndpoint();
+ return null;
+ }
+
+ @Override
+ public EPApp getApp(Long appId) {
+ refreshAppsMap(appConf);
+ EPApp app = appsMap.get(appId);
+ if(app != null)
+ return app;
+ return null;
+ }
+
+ @Override
+ public EPApp getAppForAnalytics(String appKey) {
+ refreshAppsMap(analyticsAppConf);
+ EPApp app = anlyticsAppsMap.get(appKey);
+ if(app != null)
+ return app;
+ return null;
+ }
+
+}
Code Review / portal.git / blobdiff