diff options
Diffstat (limited to 'rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateLoadbalancerTask.java')
-rw-r--r-- | rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateLoadbalancerTask.java | 307 |
1 files changed, 0 insertions, 307 deletions
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateLoadbalancerTask.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateLoadbalancerTask.java deleted file mode 100644 index 99e4c24d..00000000 --- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateLoadbalancerTask.java +++ /dev/null @@ -1,307 +0,0 @@ -/* - * 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.jk.status; - -import java.io.UnsupportedEncodingException; -import java.net.URLEncoder; - -import org.apache.tools.ant.BuildException; - -/** - * Ant task that implements the <code>/status</code> update loadbalancer command, supported by the - * mod_jk status (1.2.20) application. - * - * - * @author Peter Rossbach - * @version $Revision: 611693 $ - * @since mod_jk 1.2.20 - */ -public class JkStatusUpdateLoadbalancerTask extends AbstractJkStatusTask { - - /** - * The descriptive information about this implementation. - */ - private static final String info = "org.apache.jk.status.JkStatusUpdateLoadbalancerTask/1.0"; - - protected String loadbalancer ; - - protected int retries = -1; - protected int recoverWaitTime = -1; - protected int methodCode = -1; - protected String method; - - protected Boolean stickySession ; - - protected Boolean forceStickySession ; - - protected int lockCode = -1; - protected String lock; - protected int maxReplyTimeouts = -1; - - /** - * Return descriptive information about this implementation and the - * corresponding version number, in the format - * <code><description>/<version></code>. - */ - public String getInfo() { - - return (info); - - } - - /** - * - */ - public JkStatusUpdateLoadbalancerTask() { - super(); - setUrl("http://localhost/jkstatus"); - } - - /** - * @return the forceStickySession - */ - public Boolean getForceStickySession() { - return forceStickySession; - } - - /** - * @param forceStickySession the forceStickySession to set - */ - public void setForceStickySession(Boolean forceStickySession) { - this.forceStickySession = forceStickySession; - } - - /** - * @return the loadbalancer - */ - public String getLoadbalancer() { - return loadbalancer; - } - - /** - * @param loadbalancer the loadbalancer to set - */ - public void setLoadbalancer(String loadbalancer) { - this.loadbalancer = loadbalancer; - } - - - /** - * @return the locking - */ - public String getLock() { - return lock; - } - - /** - * @param locking the locking to set - */ - public void setLock(String locking) { - this.lock = locking; - } - - /** - * @return the lockingCode - */ - public int getLockCode() { - return lockCode; - } - - /** - * @param lockingCode the lockingCode to set - */ - public void setLockCode(int lockingCode) { - this.lockCode = lockingCode; - } - - /** - * @return the method - */ - public String getMethod() { - return method; - } - - /** - * @param method the method to set - */ - public void setMethod(String method) { - this.method = method; - } - - /** - * @return the methodCode - */ - public int getMethodCode() { - return methodCode; - } - - /** - * @param methodCode the methodCode to set - */ - public void setMethodCode(int methodCode) { - this.methodCode = methodCode; - } - - /** - * @return the recoverWaitTime - */ - public int getRecoverWaitTime() { - return recoverWaitTime; - } - - /** - * @param recoverWaitTime the recoverWaitTime to set - */ - public void setRecoverWaitTime(int recoverWaitTime) { - this.recoverWaitTime = recoverWaitTime; - } - - /** - * @return the retries - */ - public int getRetries() { - return retries; - } - - /** - * @param retries the retries to set - */ - public void setRetries(int retries) { - this.retries = retries; - } - - /** - * @return the stickySession - */ - public Boolean getStickySession() { - return stickySession; - } - - /** - * @param stickySession the stickySession to set - */ - public void setStickySession(Boolean stickySession) { - this.stickySession = stickySession; - } - - /** - * @return the maxReplyTimeouts - */ - public int getMaxReplyTimeouts() { - return maxReplyTimeouts; - } - - /** - * @param maxReplyTimeouts the maxReplyTimeouts to set - */ - public void setMaxReplyTimeouts(int maxReplyTimeouts) { - this.maxReplyTimeouts = maxReplyTimeouts; - } - - /** - * Create JkStatus worker update link - * <ul> - * </b>http://localhost/jkstatus?cmd=update&mime=txt&w=loadbalancer&vlm=1&vll=1&vlr=2&vlt=60&vls=true&vlf=false&vlx=0 - * <br/> - * - * - * <br/>Tcp worker parameter: - * <br/> - * <ul> - * <li><b>w:<b/> name loadbalancer</li> - * <li><b>vlm:<b/> method (lb strategy)</li> - * <li><b>vll:<b/> lock</li> - * <li><b>vlr:<b/> retries</li> - * <li><b>vlt:<b/> recover wait timeout</li> - * <li><b>vls:<b/> sticky session</li> - * <li><b>vlf:<b/> force sticky session</li> - * <li><b>vlx:<b/> max reply timeouts</li> - * </ul> - * <ul> - * <li>vlm=0 or Requests</li> - * <li>vlm=1 or Traffic</li> - * <li>vlm=2 or Busyness</li> - * <li>vlm=3 or Sessions</li> - * </ul> - * <ul> - * <li>vll=0 or Optimistic</li> - * <li>vll=1 or Pessimistic</li> - * </ul> - * - * @return create jkstatus update worker link - */ - protected StringBuffer createLink() { - // Building URL - StringBuffer sb = new StringBuffer(); - try { - sb.append("?cmd=update&mime=txt"); - sb.append("&w="); - sb.append(URLEncoder.encode(loadbalancer, getCharset())); - if (stickySession != null) { - sb.append("&vls="); - sb.append(stickySession); - } - if (forceStickySession != null) { - sb.append("&vlf="); - sb.append(forceStickySession); - } - if (retries >= 0) { - sb.append("&vlr="); - sb.append(retries); - } - if (recoverWaitTime >= 0) { - sb.append("&vlt="); - sb.append(recoverWaitTime); - } - if (method == null && methodCode >= 0 && methodCode < 4) { - sb.append("&vlm="); - sb.append(methodCode); - } - if (method != null) { - sb.append("&vlm="); - sb.append(method); - } - if (lock == null && lockCode >= 0 && lockCode < 2) { - sb.append("&vll="); - sb.append(lockCode); - } - if (lock != null) { - sb.append("&vll="); - sb.append(lock); - } - if (maxReplyTimeouts >= 0) { - sb.append("&vlx="); - sb.append(maxReplyTimeouts); - } - - } catch (UnsupportedEncodingException e) { - throw new BuildException("Invalid 'charset' attribute: " - + getCharset()); - } - return sb; - } - - /** - * check correct lb and worker pararmeter - */ - protected void checkParameter() { - if (loadbalancer == null) { - throw new BuildException("Must specify 'loadbalancer' attribute"); - } - } -} |