Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 7DEA2200BA8 for ; Mon, 24 Oct 2016 20:19:47 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7C2C0160B01; Mon, 24 Oct 2016 18:19:47 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 51EC3160AD7 for ; Mon, 24 Oct 2016 20:19:45 +0200 (CEST) Received: (qmail 83395 invoked by uid 500); 24 Oct 2016 18:19:44 -0000 Mailing-List: contact commits-help@geode.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.incubator.apache.org Delivered-To: mailing list commits@geode.incubator.apache.org Received: (qmail 83386 invoked by uid 99); 24 Oct 2016 18:19:44 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Oct 2016 18:19:44 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id C27AFC67A3 for ; Mon, 24 Oct 2016 18:19:43 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.219 X-Spam-Level: X-Spam-Status: No, score=-6.219 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id UgfUwy7fJt7H for ; Mon, 24 Oct 2016 18:19:38 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 66EC360DC8 for ; Mon, 24 Oct 2016 18:19:24 +0000 (UTC) Received: (qmail 68921 invoked by uid 99); 24 Oct 2016 18:16:47 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Oct 2016 18:16:47 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D1C9DE04BE; Mon, 24 Oct 2016 18:16:47 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: upthewaterspout@apache.org To: commits@geode.incubator.apache.org Date: Mon, 24 Oct 2016 18:17:33 -0000 Message-Id: <9119a3e56c5c48448a0b77193d9a1960@git.apache.org> In-Reply-To: <521baf94c6e9463a87555728650e7670@git.apache.org> References: <521baf94c6e9463a87555728650e7670@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [48/55] [abbrv] [partial] incubator-geode git commit: Added Spotless plugin to enforce formatting standards. Added Google Java Style guide formatter templates, removed existing formatter templates. archived-at: Mon, 24 Oct 2016 18:19:47 -0000 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java index f6378be..20cfeca 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/GemfireSessionManager.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter; @@ -52,8 +50,8 @@ import java.util.Map; import java.util.UUID; /** - * This class implements the session management using a Gemfire distributedCache - * as a persistent store for the session objects + * This class implements the session management using a Gemfire distributedCache as a persistent + * store for the session objects */ public class GemfireSessionManager implements SessionManager { @@ -89,16 +87,15 @@ public class GemfireSessionManager implements SessionManager { private boolean isStopping = false; /** - * Boolean indicating whether this manager is defined in the same context (war - * / classloader) as the filter. + * Boolean indicating whether this manager is defined in the same context (war / classloader) as + * the filter. */ private boolean isolated = false; /** * Map of wrapping GemFire session id to native session id */ - private Map nativeSessionMap = - new HashMap(); + private Map nativeSessionMap = new HashMap(); /** * MBean for statistics @@ -106,9 +103,8 @@ public class GemfireSessionManager implements SessionManager { private SessionStatistics mbean; /** - * This CL is used to compare against the class loader of attributes getting - * pulled out of the cache. This variable should be set to the CL of the - * filter running everything. + * This CL is used to compare against the class loader of attributes getting pulled out of the + * cache. This variable should be set to the CL of the filter running everything. */ private ClassLoader referenceClassLoader; @@ -123,21 +119,22 @@ public class GemfireSessionManager implements SessionManager { * Set up properties with default values */ private TypeAwareMap properties = - new TypeAwareMap(CacheProperty.class) {{ - put(CacheProperty.REGION_NAME, RegionHelper.NAME + "_sessions"); - put(CacheProperty.ENABLE_GATEWAY_DELTA_REPLICATION, Boolean.FALSE); - put(CacheProperty.ENABLE_GATEWAY_REPLICATION, Boolean.FALSE); - put(CacheProperty.ENABLE_DEBUG_LISTENER, Boolean.FALSE); - put(CacheProperty.STATISTICS_NAME, "gemfire_statistics"); - put(CacheProperty.SESSION_DELTA_POLICY, "delta_queued"); - put(CacheProperty.REPLICATION_TRIGGER, "set"); - /** - * For REGION_ATTRIBUTES_ID and ENABLE_LOCAL_CACHE the default - * is different for ClientServerCache and PeerToPeerCache - * so those values are set in the relevant constructors when - * these properties are passed in to them. - */ - }}; + new TypeAwareMap(CacheProperty.class) { + { + put(CacheProperty.REGION_NAME, RegionHelper.NAME + "_sessions"); + put(CacheProperty.ENABLE_GATEWAY_DELTA_REPLICATION, Boolean.FALSE); + put(CacheProperty.ENABLE_GATEWAY_REPLICATION, Boolean.FALSE); + put(CacheProperty.ENABLE_DEBUG_LISTENER, Boolean.FALSE); + put(CacheProperty.STATISTICS_NAME, "gemfire_statistics"); + put(CacheProperty.SESSION_DELTA_POLICY, "delta_queued"); + put(CacheProperty.REPLICATION_TRIGGER, "set"); + /** + * For REGION_ATTRIBUTES_ID and ENABLE_LOCAL_CACHE the default is different for + * ClientServerCache and PeerToPeerCache so those values are set in the relevant + * constructors when these properties are passed in to them. + */ + } + }; public GemfireSessionManager() { LOG = LoggerFactory.getLogger(GemfireSessionManager.class.getName()); @@ -161,8 +158,7 @@ public class GemfireSessionManager implements SessionManager { isolated = true; } - String sessionCookieName = config.getInitParameter( - INIT_PARAM_SESSION_COOKIE_NAME); + String sessionCookieName = config.getInitParameter(INIT_PARAM_SESSION_COOKIE_NAME); if (sessionCookieName != null && !sessionCookieName.isEmpty()) { this.sessionCookieName = sessionCookieName; LOG.info("Session cookie name set to: {}", this.sessionCookieName); @@ -173,8 +169,7 @@ public class GemfireSessionManager implements SessionManager { jvmId = DEFAULT_JVM_ID; } - LOG.info("Started GemfireSessionManager (isolated={}, jvmId={})", - isolated, jvmId); + LOG.info("Started GemfireSessionManager (isolated={}, jvmId={})", isolated, jvmId); } /** @@ -199,14 +194,12 @@ public class GemfireSessionManager implements SessionManager { */ @Override public HttpSession getSession(String id) { - GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get( - id); + GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(id); if (session != null) { if (session.justSerialized()) { session.setManager(this); - LOG.debug("Recovered serialized session {} (jvmId={})", id, - session.getJvmOwnerId()); + LOG.debug("Recovered serialized session {} (jvmId={})", id, session.getJvmOwnerId()); } LOG.debug("Retrieved session id {}", id); } else { @@ -221,28 +214,23 @@ public class GemfireSessionManager implements SessionManager { @Override public HttpSession wrapSession(HttpSession nativeSession) { String id = generateId(); - GemfireHttpSession session = - new GemfireHttpSession(id, nativeSession); + GemfireHttpSession session = new GemfireHttpSession(id, nativeSession); /** * Set up the attribute container depending on how things are configured */ AbstractSessionAttributes attributes; - if ("delta_queued".equals( - properties.get(CacheProperty.SESSION_DELTA_POLICY))) { + if ("delta_queued".equals(properties.get(CacheProperty.SESSION_DELTA_POLICY))) { attributes = new DeltaQueuedSessionAttributes(); - ((DeltaQueuedSessionAttributes) attributes).setReplicationTrigger( - (String) properties.get(CacheProperty.REPLICATION_TRIGGER)); - } else if ("delta_immediate".equals( - properties.get(CacheProperty.SESSION_DELTA_POLICY))) { + ((DeltaQueuedSessionAttributes) attributes) + .setReplicationTrigger((String) properties.get(CacheProperty.REPLICATION_TRIGGER)); + } else if ("delta_immediate".equals(properties.get(CacheProperty.SESSION_DELTA_POLICY))) { attributes = new DeltaSessionAttributes(); - } else if ("immediate".equals( - properties.get(CacheProperty.SESSION_DELTA_POLICY))) { + } else if ("immediate".equals(properties.get(CacheProperty.SESSION_DELTA_POLICY))) { attributes = new ImmediateSessionAttributes(); } else { attributes = new DeltaSessionAttributes(); - LOG.warn( - "No session delta policy specified - using default of 'delta_immediate'"); + LOG.warn("No session delta policy specified - using default of 'delta_immediate'"); } attributes.setSession(session); @@ -279,8 +267,7 @@ public class GemfireSessionManager implements SessionManager { public void destroySession(String id) { if (!isStopping) { try { - GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get( - id); + GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(id); if (session != null && session.getJvmOwnerId().equals(jvmId)) { LOG.debug("Destroying session {}", id); sessionCache.getOperatingRegion().destroy(id); @@ -299,8 +286,7 @@ public class GemfireSessionManager implements SessionManager { // Ignored } } else { - GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get( - id); + GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get(id); if (session != null) { session.setNativeSession(null); } @@ -338,13 +324,12 @@ public class GemfireSessionManager implements SessionManager { } /** - * This method is called when a native session gets destroyed. It will check - * if the GemFire session is actually still valid/not expired and will then - * attach a new, native session. + * This method is called when a native session gets destroyed. It will check if the GemFire + * session is actually still valid/not expired and will then attach a new, native session. * * @param nativeId the id of the native session - * @return the id of the newly attached native session or null if the GemFire - * session was already invalid + * @return the id of the newly attached native session or null if the GemFire session was already + * invalid */ public String refreshSession(String nativeId) { String gemfireId = getGemfireSessionIdFromNativeId(nativeId); @@ -352,8 +337,8 @@ public class GemfireSessionManager implements SessionManager { return null; } - GemfireHttpSession session = (GemfireHttpSession) sessionCache.getOperatingRegion().get( - gemfireId); + GemfireHttpSession session = + (GemfireHttpSession) sessionCache.getOperatingRegion().get(gemfireId); if (session.isValid()) { } @@ -399,27 +384,24 @@ public class GemfireSessionManager implements SessionManager { } else if (CACHE_TYPE_PEER_TO_PEER.equals(cacheType)) { distributedCache = PeerToPeerCache.getInstance(); } else { - LOG.error("No 'cache-type' initialization param set. " - + "Cache will not be started"); + LOG.error("No 'cache-type' initialization param set. " + "Cache will not be started"); return; } if (!distributedCache.isStarted()) { /** - * Process all the init params and see if any apply to the - * distributed system. + * Process all the init params and see if any apply to the distributed system. */ - for (Enumeration e = config.getInitParameterNames(); e.hasMoreElements(); ) { + for (Enumeration e = config.getInitParameterNames(); e.hasMoreElements();) { String param = e.nextElement(); if (!param.startsWith(GEMFIRE_PROPERTY)) { continue; } String gemfireProperty = param.substring(GEMFIRE_PROPERTY.length()); - LOG.info("Setting gemfire property: {} = {}", - gemfireProperty, config.getInitParameter(param)); - distributedCache.setProperty(gemfireProperty, + LOG.info("Setting gemfire property: {} = {}", gemfireProperty, config.getInitParameter(param)); + distributedCache.setProperty(gemfireProperty, config.getInitParameter(param)); } distributedCache.lifecycleEvent(LifecycleTypeAdapter.START); @@ -433,17 +415,16 @@ public class GemfireSessionManager implements SessionManager { // Retrieve the distributedCache GemFireCacheImpl cache = (GemFireCacheImpl) CacheFactory.getAnyInstance(); if (cache == null) { - throw new IllegalStateException("No cache exists. Please configure " - + "either a PeerToPeerCacheLifecycleListener or " - + "ClientServerCacheLifecycleListener in the " - + "server.xml file."); + throw new IllegalStateException( + "No cache exists. Please configure " + "either a PeerToPeerCacheLifecycleListener or " + + "ClientServerCacheLifecycleListener in the " + "server.xml file."); } /** * Process all the init params and see if any apply to the distributedCache */ ResourceManager rm = cache.getResourceManager(); - for (Enumeration e = config.getInitParameterNames(); e.hasMoreElements(); ) { + for (Enumeration e = config.getInitParameterNames(); e.hasMoreElements();) { String param = e.nextElement(); // Uggh - don't like this non-generic stuff @@ -463,15 +444,13 @@ public class GemfireSessionManager implements SessionManager { } String gemfireWebParam = param.substring(GEMFIRE_CACHE.length()); - LOG.info("Setting cache parameter: {} = {}", - gemfireWebParam, config.getInitParameter(param)); + LOG.info("Setting cache parameter: {} = {}", gemfireWebParam, config.getInitParameter(param)); properties.put(CacheProperty.valueOf(gemfireWebParam.toUpperCase()), config.getInitParameter(param)); } // Create the appropriate session distributedCache - sessionCache = cache.isClient() - ? new ClientServerSessionCache(cache, properties) + sessionCache = cache.isClient() ? new ClientServerSessionCache(cache, properties) : new PeerToPeerSessionCache(cache, properties); // Initialize the session distributedCache @@ -486,15 +465,12 @@ public class GemfireSessionManager implements SessionManager { try { InitialContext ctx = new InitialContext(); - MBeanServer mbs = MBeanServer.class.cast( - ctx.lookup("java:comp/env/jmx/runtime")); - ObjectName oname = new ObjectName( - Constants.SESSION_STATISTICS_MBEAN_NAME); + MBeanServer mbs = MBeanServer.class.cast(ctx.lookup("java:comp/env/jmx/runtime")); + ObjectName oname = new ObjectName(Constants.SESSION_STATISTICS_MBEAN_NAME); mbs.registerMBean(mbean, oname); } catch (Exception ex) { - LOG.warn("Unable to register statistics MBean. Error: {}", - ex.getMessage()); + LOG.warn("Unable to register statistics MBean. Error: {}", ex.getMessage()); } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java index cfb2d49..2e4337d 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/ListenerEventType.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter; @@ -25,51 +23,40 @@ public enum ListenerEventType { /** * HttpSessionAttributeListener */ - SESSION_ATTRIBUTE_ADDED, - SESSION_ATTRIBUTE_REMOVED, - SESSION_ATTRIBUTE_REPLACED, + SESSION_ATTRIBUTE_ADDED, SESSION_ATTRIBUTE_REMOVED, SESSION_ATTRIBUTE_REPLACED, /** * HttpSessionBindingListener */ - SESSION_VALUE_BOUND, - SESSION_VALUE_UNBOUND, + SESSION_VALUE_BOUND, SESSION_VALUE_UNBOUND, /** * HttpSessionListener */ - SESSION_CREATED, - SESSION_DESTROYED, + SESSION_CREATED, SESSION_DESTROYED, /** * HttpSessionActivationListener */ - SESSION_WILL_ACTIVATE, - SESSION_DID_PASSIVATE, + SESSION_WILL_ACTIVATE, SESSION_DID_PASSIVATE, /** * ServletContextListener */ - SERVLET_CONTEXT_INITIALIZED, - SERVLET_CONTEXT_DESTROYED, + SERVLET_CONTEXT_INITIALIZED, SERVLET_CONTEXT_DESTROYED, /** * ServletContextAttributeListener */ - SERVLET_CONTEXT_ATTRIBUTE_ADDED, - SERVLET_CONTEXT_ATTRIBUTE_REMOVED, - SERVLET_CONTEXT_ATTRIBUTE_REPLACED, + SERVLET_CONTEXT_ATTRIBUTE_ADDED, SERVLET_CONTEXT_ATTRIBUTE_REMOVED, SERVLET_CONTEXT_ATTRIBUTE_REPLACED, /** * ServletRequestListener */ - SERVLET_REQUEST_DESTROYED, - SERVLET_REQUEST_INITIALIZED, + SERVLET_REQUEST_DESTROYED, SERVLET_REQUEST_INITIALIZED, /** * ServletRequestAttributeListener */ - SERVLET_REQUEST_ATTRIBUTE_ADDED, - SERVLET_REQUEST_ATTRIBUTE_REMOVED, - SERVLET_REQUEST_ATTRIBUTE_REPLACED; + SERVLET_REQUEST_ATTRIBUTE_ADDED, SERVLET_REQUEST_ATTRIBUTE_REMOVED, SERVLET_REQUEST_ATTRIBUTE_REPLACED; } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java index c59624c..642c287 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/SessionManager.java @@ -1,27 +1,24 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter; import javax.servlet.http.HttpSession; /** - * Interface to session management. This class would be responsible for creating - * new sessions. + * Interface to session management. This class would be responsible for creating new sessions. */ public interface SessionManager { @@ -29,12 +26,10 @@ public interface SessionManager { * Start the manager possibly using the config passed in. * * @param config Config object specific to individual implementations. - * @param loader This is a hack. When the manager is started it wants to be - * able to determine if the cache, which it would create, and - * the filter which starts everything, are defined by the same - * classloader. This is so that during shutdown, the manager can - * decide whether or not to also stop the cache. This option - * allows the filter's classloader to be passed in. + * @param loader This is a hack. When the manager is started it wants to be able to determine if + * the cache, which it would create, and the filter which starts everything, are defined by + * the same classloader. This is so that during shutdown, the manager can decide whether or + * not to also stop the cache. This option allows the filter's classloader to be passed in. */ public void start(Object config, ClassLoader loader); @@ -67,9 +62,8 @@ public interface SessionManager { public HttpSession wrapSession(HttpSession nativeSession); /** - * Get the wrapped (GemFire) session from a native session id. This method - * would typically be used from within session/http event listeners which - * receive the original session id. + * Get the wrapped (GemFire) session from a native session id. This method would typically be used + * from within session/http event listeners which receive the original session id. * * @param nativeId * @return the wrapped GemFire session which maps the native session @@ -87,22 +81,20 @@ public interface SessionManager { * Destroy the session associated with a given native session * * @param id the id of the native session - * @return the corresponding Gemfire session which wrapped the native session - * and was destroyed. + * @return the corresponding Gemfire session which wrapped the native session and was destroyed. */ public String destroyNativeSession(String id); /** - * Returns the cookie name used to hold the session id. By default this is - * JSESSIONID. + * Returns the cookie name used to hold the session id. By default this is JSESSIONID. * * @return the name of the cookie which contains the session id */ public String getSessionCookieName(); /** - * Get the JVM Id - this is a unique string used internally to identify who - * last touched a session. + * Get the JVM Id - this is a unique string used internally to identify who last touched a + * session. * * @return the jvm id */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java index 0d36932..4d1f108 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractDeltaSessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -32,11 +30,10 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * This abstract class contains the structures and methods to handle delta - * updates to attributes. + * This abstract class contains the structures and methods to handle delta updates to attributes. */ -public abstract class AbstractDeltaSessionAttributes - extends AbstractSessionAttributes implements Delta { +public abstract class AbstractDeltaSessionAttributes extends AbstractSessionAttributes + implements Delta { private static final Logger LOG = LoggerFactory.getLogger(AbstractDeltaSessionAttributes.class.getName()); @@ -70,8 +67,7 @@ public abstract class AbstractDeltaSessionAttributes } @Override - public void fromDelta(DataInput in) - throws IOException, InvalidDeltaException { + public void fromDelta(DataInput in) throws IOException, InvalidDeltaException { maxInactiveInterval = in.readInt(); lastAccessedTime = in.readLong(); Map localDeltas = new HashMap(); @@ -87,8 +83,7 @@ public abstract class AbstractDeltaSessionAttributes return; } - LOG.debug("Processing {} delta events for {}", - localDeltas.size(), session); + LOG.debug("Processing {} delta events for {}", localDeltas.size(), session); for (DeltaEvent e : localDeltas.values()) { if (e.isUpdate()) { attributes.put(e.getName(), e.getValue()); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java index 4c4564c..6e0cbc4 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/AbstractSessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -33,9 +31,9 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * Abstract implementation for attributes. Should be sub-classed to provide - * differing implementations for synchronous or delta propagation. The backing - * store used is defined by the session manager. + * Abstract implementation for attributes. Should be sub-classed to provide differing + * implementations for synchronous or delta propagation. The backing store used is defined by the + * session manager. */ public abstract class AbstractSessionAttributes implements SessionAttributes { @@ -77,9 +75,8 @@ public abstract class AbstractSessionAttributes implements SessionAttributes { } /** - * {@inheritDoc} The actual de-serialization of any domain objects is deferred - * until the point at which they are actually retrieved by the application - * layer. + * {@inheritDoc} The actual de-serialization of any domain objects is deferred until the point at + * which they are actually retrieved by the application layer. */ @Override public Object getAttribute(String name) { @@ -92,8 +89,7 @@ public abstract class AbstractSessionAttributes implements SessionAttributes { value = BlobHelper.deserializeBlob((byte[]) value); attributes.put(name, value); } catch (Exception iox) { - LOG.error("Attribute '" + name + - " contains a byte[] that cannot be deserialized due " + LOG.error("Attribute '" + name + " contains a byte[] that cannot be deserialized due " + "to the following exception", iox); } } @@ -133,8 +129,8 @@ public abstract class AbstractSessionAttributes implements SessionAttributes { } /** - * {@inheritDoc} This method calls back into the session to flush the whole - * session including its attributes. + * {@inheritDoc} This method calls back into the session to flush the whole session including its + * attributes. */ @Override public void flush() { @@ -142,9 +138,8 @@ public abstract class AbstractSessionAttributes implements SessionAttributes { } /** - * Use DeltaEvents to propagate the actual attribute data - DeltaEvents turn - * the values into byte arrays which means that the actual domain classes are - * not required on the server. + * Use DeltaEvents to propagate the actual attribute data - DeltaEvents turn the values into byte + * arrays which means that the actual domain classes are not required on the server. */ @Override public void toData(DataOutput out) throws IOException { @@ -154,8 +149,7 @@ public abstract class AbstractSessionAttributes implements SessionAttributes { synchronized (attributes) { out.writeInt(attributes.size()); for (Map.Entry entry : attributes.entrySet()) { - DeltaEvent delta = new DeltaEvent(true, entry.getKey(), - entry.getValue()); + DeltaEvent delta = new DeltaEvent(true, entry.getKey(), entry.getValue()); DataSerializer.writeObject(delta, out); } } @@ -164,8 +158,7 @@ public abstract class AbstractSessionAttributes implements SessionAttributes { } @Override - public void fromData( - DataInput in) throws IOException, ClassNotFoundException { + public void fromData(DataInput in) throws IOException, ClassNotFoundException { maxInactiveInterval = in.readInt(); lastAccessedTime = in.readLong(); int size = in.readInt(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java index 2bffadc..68c6995 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaEvent.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -33,8 +31,7 @@ import java.io.IOException; */ public class DeltaEvent implements DataSerializable { - private static final Logger LOG = - LoggerFactory.getLogger(DeltaEvent.class.getName()); + private static final Logger LOG = LoggerFactory.getLogger(DeltaEvent.class.getName()); /** * The event is either an update (true) or a remove (false) */ @@ -49,15 +46,13 @@ public class DeltaEvent implements DataSerializable { /** * Constructor for de-serialization only */ - public DeltaEvent() { - } + public DeltaEvent() {} /** - * Constructor which creates a 'deferred' event. This is used when the value - * should only be applied when the object is serialized. + * Constructor which creates a 'deferred' event. This is used when the value should only be + * applied when the object is serialized. * - * @param session the session from which the value ultimately will be - * retrieved + * @param session the session from which the value ultimately will be retrieved * @param attribute the name of the attribute */ public DeltaEvent(GemfireHttpSession session, String attribute) { @@ -110,8 +105,7 @@ public class DeltaEvent implements DataSerializable { } @Override - public void fromData( - DataInput in) throws IOException, ClassNotFoundException { + public void fromData(DataInput in) throws IOException, ClassNotFoundException { update = in.readBoolean(); name = DataSerializer.readString(in); value = DataSerializer.readObject(in); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java index faa849d..a806515 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaQueuedSessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -23,9 +21,8 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * This class implements delayed attribute delta propagation. Updates to - * attributes are only propagated once the session goes out of scope - i.e. as - * the request is done being processed. + * This class implements delayed attribute delta propagation. Updates to attributes are only + * propagated once the session goes out of scope - i.e. as the request is done being processed. */ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes { @@ -35,28 +32,25 @@ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes private Trigger trigger = Trigger.SET; private enum Trigger { - SET, - SET_AND_GET; + SET, SET_AND_GET; } /** * Register ourselves for de-serialization */ static { - Instantiator.register( - new Instantiator(DeltaQueuedSessionAttributes.class, 3479) { - @Override - public DataSerializable newInstance() { - return new DeltaQueuedSessionAttributes(); - } - }); + Instantiator.register(new Instantiator(DeltaQueuedSessionAttributes.class, 3479) { + @Override + public DataSerializable newInstance() { + return new DeltaQueuedSessionAttributes(); + } + }); } /** * Default constructor */ - public DeltaQueuedSessionAttributes() { - } + public DeltaQueuedSessionAttributes() {} public void setReplicationTrigger(String trigger) { this.trigger = Trigger.valueOf(trigger.toUpperCase()); @@ -71,8 +65,8 @@ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes } /** - * {@inheritDoc} Put an attribute, setting the dirty flag. The changes are - * flushed at the end of filter processing. + * {@inheritDoc} Put an attribute, setting the dirty flag. The changes are flushed at the end of + * filter processing. */ @Override public Object putAttribute(String attr, Object value) { @@ -82,8 +76,8 @@ public class DeltaQueuedSessionAttributes extends AbstractDeltaSessionAttributes } /** - * {@inheritDoc} Remove an attribute, setting the dirty flag. The changes are - * flushed at the end of filter processing. + * {@inheritDoc} Remove an attribute, setting the dirty flag. The changes are flushed at the end + * of filter processing. */ @Override public Object removeAttribute(String attr) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java index 85723ec..010d4e3 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/DeltaSessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -23,13 +21,12 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * This class implements synchronous attribute delta propagation. Updates to - * attributes are immediately propagated. + * This class implements synchronous attribute delta propagation. Updates to attributes are + * immediately propagated. */ public class DeltaSessionAttributes extends AbstractDeltaSessionAttributes { - private static final Logger LOG = - LoggerFactory.getLogger(DeltaSessionAttributes.class.getName()); + private static final Logger LOG = LoggerFactory.getLogger(DeltaSessionAttributes.class.getName()); /** * Register ourselves for de-serialization @@ -46,12 +43,11 @@ public class DeltaSessionAttributes extends AbstractDeltaSessionAttributes { /** * Default constructor */ - public DeltaSessionAttributes() { - } + public DeltaSessionAttributes() {} /** - * {@inheritDoc} Put an attribute, setting the dirty flag and immediately - * flushing the delta queue. + * {@inheritDoc} Put an attribute, setting the dirty flag and immediately flushing the delta + * queue. */ @Override public Object putAttribute(String attr, Object value) { @@ -62,8 +58,8 @@ public class DeltaSessionAttributes extends AbstractDeltaSessionAttributes { } /** - * {@inheritDoc} Remove an attribute, setting the dirty flag and immediately - * flushing the delta queue. + * {@inheritDoc} Remove an attribute, setting the dirty flag and immediately flushing the delta + * queue. */ @Override public Object removeAttribute(String attr) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java index 15dd522..084be45 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/ImmediateSessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -24,9 +22,9 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * This class implements immediately transmitted attributes. All attributes are - * transmitted for every attribute update. This is bound to be a performance hit - * in some cases but ensures much higher data availability. + * This class implements immediately transmitted attributes. All attributes are transmitted for + * every attribute update. This is bound to be a performance hit in some cases but ensures much + * higher data availability. */ public class ImmediateSessionAttributes extends AbstractSessionAttributes { @@ -37,20 +35,18 @@ public class ImmediateSessionAttributes extends AbstractSessionAttributes { * Register ourselves for de-serialization */ static { - Instantiator.register( - new Instantiator(ImmediateSessionAttributes.class, 347) { - @Override - public DataSerializable newInstance() { - return new ImmediateSessionAttributes(); - } - }); + Instantiator.register(new Instantiator(ImmediateSessionAttributes.class, 347) { + @Override + public DataSerializable newInstance() { + return new ImmediateSessionAttributes(); + } + }); } /** * Default constructor */ - public ImmediateSessionAttributes() { - } + public ImmediateSessionAttributes() {} @Override public Object putAttribute(String attr, Object value) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java index e1aeb0b..374e81e 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/QueuedSessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -24,9 +22,8 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * This class implements an attribute container which delays sending updates - * until the session goes out of scope. All attributes are transmitted during - * the update. + * This class implements an attribute container which delays sending updates until the session goes + * out of scope. All attributes are transmitted during the update. */ public class QueuedSessionAttributes extends AbstractSessionAttributes { @@ -48,8 +45,7 @@ public class QueuedSessionAttributes extends AbstractSessionAttributes { /** * Default constructor */ - public QueuedSessionAttributes() { - } + public QueuedSessionAttributes() {} @Override public Object putAttribute(String attr, Object value) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java index a882712..4f4a2f8 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/attributes/SessionAttributes.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.attributes; @@ -23,10 +21,9 @@ import org.apache.geode.modules.session.internal.filter.GemfireHttpSession; import java.util.Set; /** - * Interface for session attribute storage. In reality, this interface is - * responsible for anything, in the session which needs to be propagated for - * caching - as such it also includes other 'attributes' such as - * maxInactiveInterval and lastAccessedTime + * Interface for session attribute storage. In reality, this interface is responsible for anything, + * in the session which needs to be propagated for caching - as such it also includes other + * 'attributes' such as maxInactiveInterval and lastAccessedTime */ public interface SessionAttributes extends DataSerializable { @@ -40,7 +37,7 @@ public interface SessionAttributes extends DataSerializable { /** * Set an attribute value. * - * @param attr the name of the attribute to set + * @param attr the name of the attribute to set * @param value the value for the attribute * @return the value object */ @@ -58,8 +55,7 @@ public interface SessionAttributes extends DataSerializable { * Remove the named attribute. * * @param attr the name of the attribute to remove - * @return the value of the attribute removed or null if the named attribute - * did not exist. + * @return the value of the attribute removed or null if the named attribute did not exist. */ public Object removeAttribute(String attr); @@ -111,8 +107,7 @@ public interface SessionAttributes extends DataSerializable { public String getJvmOwnerId(); /** - * Set the jvmId. This is set every time the attributes are flushed to the - * cache. + * Set the jvmId. This is set every time the attributes are flushed to the cache. * * @param jvmId */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java index dbd5894..9fe9e27 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/NamedThreadFactory.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.util; @@ -28,16 +26,14 @@ import java.util.logging.Logger; */ public class NamedThreadFactory implements ThreadFactory { - private static final Logger LOG = Logger.getLogger( - NamedThreadFactory.class.getName()); + private static final Logger LOG = Logger.getLogger(NamedThreadFactory.class.getName()); private final String id; private final AtomicLong serial = new AtomicLong(); /** - * Create a new thread factory, using the specified pool ID as a basis for - * naming each thread. + * Create a new thread factory, using the specified pool ID as a basis for naming each thread. * * @param poolID pool name/ID */ @@ -48,8 +44,8 @@ public class NamedThreadFactory implements ThreadFactory { /** * {@inheritDoc} *

- * This implementation sets the name of the thread, sets the thread to be a - * daemon thread, and adds an uncaught exception handler. + * This implementation sets the name of the thread, sets the thread to be a daemon thread, and + * adds an uncaught exception handler. */ @Override public Thread newThread(Runnable r) { @@ -59,8 +55,7 @@ public class NamedThreadFactory implements ThreadFactory { thr.setUncaughtExceptionHandler(new UncaughtExceptionHandler() { @Override public void uncaughtException(Thread t, Throwable e) { - LOG.log(Level.WARNING, - "Uncaught Exception in thread: " + t.getName(), e); + LOG.log(Level.WARNING, "Uncaught Exception in thread: " + t.getName(), e); } }); return thr; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java index 13af79c..31dd134 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/ThreadLocalSession.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.util; @@ -22,8 +20,7 @@ import javax.servlet.http.HttpSession; /** */ public class ThreadLocalSession { - private static ThreadLocal threadLocal = - new ThreadLocal(); + private static ThreadLocal threadLocal = new ThreadLocal(); public static HttpSession get() { return threadLocal.get(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java index 7000033..2a86a06 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/filter/util/TypeAwareMap.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.filter.util; @@ -40,8 +38,7 @@ public class TypeAwareMap extends HashMap { } else if (key.getClazz() == Integer.class) { return (Object) super.put(key, Integer.valueOf((String) value)); } else { - throw new IllegalArgumentException("Value is not of type " + - key.getClazz().getName()); + throw new IllegalArgumentException("Value is not of type " + key.getClazz().getName()); } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java index 5fba0a5..678b53e 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatistics.java @@ -1,19 +1,17 @@ /* -* Licensed to the Apache Software Foundation (ASF) under one or more -* contributor license agreements. See the NOTICE file distributed with -* this work for additional information regarding copyright ownership. -* The ASF licenses this file to You 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. -*/ + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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.apache.geode.modules.session.internal.jmx; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java index c219e3a..1821f62 100644 --- a/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java +++ b/extensions/geode-modules-session-internal/src/main/java/org/apache/geode/modules/session/internal/jmx/SessionStatisticsMXBean.java @@ -1,18 +1,16 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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 + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You 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 + * 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. + * 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.apache.geode.modules.session.internal.jmx;