Author: markt Date: Sat Mar 6 09:34:08 2010 New Revision: 919724 URL: http://svn.apache.org/viewvc?rev=919724&view=rev Log: Tabs to 8 spaces - no functional change
Modified: tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOn.java tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOnListener.java tomcat/trunk/java/org/apache/catalina/ha/authenticator/SingleSignOnMessage.java Modified: tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOn.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOn.java?rev=919724&r1=919723&r2=919724&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOn.java (original) +++ tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOn.java Sat Mar 6 09:34:08 2010 @@ -124,24 +124,24 @@ Cluster cluster = getCluster(); // stop remove cluster binding if(cluster == null) { - Container host = getContainer(); - if(host != null && host instanceof Host) { - cluster = host.getCluster(); - if(cluster != null && cluster instanceof CatalinaCluster) { - setCluster((CatalinaCluster) cluster); - getCluster().addClusterListener(clusterSSOListener); - } else { - Container engine = host.getParent(); - if(engine != null && engine instanceof Engine) { - cluster = engine.getCluster(); - if(cluster != null && cluster instanceof CatalinaCluster) { - setCluster((CatalinaCluster) cluster); - getCluster().addClusterListener(clusterSSOListener); - } - } else { - cluster = null; - } - } + Container host = getContainer(); + if(host != null && host instanceof Host) { + cluster = host.getCluster(); + if(cluster != null && cluster instanceof CatalinaCluster) { + setCluster((CatalinaCluster) cluster); + getCluster().addClusterListener(clusterSSOListener); + } else { + Container engine = host.getParent(); + if(engine != null && engine instanceof Engine) { + cluster = engine.getCluster(); + if(cluster != null && cluster instanceof CatalinaCluster) { + setCluster((CatalinaCluster) cluster); + getCluster().addClusterListener(clusterSSOListener); + } + } else { + cluster = null; + } + } } } if (cluster == null) { @@ -190,31 +190,31 @@ @Override protected void associate(String ssoId, Session session) { - if (cluster != null) { - messageNumber++; - SingleSignOnMessage msg = - new SingleSignOnMessage(cluster.getLocalMember(), - ssoId, session.getId()); - Manager mgr = session.getManager(); - if ((mgr != null) && (mgr instanceof ClusterManager)) - msg.setContextName(((ClusterManager) mgr).getName()); - - msg.setAction(SingleSignOnMessage.ADD_SESSION); - - cluster.sendClusterDomain(msg); - - if (containerLog.isDebugEnabled()) - containerLog.debug("SingleSignOnMessage Send with action " - + msg.getAction()); - } + if (cluster != null) { + messageNumber++; + SingleSignOnMessage msg = + new SingleSignOnMessage(cluster.getLocalMember(), + ssoId, session.getId()); + Manager mgr = session.getManager(); + if ((mgr != null) && (mgr instanceof ClusterManager)) + msg.setContextName(((ClusterManager) mgr).getName()); + + msg.setAction(SingleSignOnMessage.ADD_SESSION); + + cluster.sendClusterDomain(msg); + + if (containerLog.isDebugEnabled()) + containerLog.debug("SingleSignOnMessage Send with action " + + msg.getAction()); + } - associateLocal(ssoId, session); + associateLocal(ssoId, session); } protected void associateLocal(String ssoId, Session session) { - super.associate(ssoId, session); + super.associate(ssoId, session); } @@ -230,30 +230,30 @@ @Override protected void deregister(String ssoId, Session session) { - if (cluster != null) { - messageNumber++; - SingleSignOnMessage msg = - new SingleSignOnMessage(cluster.getLocalMember(), - ssoId, session.getId()); - Manager mgr = session.getManager(); - if ((mgr != null) && (mgr instanceof ClusterManager)) - msg.setContextName(((ClusterManager) mgr).getName()); - - msg.setAction(SingleSignOnMessage.DEREGISTER_SESSION); - - cluster.sendClusterDomain(msg); - if (containerLog.isDebugEnabled()) - containerLog.debug("SingleSignOnMessage Send with action " - + msg.getAction()); - } + if (cluster != null) { + messageNumber++; + SingleSignOnMessage msg = + new SingleSignOnMessage(cluster.getLocalMember(), + ssoId, session.getId()); + Manager mgr = session.getManager(); + if ((mgr != null) && (mgr instanceof ClusterManager)) + msg.setContextName(((ClusterManager) mgr).getName()); + + msg.setAction(SingleSignOnMessage.DEREGISTER_SESSION); + + cluster.sendClusterDomain(msg); + if (containerLog.isDebugEnabled()) + containerLog.debug("SingleSignOnMessage Send with action " + + msg.getAction()); + } - deregisterLocal(ssoId, session); + deregisterLocal(ssoId, session); } protected void deregisterLocal(String ssoId, Session session) { - super.deregister(ssoId, session); + super.deregister(ssoId, session); } @@ -268,26 +268,26 @@ @Override protected void deregister(String ssoId) { - if (cluster != null) { - messageNumber++; - SingleSignOnMessage msg = - new SingleSignOnMessage(cluster.getLocalMember(), - ssoId, null); - msg.setAction(SingleSignOnMessage.LOGOUT_SESSION); - - cluster.sendClusterDomain(msg); - if (containerLog.isDebugEnabled()) - containerLog.debug("SingleSignOnMessage Send with action " - + msg.getAction()); - } + if (cluster != null) { + messageNumber++; + SingleSignOnMessage msg = + new SingleSignOnMessage(cluster.getLocalMember(), + ssoId, null); + msg.setAction(SingleSignOnMessage.LOGOUT_SESSION); + + cluster.sendClusterDomain(msg); + if (containerLog.isDebugEnabled()) + containerLog.debug("SingleSignOnMessage Send with action " + + msg.getAction()); + } - deregisterLocal(ssoId); + deregisterLocal(ssoId); } protected void deregisterLocal(String ssoId) { - super.deregister(ssoId); + super.deregister(ssoId); } @@ -307,30 +307,30 @@ protected void register(String ssoId, Principal principal, String authType, String username, String password) { - if (cluster != null) { - messageNumber++; - SingleSignOnMessage msg = - new SingleSignOnMessage(cluster.getLocalMember(), - ssoId, null); - msg.setAction(SingleSignOnMessage.REGISTER_SESSION); - msg.setAuthType(authType); - msg.setUsername(username); - msg.setPassword(password); - - cluster.sendClusterDomain(msg); - if (containerLog.isDebugEnabled()) - containerLog.debug("SingleSignOnMessage Send with action " - + msg.getAction()); - } + if (cluster != null) { + messageNumber++; + SingleSignOnMessage msg = + new SingleSignOnMessage(cluster.getLocalMember(), + ssoId, null); + msg.setAction(SingleSignOnMessage.REGISTER_SESSION); + msg.setAuthType(authType); + msg.setUsername(username); + msg.setPassword(password); + + cluster.sendClusterDomain(msg); + if (containerLog.isDebugEnabled()) + containerLog.debug("SingleSignOnMessage Send with action " + + msg.getAction()); + } - registerLocal(ssoId, principal, authType, username, password); + registerLocal(ssoId, principal, authType, username, password); } protected void registerLocal(String ssoId, Principal principal, String authType, String username, String password) { - super.register(ssoId, principal, authType, username, password); + super.register(ssoId, principal, authType, username, password); } @@ -365,30 +365,30 @@ protected void update(String ssoId, Principal principal, String authType, String username, String password) { - if (cluster != null) { - messageNumber++; - SingleSignOnMessage msg = - new SingleSignOnMessage(cluster.getLocalMember(), - ssoId, null); - msg.setAction(SingleSignOnMessage.UPDATE_SESSION); - msg.setAuthType(authType); - msg.setUsername(username); - msg.setPassword(password); - - cluster.sendClusterDomain(msg); - if (containerLog.isDebugEnabled()) - containerLog.debug("SingleSignOnMessage Send with action " - + msg.getAction()); - } + if (cluster != null) { + messageNumber++; + SingleSignOnMessage msg = + new SingleSignOnMessage(cluster.getLocalMember(), + ssoId, null); + msg.setAction(SingleSignOnMessage.UPDATE_SESSION); + msg.setAuthType(authType); + msg.setUsername(username); + msg.setPassword(password); + + cluster.sendClusterDomain(msg); + if (containerLog.isDebugEnabled()) + containerLog.debug("SingleSignOnMessage Send with action " + + msg.getAction()); + } - updateLocal(ssoId, principal, authType, username, password); + updateLocal(ssoId, principal, authType, username, password); } protected void updateLocal(String ssoId, Principal principal, String authType, String username, String password) { - super.update(ssoId, principal, authType, username, password); + super.update(ssoId, principal, authType, username, password); } @@ -403,31 +403,31 @@ @Override protected void removeSession(String ssoId, Session session) { - if (cluster != null) { - messageNumber++; - SingleSignOnMessage msg = - new SingleSignOnMessage(cluster.getLocalMember(), - ssoId, session.getId()); - - Manager mgr = session.getManager(); - if ((mgr != null) && (mgr instanceof ClusterManager)) - msg.setContextName(((ClusterManager) mgr).getName()); - - msg.setAction(SingleSignOnMessage.REMOVE_SESSION); - - cluster.sendClusterDomain(msg); - if (containerLog.isDebugEnabled()) - containerLog.debug("SingleSignOnMessage Send with action " - + msg.getAction()); - } + if (cluster != null) { + messageNumber++; + SingleSignOnMessage msg = + new SingleSignOnMessage(cluster.getLocalMember(), + ssoId, session.getId()); + + Manager mgr = session.getManager(); + if ((mgr != null) && (mgr instanceof ClusterManager)) + msg.setContextName(((ClusterManager) mgr).getName()); + + msg.setAction(SingleSignOnMessage.REMOVE_SESSION); + + cluster.sendClusterDomain(msg); + if (containerLog.isDebugEnabled()) + containerLog.debug("SingleSignOnMessage Send with action " + + msg.getAction()); + } - removeSessionLocal(ssoId, session); + removeSessionLocal(ssoId, session); } protected void removeSessionLocal(String ssoId, Session session) { - super.removeSession(ssoId, session); - + super.removeSession(ssoId, session); + } } Modified: tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOnListener.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOnListener.java?rev=919724&r1=919723&r2=919724&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOnListener.java (original) +++ tomcat/trunk/java/org/apache/catalina/ha/authenticator/ClusterSingleSignOnListener.java Sat Mar 6 09:34:08 2010 @@ -83,44 +83,44 @@ if (myobj != null && myobj instanceof SingleSignOnMessage) { SingleSignOnMessage msg = (SingleSignOnMessage) myobj; int action = msg.getAction(); - Session session = null; + Session session = null; - if (log.isDebugEnabled()) - log.debug("SingleSignOnMessage Received with action " - + msg.getAction()); - - switch(action) { - case SingleSignOnMessage.ADD_SESSION: - session = getSession(msg.getSessionId(), - msg.getContextName()); - if (session != null) - clusterSSO.associateLocal(msg.getSsoId(), session); - break; - case SingleSignOnMessage.DEREGISTER_SESSION: - session = getSession(msg.getSessionId(), - msg.getContextName()); - if (session != null) - clusterSSO.deregisterLocal(msg.getSsoId(), session); - break; - case SingleSignOnMessage.LOGOUT_SESSION: - clusterSSO.deregisterLocal(msg.getSsoId()); - break; - case SingleSignOnMessage.REGISTER_SESSION: - clusterSSO.registerLocal(msg.getSsoId(), null, msg.getAuthType(), - msg.getUsername(), msg.getPassword()); - break; - case SingleSignOnMessage.UPDATE_SESSION: - clusterSSO.updateLocal(msg.getSsoId(), null, msg.getAuthType(), - msg.getUsername(), msg.getPassword()); - break; - case SingleSignOnMessage.REMOVE_SESSION: - session = getSession(msg.getSessionId(), - msg.getContextName()); - if (session != null) - clusterSSO.removeSessionLocal(msg.getSsoId(), session); - break; - } - } + if (log.isDebugEnabled()) + log.debug("SingleSignOnMessage Received with action " + + msg.getAction()); + + switch(action) { + case SingleSignOnMessage.ADD_SESSION: + session = getSession(msg.getSessionId(), + msg.getContextName()); + if (session != null) + clusterSSO.associateLocal(msg.getSsoId(), session); + break; + case SingleSignOnMessage.DEREGISTER_SESSION: + session = getSession(msg.getSessionId(), + msg.getContextName()); + if (session != null) + clusterSSO.deregisterLocal(msg.getSsoId(), session); + break; + case SingleSignOnMessage.LOGOUT_SESSION: + clusterSSO.deregisterLocal(msg.getSsoId()); + break; + case SingleSignOnMessage.REGISTER_SESSION: + clusterSSO.registerLocal(msg.getSsoId(), null, msg.getAuthType(), + msg.getUsername(), msg.getPassword()); + break; + case SingleSignOnMessage.UPDATE_SESSION: + clusterSSO.updateLocal(msg.getSsoId(), null, msg.getAuthType(), + msg.getUsername(), msg.getPassword()); + break; + case SingleSignOnMessage.REMOVE_SESSION: + session = getSession(msg.getSessionId(), + msg.getContextName()); + if (session != null) + clusterSSO.removeSessionLocal(msg.getSsoId(), session); + break; + } + } } /** @@ -139,44 +139,44 @@ private Session getSession(String sessionId, String ctxname) { - - Map<String,ClusterManager> managers = clusterSSO.getCluster().getManagers(); - Session session = null; - - if (ctxname == null) { - java.util.Iterator<String> i = managers.keySet().iterator(); - while (i.hasNext()) { - String key = i.next(); - ClusterManager mgr = managers.get(key); - if (mgr != null) { - try { - session = mgr.findSession(sessionId); - } catch (IOException io) { - log.error("Session doesn't exist:" + io); - } - return session; - } else { - //this happens a lot before the system has started - // up - if (log.isDebugEnabled()) - log.debug("Context manager doesn't exist:" - + key); - } - } - } else { - ClusterManager mgr = managers.get(ctxname); - if (mgr != null) { - try { - session = mgr.findSession(sessionId); - } catch (IOException io) { - log.error("Session doesn't exist:" + io); - } - return session; - } else if (log.isErrorEnabled()) - log.error("Context manager doesn't exist:" + ctxname); - } + + Map<String,ClusterManager> managers = clusterSSO.getCluster().getManagers(); + Session session = null; + + if (ctxname == null) { + java.util.Iterator<String> i = managers.keySet().iterator(); + while (i.hasNext()) { + String key = i.next(); + ClusterManager mgr = managers.get(key); + if (mgr != null) { + try { + session = mgr.findSession(sessionId); + } catch (IOException io) { + log.error("Session doesn't exist:" + io); + } + return session; + } else { + //this happens a lot before the system has started + // up + if (log.isDebugEnabled()) + log.debug("Context manager doesn't exist:" + + key); + } + } + } else { + ClusterManager mgr = managers.get(ctxname); + if (mgr != null) { + try { + session = mgr.findSession(sessionId); + } catch (IOException io) { + log.error("Session doesn't exist:" + io); + } + return session; + } else if (log.isErrorEnabled()) + log.error("Context manager doesn't exist:" + ctxname); + } - return null; + return null; } } Modified: tomcat/trunk/java/org/apache/catalina/ha/authenticator/SingleSignOnMessage.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/ha/authenticator/SingleSignOnMessage.java?rev=919724&r1=919723&r2=919724&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/ha/authenticator/SingleSignOnMessage.java (original) +++ tomcat/trunk/java/org/apache/catalina/ha/authenticator/SingleSignOnMessage.java Sat Mar 6 09:34:08 2010 @@ -49,11 +49,11 @@ private String uniqueId = null; public SingleSignOnMessage(Member source, - String ssoId, - String sessionId) { + String ssoId, + String sessionId) { this.address = source; - this.ssoId = ssoId; - this.sessionId = sessionId; + this.ssoId = ssoId; + this.sessionId = sessionId; } /** @@ -62,7 +62,7 @@ * that originally sent it. */ public Member getAddress() { - return address; + return address; } /** @@ -72,7 +72,7 @@ * @param member Member */ public void setAddress(Member member) { - this.address = member; + this.address = member; } /** @@ -101,12 +101,12 @@ * @return String */ public String getUniqueId() { - if (this.uniqueId != null) - return this.uniqueId; - StringBuilder result = new StringBuilder(getSsoId()); - result.append("#-#"); - result.append(System.currentTimeMillis()); - return result.toString(); + if (this.uniqueId != null) + return this.uniqueId; + StringBuilder result = new StringBuilder(getSsoId()); + result.append("#-#"); + result.append(System.currentTimeMillis()); + return result.toString(); } public void setUniqueId(String uniqueId) { @@ -114,59 +114,59 @@ } public int getAction() { - return action; + return action; } public void setAction(int action) { - this.action = action; + this.action = action; } public String getSsoId() { - return ssoId; + return ssoId; } public void setSsoId(String ssoId) { - this.ssoId = ssoId; + this.ssoId = ssoId; } public String getContextName() { - return ctxname; + return ctxname; } public void setContextName(String ctxname) { - this.ctxname = ctxname; + this.ctxname = ctxname; } public String getSessionId() { - return sessionId; + return sessionId; } public void setSessionId(String sessionId) { - this.sessionId = sessionId; + this.sessionId = sessionId; } public String getAuthType() { - return authType; + return authType; } public void setAuthType(String authType) { - this.authType = authType; + this.authType = authType; } public String getPassword() { - return password; + return password; } public void setPassword(String password) { - this.password = password; + this.password = password; } public String getUsername() { - return username; + return username; } public void setUsername(String username) { - this.username = username; + this.username = username; } @@ -179,9 +179,9 @@ public String toString() { StringBuilder sb = new StringBuilder("SingleSignOnMessage[action="); - sb.append(getAction()).append(", ssoId=").append(getSsoId()); - sb.append(", sessionId=").append(getSessionId()).append(", username="); - sb.append(getUsername()).append("]"); + sb.append(getAction()).append(", ssoId=").append(getSsoId()); + sb.append(", sessionId=").append(getSessionId()).append(", username="); + sb.append(getUsername()).append("]"); return (sb.toString()); } --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org