summaryrefslogtreecommitdiffstats
path: root/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share
diff options
context:
space:
mode:
Diffstat (limited to 'rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share')
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/AbstractJkStatusTask.java209
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancer.java335
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMapping.java98
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMember.java516
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkResult.java54
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkServer.java56
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkSoftware.java54
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatus.java90
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusAccessor.java133
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusParser.java228
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusResetTask.java133
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusTask.java735
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateLoadbalancerTask.java307
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateTask.java529
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateWorkerTask.java291
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/LocalStrings.properties15
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/antlib.xml34
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/jkstatus.tasks22
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/mbeans-descriptors.xml48
-rw-r--r--rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/package.html224
20 files changed, 0 insertions, 4111 deletions
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/AbstractJkStatusTask.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/AbstractJkStatusTask.java
deleted file mode 100644
index c94258ae..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/AbstractJkStatusTask.java
+++ /dev/null
@@ -1,209 +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.BufferedOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.net.HttpURLConnection;
-import java.net.MalformedURLException;
-import java.net.ProtocolException;
-import java.net.URL;
-import java.net.URLConnection;
-
-import org.apache.catalina.ant.AbstractCatalinaTask;
-import org.apache.catalina.util.Base64;
-import org.apache.tools.ant.BuildException;
-import org.apache.tools.ant.Project;
-
-/**
- * Ant task that implements mod_jk 1.2.20 result message string
- *
- * @author Peter Rossbach
- * @version $Revision: 802231 $
- * @since mod_jk 1.2.20
- */
-public abstract class AbstractJkStatusTask extends AbstractCatalinaTask {
-
- /**
- * Execute the requested operation.
- *
- * @exception BuildException
- * if an error occurs
- */
- public void execute() throws BuildException {
-
- super.execute();
- checkParameter();
- StringBuffer sb = createLink();
- execute(sb.toString(), null, null, -1);
-
- }
-
- protected abstract void checkParameter() ;
- protected abstract StringBuffer createLink() ;
-
- /**
- * Execute the specified command, based on the configured properties.
- * The input stream will be closed upon completion of this task, whether
- * it was executed successfully or not.
- *
- * @param command Command to be executed
- * @param istream InputStream to include in an HTTP PUT, if any
- * @param contentType Content type to specify for the input, if any
- * @param contentLength Content length to specify for the input, if any
- *
- * @exception BuildException if an error occurs
- */
- public void execute(String command, InputStream istream,
- String contentType, int contentLength)
- throws BuildException {
-
- InputStreamReader reader = null;
- try {
-
- HttpURLConnection hconn = send(command, istream, contentType, contentLength);
-
- // Process the response message
- reader = new InputStreamReader(hconn.getInputStream(), "UTF-8");
- String error = null;
- error = handleResult(reader, error);
- if (error != null && isFailOnError()) {
- // exception should be thrown only if failOnError == true
- // or error line will be logged twice
- throw new BuildException(error);
- }
- } catch (Throwable t) {
- if (isFailOnError()) {
- throw new BuildException(t);
- } else {
- handleErrorOutput(t.getMessage());
- }
- } finally {
- closeRedirector();
- if (reader != null) {
- try {
- reader.close();
- } catch (Throwable u) {
- ;
- }
- reader = null;
- }
- if (istream != null) {
- try {
- istream.close();
- } catch (Throwable u) {
- ;
- }
- istream = null;
- }
- }
-
- }
-
- private String handleResult(InputStreamReader reader, String error) throws IOException {
- StringBuffer buff = new StringBuffer();
- int msgPriority = Project.MSG_INFO;
- boolean first = true;
- while (true) {
- int ch = reader.read();
- if (ch < 0) {
- break;
- } else if ((ch == '\r') || (ch == '\n')) {
- // in Win \r\n would cause handleOutput() to be called
- // twice, the second time with an empty string,
- // producing blank lines
- if (buff.length() > 0) {
- String line = buff.toString();
- buff.setLength(0);
- if (first) {
- if (!line.startsWith("Result: type=OK")) {
- error = line;
- msgPriority = Project.MSG_ERR;
- }
- first = false;
- }
- handleOutput(line, msgPriority);
- }
- } else {
- buff.append((char) ch);
- }
- }
- if (buff.length() > 0) {
- handleOutput(buff.toString(), msgPriority);
- }
- return error;
- }
-
- protected HttpURLConnection send(String command, InputStream istream, String contentType, int contentLength) throws IOException, MalformedURLException, ProtocolException {
- URLConnection conn;
- // Create a connection for this command
- conn = (new URL(url + command)).openConnection();
- HttpURLConnection hconn = (HttpURLConnection) conn;
-
- // Set up standard connection characteristics
- hconn.setAllowUserInteraction(false);
- hconn.setDoInput(true);
- hconn.setUseCaches(false);
- if (istream != null) {
- hconn.setDoOutput(true);
- hconn.setRequestMethod("PUT");
- if (contentType != null) {
- hconn.setRequestProperty("Content-Type", contentType);
- }
- if (contentLength >= 0) {
- hconn.setRequestProperty("Content-Length",
- "" + contentLength);
- }
- } else {
- hconn.setDoOutput(false);
- hconn.setRequestMethod("GET");
- }
- hconn.setRequestProperty("User-Agent",
- "JkStatus-Ant-Task/1.1");
-
- // Set up an authorization header with our credentials
- String input = username + ":" + password;
- String output = new String(Base64.encode(input.getBytes()));
- hconn.setRequestProperty("Authorization",
- "Basic " + output);
-
- // Establish the connection with the server
- hconn.connect();
- // Send the request data (if any)
- if (istream != null) {
- BufferedOutputStream ostream =
- new BufferedOutputStream(hconn.getOutputStream(), 1024);
- byte buffer[] = new byte[1024];
- while (true) {
- int n = istream.read(buffer);
- if (n < 0) {
- break;
- }
- ostream.write(buffer, 0, n);
- }
- ostream.flush();
- ostream.close();
- istream.close();
- }
- return hconn;
- }
-
-
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancer.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancer.java
deleted file mode 100644
index f9e4f7ad..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancer.java
+++ /dev/null
@@ -1,335 +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.Serializable;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 500555 $ $Date: 2007-01-27 16:59:41 +0100 (Sat, 27 Jan 2007) $
- * @see org.apache.jk.status.JkStatusParser
- */
-public class JkBalancer implements Serializable {
-
- int id =-1;
- String name ;
- String type ;
- boolean sticky ;
- boolean stickyforce;
- int retries ;
- int recover ;
- String method ;
- String lock ;
- int good = -1 ;
- int degraded = -1;
- int bad = -1 ;
- int busy = -1;
- int max_busy = -1 ;
- int member_count = -1 ;
- int map_count = -1 ;
- int time_to_maintenance_min = -1 ;
- int time_to_maintenance_max = -1 ;
-
- List members = new ArrayList() ;
- List mappings = new ArrayList() ;
-
- /**
- * @return Returns the id.
- */
- public int getId() {
- return id;
- }
- /**
- * @param id The id to set.
- */
- public void setId(int id) {
- this.id = id;
- }
- /**
- * @return Returns the mappings.
- */
- public List getBalancerMappings() {
- return mappings;
- }
- /**
- * @param mappings The mappings to set.
- */
- public void setBalancerMappings(List mappings) {
- this.mappings = mappings;
- }
- public void addBalancerMapping(JkBalancerMapping mapping) {
- mappings.add(mapping);
- }
- public void removeBalancerMapping(JkBalancerMapping mapping) {
- mappings.remove(mapping);
- }
- /**
- * @return Returns the members.
- */
- public List getBalancerMembers() {
- return members;
- }
- /**
- * @param members The members to set.
- */
- public void setBalancerMembers(List members) {
- this.members = members;
- }
- public void addBalancerMember(JkBalancerMember member) {
- members.add(member);
- }
- public void removeBalancerMember(JkBalancerMember member) {
- members.remove(member);
- }
- /**
- * @return Returns the name.
- */
- public String getName() {
- return name;
- }
- /**
- * @param name The name to set.
- */
- public void setName(String name) {
- this.name = name;
- }
- /**
- * @return Returns the recover.
- */
- public int getRecover_time() {
- return recover;
- }
- /**
- * @param recover The recover to set.
- */
- public void setRecover_time(int recover) {
- this.recover = recover;
- }
- /**
- * @return Returns the retries.
- */
- public int getRetries() {
- return retries;
- }
- /**
- * @param retries The retries to set.
- */
- public void setRetries(int retries) {
- this.retries = retries;
- }
- /**
- * @return Returns the sticky.
- */
- public boolean isSticky_session() {
- return sticky;
- }
- /**
- * @param sticky The sticky to set.
- */
- public void setSticky_session(boolean sticky) {
- this.sticky = sticky;
- }
- /**
- * @return Returns the stickyforce.
- */
- public boolean isSticky_session_force() {
- return stickyforce;
- }
- /**
- * @param stickyforce The stickyforce to set.
- */
- public void setSticky_session_force(boolean stickyforce) {
- this.stickyforce = stickyforce;
- }
- /**
- * @return Returns the type.
- */
- public String getType() {
- return type;
- }
- /**
- * @param type The type to set.
- */
- public void setType(String type) {
- this.type = type;
- }
- /**
- * @return the bad
- * @since mod_jk 1.2.20
- */
- public int getBad() {
- return bad;
- }
- /**
- * @param bad the bad to set
- * @since mod_jk 1.2.20
- */
- public void setBad(int bad) {
- this.bad = bad;
- }
- /**
- * @return the busy
- * @since mod_jk 1.2.20
- */
- public int getBusy() {
- return busy;
- }
- /**
- * @param busy the busy to set
- * @since mod_jk 1.2.20
- */
- public void setBusy(int busy) {
- this.busy = busy;
- }
- /**
- * @return the degraded
- * @since mod_jk 1.2.20
- */
- public int getDegraded() {
- return degraded;
- }
- /**
- * @param degraded the degraded to set
- * @since mod_jk 1.2.20
- */
- public void setDegraded(int degraded) {
- this.degraded = degraded;
- }
- /**
- * @return the good
- * @since mod_jk 1.2.20
- */
- public int getGood() {
- return good;
- }
- /**
- * @param good the good to set
- * @since mod_jk 1.2.20
- */
- public void setGood(int good) {
- this.good = good;
- }
- /**
- * @return the lock
- * @since mod_jk 1.2.20
- */
- public String getLock() {
- return lock;
- }
- /**
- * @param lock the lock to set
- * @since mod_jk 1.2.20
- */
- public void setLock(String lock) {
- this.lock = lock;
- }
- /**
- * @return the max_busy
- * @since mod_jk 1.2.20
- */
- public int getMax_busy() {
- return max_busy;
- }
- /**
- * @param max_busy the max_busy to set
- * @since mod_jk 1.2.20
- */
- public void setMax_busy(int max_busy) {
- this.max_busy = max_busy;
- }
- /**
- * @return the method
- * @since mod_jk 1.2.20
- */
- public String getMethod() {
- return method;
- }
- /**
- * @param method the method to set
- * @since mod_jk 1.2.20
- */
- public void setMethod(String method) {
- this.method = method;
- }
-
- /**
- * @return the member_count
- * @since mod_jk 1.2.20
- */
- public int getMember_count() {
- return member_count;
- }
-
- /**
- * @param member_count the member_count to set
- * @since mod_jk 1.2.20
- */
- public void setMember_count(int member_count) {
- this.member_count = member_count;
- }
-
- /**
- * @return the map_count
- * @since mod_jk 1.2.20
- */
- public int getMap_count() {
- return map_count;
- }
-
- /**
- * @param map_count the map_count to set
- * @since mod_jk 1.2.20
- */
- public void setMap_count(int map_count) {
- this.map_count = map_count;
- }
-
- /**
- * @return the time_to_maintenance_min
- * @since mod_jk 1.2.21
- */
- public int getTime_to_maintenance_min() {
- return time_to_maintenance_min;
- }
-
- /**
- * @param time_to_maintenance_min the time_to_maintenance_min to set
- * @since mod_jk 1.2.21
- */
- public void setTime_to_maintenance_min(int time_to_maintenance_min) {
- this.time_to_maintenance_min = time_to_maintenance_min;
- }
-
- /**
- * @return the time_to_maintenance_max
- * @since mod_jk 1.2.21
- */
- public int getTime_to_maintenance_max() {
- return time_to_maintenance_max;
- }
-
- /**
- * @param time_to_maintenance_max the time_to_maintenance_max to set
- * @since mod_jk 1.2.21
- */
- public void setTime_to_maintenance_max(int time_to_maintenance_max) {
- this.time_to_maintenance_max = time_to_maintenance_max;
- }
-
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMapping.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMapping.java
deleted file mode 100644
index 5d4ef836..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMapping.java
+++ /dev/null
@@ -1,98 +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.Serializable;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 485242 $ $Date: 2006-12-10 20:45:39 +0100 (Sun, 10 Dec 2006) $
- * @see org.apache.jk.status.JkStatusParser
- */
-public class JkBalancerMapping implements Serializable {
- int id =-1 ;
- String type ;
- String uri;
- String context ;
- String source ;
-
- /**
- * @return the id
- */
- public int getId() {
- return id;
- }
- /**
- * @param id the id to set
- */
- public void setId(int id) {
- this.id = id;
- }
- /**
- * @return Returns the context.
- * @deprecated mod_jk 1.2.20
- */
- public String getContext() {
- return context;
- }
- /**
- * @param context The context to set.
- * @deprecated mod_jk 1.2.20
- */
- public void setContext(String context) {
- this.context = context;
- }
- /**
- * @return Returns the type.
- */
- public String getType() {
- return type;
- }
- /**
- * @param type The type to set.
- */
- public void setType(String type) {
- this.type = type;
- }
- /**
- * @return Returns the uri.
- */
- public String getUri() {
- return uri;
- }
- /**
- * @param uri The uri to set.
- */
- public void setUri(String uri) {
- this.uri = uri;
- }
- /**
- * @return the source
- * @since mod_jk 1.2.20
- */
- public String getSource() {
- return source;
- }
- /**
- * @param source the source to set
- * @since mod_jk 1.2.20
- */
- public void setSource(String source) {
- this.source = source;
- }
-
- }
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMember.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMember.java
deleted file mode 100644
index 6e884477..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkBalancerMember.java
+++ /dev/null
@@ -1,516 +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.Serializable;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 500550 $ $Date: 2007-01-27 16:41:36 +0100 (Sat, 27 Jan 2007) $
- * @see org.apache.jk.status.JkStatusParser
- */
-/**
- * @author peter
- *
- */
-public class JkBalancerMember implements Serializable {
-
- int id = -1;
-
- String name;
-
- /* possible with >= 1.2.16 */
- String jvm_route;
-
- /* possible with >= 1.2.20 */
- String route;
-
- String type;
-
- String host;
-
- int port;
-
- String address;
-
- /* deprecated with mod_jk 1.2.16*/
- String status;
-
- /* possible with > 1.2.16 */
- String activation;
-
- /* possible with > 1.2.16 */
- String state;
-
- int lbfactor;
-
- long lbvalue;
-
- /* possible with > 1.2.16 */
- long lbmult = -1 ;
-
- int elected;
-
- long readed;
-
- long transferred;
-
- long errors;
-
- long clienterrors = -1;
-
- int busy;
-
- /* possible with > 1.2.16 */
- int maxbusy = -1;
-
- String redirect;
-
- String domain;
-
- /* possible with > 1.2.16 */
- int distance = -1;
-
- /* possible with > 1.2.20 */
- int time_to_recover = -1 ;
-
- /* possible with > 1.2.21 */
- int time_to_recover_max = -1 ;
-
- /* possible with > 1.2.21 */
- int time_to_recover_min = -1 ;
-
- /**
- * @return Returns the jvm_route.
- * @since mod_jk 1.2.16
- * @deprecated
- */
- public String getJvm_route() {
- return jvm_route;
- }
-
- /**
- * @param jvm_route The jvm_route to set.
- * @since mod_jk 1.2.16
- * @deprecated
- */
- public void setJvm_route(String jvm_route) {
- this.jvm_route = jvm_route;
- }
-
- /**
- * @return the route
- * @since mod_jk 1.2.20
- */
- public String getRoute() {
- return route;
- }
-
- /**
- * @param route the route to set
- * @since mod_jk 1.2.20
- */
- public void setRoute(String route) {
- this.route = route;
- }
-
- /**
- * @return Returns the address.
- */
- public String getAddress() {
- return address;
- }
-
- /**
- * @param address
- * The address to set.
- */
- public void setAddress(String address) {
- this.address = address;
- }
-
- /**
- * @return Returns the busy.
- */
- public int getBusy() {
- return busy;
- }
-
- /**
- * @param busy
- * The busy to set.
- */
- public void setBusy(int busy) {
- this.busy = busy;
- }
-
-
- /**
- * @return Returns the maxbusy.
- * @since mod_jk 1.2.18
- */
- public int getMax_busy() {
- return maxbusy;
- }
-
- /**
- * @param maxbusy The maxbusy to set.
- * @since mod_jk 1.2.18
- */
- public void setMax_busy(int maxbusy) {
- this.maxbusy = maxbusy;
- }
-
- /**
- * @return Returns the elected.
- */
- public int getElected() {
- return elected;
- }
-
- /**
- * @param elected
- * The elected to set.
- */
- public void setElected(int elected) {
- this.elected = elected;
- }
-
- /**
- * @return Returns the clienterrors.
- * @since mod_jk 1.2.19
- */
- public long getClient_errors() {
- return clienterrors;
- }
-
- /**
- * @param clienterrors The clienterrors to set.
- * @since mod_jk 1.2.19
- */
- public void setClient_errors(long clienterrors) {
- this.clienterrors = clienterrors;
- }
-
- /**
- * @return Returns the errors.
- */
- public long getErrors() {
- return errors;
- }
-
- /**
- * @param errors
- * The errors to set.
- */
- public void setErrors(long errors) {
- this.errors = errors;
- }
-
- /**
- * @return Returns the host.
- */
- public String getHost() {
- return host;
- }
-
- /**
- * @param host
- * The host to set.
- */
- public void setHost(String host) {
- this.host = host;
- }
-
- /**
- * @return Returns the id.
- */
- public int getId() {
- return id;
- }
-
- /**
- * @param id
- * The id to set.
- */
- public void setId(int id) {
- this.id = id;
- }
-
- /**
- * @return Returns the lbfactor.
- */
- public int getLbfactor() {
- return lbfactor;
- }
-
- /**
- * @param lbfactor
- * The lbfactor to set.
- */
- public void setLbfactor(int lbfactor) {
- this.lbfactor = lbfactor;
- }
-
- /**
- * @return Returns the lbvalue.
- */
- public long getLbvalue() {
- return lbvalue;
- }
-
- /**
- * @param lbvalue
- * The lbvalue to set.
- */
- public void setLbvalue(long lbvalue) {
- this.lbvalue = lbvalue;
- }
-
- /**
- * @return Returns the lbmult.
- * @since mod_jk 1.2.19
- */
- public long getLbmult() {
- return lbmult;
- }
-
- /**
- * @param lbmult The lbmult to set.
- * @since mod_jk 1.2.19
- */
- public void setLbmult(long lbmult) {
- this.lbmult = lbmult;
- }
-
- /**
- * @return Returns the name.
- */
- public String getName() {
- return name;
- }
-
- /**
- * @param name
- * The name to set.
- */
- public void setName(String name) {
- this.name = name;
- }
-
-
- /**
- * @return Returns the port.
- */
- public int getPort() {
- return port;
- }
-
- /**
- * @param port
- * The port to set.
- */
- public void setPort(int port) {
- this.port = port;
- }
-
- /**
- * @return Returns the readed.
- */
- public long getReaded() {
- return readed;
- }
-
- /**
- * @param readed
- * The readed to set.
- */
- public void setReaded(long readed) {
- this.readed = readed;
- }
-
- /**
- * @return Returns the status.
- * @deprecated since 1.2.16
- */
- public String getStatus() {
- return status;
- }
-
- /**
- * @param status
- * The status to set.
- * @deprecated since 1.2.16
- */
- public void setStatus(String status) {
- this.status = status;
- }
-
- /**
- * @return Returns the activation.
- * @since mod_jk 1.2.19
- */
- public String getActivation() {
- return activation;
- }
-
- /**
- * @param activation The activation to set.
- * @since mod_jk 1.2.19
- */
- public void setActivation(String activation) {
- this.activation = activation;
- }
-
- /**
- * @return Returns the state.
- * @since mod_jk 1.2.19
- */
- public String getState() {
- return state;
- }
-
- /**
- * @param state The state to set.
- * @since mod_jk 1.2.19
- */
- public void setState(String state) {
- this.state = state;
- }
-
- /**
- * @return Returns the transferred.
- */
- public long getTransferred() {
- return transferred;
- }
-
- /**
- * @param transferred
- * The transferred to set.
- */
- public void setTransferred(long transferred) {
- this.transferred = transferred;
- }
-
- /**
- * @return Returns the type.
- */
- public String getType() {
- return type;
- }
-
- /**
- * @param type
- * The type to set.
- */
- public void setType(String type) {
- this.type = type;
- }
-
-
- /**
- * @return Returns the domain.
- */
- public String getDomain() {
- return domain;
- }
- /**
- * @param domain The domain to set.
- */
- public void setDomain(String domain) {
- this.domain = domain;
- }
-
- /**
- * @return Returns the redirect.
- */
- public String getRedirect() {
- return redirect;
- }
- /**
- * @param redirect The redirect to set.
- */
- public void setRedirect(String redirect) {
- this.redirect = redirect;
- }
-
- /**
- * @return Returns the distance.
- * @since mod_jk 1.2.18
- */
- public int getDistance() {
- return distance;
- }
-
- /**
- * @param distance The distance to set.
- * @since mod_jk 1.2.18
- */
- public void setDistance(int distance) {
- this.distance = distance;
- }
-
- /**
- * @return the time_to_recover
- * @since mod_jk 1.2.20
- */
- public int getTime_to_recover() {
- return time_to_recover;
- }
-
- /**
- * @param time_to_recover the time_to_recover to set
- * @since mod_jk 1.2.20
- */
- public void setTime_to_recover(int time_to_recover) {
- this.time_to_recover = time_to_recover;
- }
-
- /**
- * @return the time_to_recover_min
- * @since mod_jk 1.2.21
- */
- public int getTime_to_recover_min() {
- return time_to_recover_min;
- }
-
- /**
- * @param time_to_recover_min the time_to_recover_min to set
- * @since mod_jk 1.2.21
- */
- public void setTime_to_recover_min(int time_to_recover_min) {
- this.time_to_recover_min = time_to_recover_min;
- }
-
- /**
- * @return the time_to_recover_max
- * @since mod_jk 1.2.21
- */
- public int getTime_to_recover_max() {
- return time_to_recover_max;
- }
-
- /**
- * @param time_to_recover_max the time_to_recover_max to set
- * @since mod_jk 1.2.21
- */
- public void setTime_to_recover_max(int time_to_recover_max) {
- this.time_to_recover_max = time_to_recover_max;
- }
-
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkResult.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkResult.java
deleted file mode 100644
index 63c39d7f..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkResult.java
+++ /dev/null
@@ -1,54 +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.Serializable;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 802231 $ $Date: 2009-08-07 23:43:52 +0200 (Fri, 07 Aug 2009) $
- * @see org.apache.jk.status.JkStatusParser
- */
-public class JkResult implements Serializable {
- String type ;
- String message;
- /**
- * @return the message
- */
- public String getMessage() {
- return message;
- }
- /**
- * @param message the message to set
- */
- public void setMessage(String message) {
- this.message = message;
- }
- /**
- * @return the type
- */
- public String getType() {
- return type;
- }
- /**
- * @param type the type to set
- */
- public void setType(String type) {
- this.type = type;
- }
-
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkServer.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkServer.java
deleted file mode 100644
index 88bc9ce6..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkServer.java
+++ /dev/null
@@ -1,56 +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.Serializable;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 485242 $ $Date: 2006-12-10 20:45:39 +0100 (Sun, 10 Dec 2006) $
- * @see org.apache.jk.status.JkStatusParser
- */
-public class JkServer implements Serializable {
- String name ;
- String port;
-
- /**
- * @return Returns the name.
- */
- public String getName() {
- return name;
- }
- /**
- * @param name The name to set.
- */
- public void setName(String name) {
- this.name = name;
- }
- /**
- * @return Returns the port.
- */
- public String getPort() {
- return port;
- }
- /**
- * @param port The port to set.
- */
- public void setPort(String port) {
- this.port = port;
- }
-
-
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkSoftware.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkSoftware.java
deleted file mode 100644
index da220b06..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkSoftware.java
+++ /dev/null
@@ -1,54 +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.Serializable;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 802231 $ $Date: 2009-08-07 23:43:52 +0200 (Fri, 07 Aug 2009) $
- * @see org.apache.jk.status.JkStatusParser
- */
-public class JkSoftware implements Serializable {
- String web_server;
- String jk_version ;
-
- /**
- * @return Returns the software.
- */
- public String getWeb_server() {
- return web_server;
- }
- /**
- * @param software The software to set.
- */
- public void setWeb_server(String software) {
- this.web_server = software;
- }
- /**
- * @return Returns the version.
- */
- public String getJk_version() {
- return jk_version;
- }
- /**
- * @param version The version to set.
- */
- public void setJk_version(String version) {
- this.jk_version = version;
- }
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatus.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatus.java
deleted file mode 100644
index df51ed1a..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatus.java
+++ /dev/null
@@ -1,90 +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.Serializable;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * @author Peter Rossbach
- * @version $Revision: 485242 $ $Date: 2006-12-10 20:45:39 +0100 (Sun, 10 Dec 2006) $
- * @see org.apache.jk.status.JkStatusParser
- */
-public class JkStatus implements Serializable {
-
- JkServer server ;
- JkSoftware software ;
- JkResult result ;
- List balancers = new ArrayList() ;
-
- /**
- * @return Returns the balancers.
- */
- public List getBalancers() {
- return balancers;
- }
- /**
- * @param balancers The balancers to set.
- */
- public void setBalancers(List balancers) {
- this.balancers = balancers;
- }
-
- public void addBalancer(JkBalancer balancer) {
- balancers.add(balancer);
- }
-
- public void removeBalancer(JkBalancer balancer) {
- balancers.remove(balancer);
- }
-
- /**
- * @return Returns the server.
- */
- public JkServer getServer() {
- return server;
- }
- public void setServer(JkServer server) {
- this.server = server ;
- }
- /**
- * @return the result
- */
- public JkResult getResult() {
- return result;
- }
- /**
- * @param result the result to set
- */
- public void setResult(JkResult result) {
- this.result = result;
- }
-
- /**
- * @return Returns the software.
- */
- public JkSoftware getSoftware() {
- return software;
- }
- /**
- * @param software The software to set.
- */
- public void setSoftware(JkSoftware software) {
- this.software = software;
- }
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusAccessor.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusAccessor.java
deleted file mode 100644
index e884f542..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusAccessor.java
+++ /dev/null
@@ -1,133 +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.IOException;
-import java.net.HttpURLConnection;
-import java.net.MalformedURLException;
-import java.net.ProtocolException;
-import java.net.URL;
-import java.net.URLConnection;
-
-import org.apache.catalina.util.Base64;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.tomcat.util.digester.Digester;
-
-/**
- * Create connection to mod_jk jkstatus page.
- * Optional you can use Http basic auth user and password.
- * @author Peter Rossbach
- * @version $Revision: 485242 $ $Date: 2006-12-10 20:45:39 +0100 (Sun, 10 Dec 2006) $
- * @see org.apache.jk.status.JkStatusParser
- * @since 5.5.10
- */
-public class JkStatusAccessor {
-
- private static Log log = LogFactory.getLog(JkStatusAccessor.class);
- /**
- * The descriptive information about this implementation.
- */
- protected static final String info = "org.apache.jk.status.JkStatusAccessor/1.0";
-
- /**
- * Parse Apache mod_jk Status from base url http://host:port/jkstatus)
- * @param url
- * @param username
- * @param password
- *
- */
- public JkStatus status(String url, String username, String password)
- throws Exception {
-
- if(url == null || "".equals(url))
- return null ;
- HttpURLConnection hconn = null;
- JkStatus status = null;
-
- try {
- // FIXME: use cmd show for older mod_jk versions
- hconn = openConnection(url + "?cmd=list&mime=xml", username, password);
- Digester digester = JkStatusParser.getDigester();
- synchronized (digester) {
- status = (JkStatus) digester.parse(hconn.getInputStream());
- }
- } catch (Throwable t) {
- throw new Exception(t);
- } finally {
- if (hconn != null) {
- try {
- hconn.disconnect();
- } catch (Throwable u) {
- ;
- }
- hconn = null;
- }
- }
- return status;
- }
-
- /**
- * Create a auth http connection for this url
- *
- * @param url
- * @param username
- * @param password
- * @return HttpConnection
- * @throws IOException
- * @throws MalformedURLException
- * @throws ProtocolException
- */
- protected HttpURLConnection openConnection(String url, String username,
- String password) throws IOException, MalformedURLException,
- ProtocolException {
- URLConnection conn;
- conn = (new URL(url)).openConnection();
- HttpURLConnection hconn = (HttpURLConnection) conn;
-
- // Set up standard connection characteristics
- hconn.setAllowUserInteraction(false);
- hconn.setDoInput(true);
- hconn.setUseCaches(false);
- hconn.setDoOutput(false);
- hconn.setRequestMethod("GET");
- hconn.setRequestProperty("User-Agent", "JkStatus-Client/1.0");
-
- if(username != null && password != null ) {
- setAuthHeader(hconn, username, password);
- }
- // Establish the connection with the server
- hconn.connect();
- return hconn;
- }
-
- /**
- * Set Basic Auth Header
- *
- * @param hconn
- * @param username
- * @param password
- */
- protected void setAuthHeader(HttpURLConnection hconn, String username,
- String password) {
- // Set up an authorization header with our credentials
- String input = username + ":" + password;
- String output = new String(Base64.encode(input.getBytes()));
- hconn.setRequestProperty("Authorization", "Basic " + output);
- }
-
-} \ No newline at end of file
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusParser.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusParser.java
deleted file mode 100644
index 87595d99..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusParser.java
+++ /dev/null
@@ -1,228 +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 org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.tomcat.util.digester.Digester;
-
-/**
- * mod_jk 1.2.19 document:<br/>
- * <code>
- *
- * &lt;?xml version="1.0" encoding="UTF-8" ?&gt;
- * &lt;jk:status xmlns:jk="http://tomcat.apache.org"&gt;
- * &lt;jk:server name="localhost" port="2010" software="Apache/2.0.58 (Unix) mod_jk/1.2.19-dev" version="1.2.19" /&gt;
- * &lt;jk:balancers&gt;
- * &lt;jk:balancer id="0" name="loadbalancer" type="lb" sticky="True" stickyforce="False" retries="2" recover="60" &gt;
- * &lt;jk:member id="0" name="node01" type="ajp13" host="localhost" port="20012" address="127.0.0.1:20012" activation="ACT" state="N/A" distance="0" lbfactor="1" lbmult="1" lbvalue="0" elected="0" errors="0" transferred="0" readed="0" busy="0" maxbusy="0" jvm_route="node01" /&gt;
- * &lt;jk:member id="1" name="node02" type="ajp13" host="localhost" port="20022" address="127.0.0.1:20022" activation="ACT" state="N/A" distance="0" lbfactor="1" lbmult="1" lbvalue="0" elected="0" errors="0" transferred="0" readed="0" busy="0" maxbusy="0" jvm_route="node02" /&gt;
- * &lt;jk:map type="Wildchar" uri="/ClusterSession*" context="/ClusterSession*" /&gt;
- * &lt;jk:map type="Wildchar" uri="/ClusterTest*" context="/ClusterTest*" /&gt;
- * &lt;jk:map type="Wildchar" uri="/test*" context="/test*" /&gt;
- * &lt;/jk:balancer&gt;
- * &lt;/jk:balancers&gt;
- * &lt;/jk:status&gt;
- * </code>
- * <br/>
- * mod_jk 1.2.20 document:<br/>
- * <code>
- * &lt;?xml version="1.0" encoding="UTF-8" ?&gt;
- * &lt;jk:status xmlns:jk="http://tomcat.apache.org"&gt;
- * &lt;jk:server
- * name="127.0.0.1"
- * port="2080"
- * software="Apache/2.0.59 (Unix) mod_jk/1.2.20-dev"
- * version="1.2.20"/&gt;
- * &lt;jk:balancers&gt;
- * &lt;jk:balancer
- * name="loadbalancer"
- * type="lb"
- * sticky="True"
- * stickyforce="False"
- * retries="2"
- * recover="60"
- * method="Request"
- * lock="Optimistic"
- * good="2"
- * degraded="0"
- * bad="0"
- * busy="0"
- * max_busy="0"&gt;
- * &lt;jk:member
- * name="node01"
- * type="ajp13"
- * host="localhost"
- * port="7309"
- * address="127.0.0.1:7309"
- * activation="ACT"
- * lbfactor="1"
- * jvm_route="node01"
- * redirect=""
- * domain=""
- * distance="0"
- * state="N/A"
- * lbmult="1"
- * lbvalue="0"
- * elected="0"
- * errors="0"
- * clienterrors="0"
- * transferred="0"
- * readed="0"
- * busy="0"
- * maxbusy="0"
- * time-to-recover="0"/&gt;
- * &lt;jk:member
- * name="node02"
- * type="ajp13"
- * host="localhost"
- * port="7409"
- * address="127.0.0.1:7409"
- * activation="ACT"
- * lbfactor="1"
- * jvm_route="node02"
- * redirect=""
- * domain=""
- * distance="0"
- * state="N/A"
- * lbmult="1"
- * lbvalue="0"
- * elected="0"
- * errors="0"
- * clienterrors="0"
- * transferred="0"
- * readed="0"
- * busy="0"
- * maxbusy="0"
- * time-to-recover="0"/&gt;
- * &lt;jk:map
- * type="Wildchar"
- * uri="/ClusterTest*"
- * source="JkMount"/&gt;
- * &lt;jk:map
- * type="Wildchar"
- * uri="/myapps*"
- * source="JkMount"/&gt;
- * &lt;jk:map
- * type="Wildchar"
- * uri="/last*"
- * source="JkMount"/&gt;
- * &lt;/jk:balancer&gt;
- * &lt;/jk:balancers&gt;
- * &lt;/jk:status&gt;
- *
- *
- * </code>
- * <br/>
- * mod_jk 1.2.24 runtime state N/A changed to OK/IDLE:<br/>
- * <code>
- * state="OK/IDLE"
- * </code>
- * @author Peter Rossbach
- * @version $Revision: 753168 $ $Date: 2009-03-13 09:46:29 +0100 (Fri, 13 Mar 2009) $
- * @since 5.5.10
- */
-public class JkStatusParser {
- private static Log log = LogFactory.getLog(JkStatusParser.class);
-
- /**
- * The descriptive information about this implementation.
- */
- private static final String info = "org.apache.jk.status.JkStatusParser/1.1";
-
- /**
- * Return descriptive information about this implementation and the
- * corresponding version number, in the format
- * <code>&lt;description&gt;/&lt;version&gt;</code>.
- */
- public String getInfo() {
-
- return (info);
-
- }
-
- /**
- * The <code>Digester</code> instance used to parse registry descriptors.
- */
- public static final Digester digester = createDigester();
-
- public static Digester getDigester() {
- return digester;
- }
-
- /**
- * Create and configure the Digester we will be using for setup mod_jk jk status page.
- */
- public static Digester createDigester() {
- long t1 = System.currentTimeMillis();
- // Initialize the digester
- Digester digester = new Digester();
- digester.setValidating(false);
- digester.setClassLoader(JkStatus.class.getClassLoader());
-
- // parse status
- digester.addObjectCreate("jk:status", "org.apache.jk.status.JkStatus",
- "className");
- digester.addSetProperties("jk:status");
-
- digester.addObjectCreate("jk:status/jk:server",
- "org.apache.jk.status.JkServer", "className");
- digester.addSetProperties("jk:status/jk:server");
- digester.addSetNext("jk:status/jk:server", "setServer",
- "org.apache.jk.status.JkServer");
-
- digester.addObjectCreate("jk:status/jk:software",
- "org.apache.jk.status.JkSoftware", "className");
- digester.addSetProperties("jk:status/jk:software");
- digester.addSetNext("jk:status/jk:software", "setSoftware",
- "org.apache.jk.status.JkSoftware");
-
- digester.addObjectCreate("jk:status/jk:result",
- "org.apache.jk.status.JkResult", "className");
- digester.addSetProperties("jk:status/jk:result");
- digester.addSetNext("jk:status/jk:result", "setResult",
- "org.apache.jk.status.JkResult");
-
- digester.addObjectCreate("jk:status/jk:balancers/jk:balancer",
- "org.apache.jk.status.JkBalancer", "className");
- digester.addSetProperties("jk:status/jk:balancers/jk:balancer");
- digester.addSetNext("jk:status/jk:balancers/jk:balancer",
- "addBalancer", "org.apache.jk.status.JkBalancer");
-
- digester.addObjectCreate(
- "jk:status/jk:balancers/jk:balancer/jk:member",
- "org.apache.jk.status.JkBalancerMember", "className");
- digester
- .addSetProperties("jk:status/jk:balancers/jk:balancer/jk:member");
- digester.addSetNext("jk:status/jk:balancers/jk:balancer/jk:member",
- "addBalancerMember", "org.apache.jk.status.JkBalancerMember");
-
- digester.addObjectCreate("jk:status/jk:balancers/jk:balancer/jk:map",
- "org.apache.jk.status.JkBalancerMapping", "className");
- digester.addSetProperties("jk:status/jk:balancers/jk:balancer/jk:map");
- digester.addSetNext("jk:status/jk:balancers/jk:balancer/jk:map",
- "addBalancerMapping", "org.apache.jk.status.JkBalancerMapping");
-
- long t2 = System.currentTimeMillis();
- if (log.isDebugEnabled())
- log.debug("Digester for apache mod_jk jkstatus page is created "
- + (t2 - t1));
- return (digester);
-
- }
-
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusResetTask.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusResetTask.java
deleted file mode 100644
index 703f04bf..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusResetTask.java
+++ /dev/null
@@ -1,133 +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>/jkstatus?cmd=reset&amp;w=loadbalancer</code> command, supported by the
- * mod_jk status (1.2.20) application.
- *
- * @author Peter Rossbach
- * @version $Revision: 485242 $
- * @since mod_jk 1.2.20
- */
-public class JkStatusResetTask extends AbstractJkStatusTask {
-
- /**
- * The descriptive information about this implementation.
- */
- private static final String info = "org.apache.jk.status.JkStatusResetTask/1.1";
-
- private String worker;
- private String loadbalancer;
-
- /**
- *
- */
- public JkStatusResetTask() {
- super();
- setUrl("http://localhost/jkstatus");
- }
-
- /**
- * Return descriptive information about this implementation and the
- * corresponding version number, in the format
- * <code>&lt;description&gt;/&lt;version&gt;</code>.
- */
- public String getInfo() {
-
- return (info);
-
- }
-
- /**
- * @return the loadbalancer
- */
- public String getLoadbalancer() {
- return loadbalancer;
- }
-
-
- /**
- * @param loadbalancer the loadbalancer to set
- */
- public void setLoadbalancer(String loadbalancer) {
- this.loadbalancer = loadbalancer;
- }
-
-
- /**
- * @return the worker
- */
- public String getWorker() {
- return worker;
- }
-
-
- /**
- * @param worker the worker to set
- */
- public void setWorker(String worker) {
- this.worker = worker;
- }
-
-
- /**
- * Create jkstatus reset link
- * <ul>
- * <li><b>loadbalancer example:
- * </b>http://localhost/jkstatus?cmd=reset&mime=txt&w=loadbalancer</li>
- * <li><b>loadbalancer + sub worker example:
- * </b>http://localhost/jkstatus?cmd=reset&mime=txt&w=loadbalancer&sw=node01</li>
- * </ul>
- *
- * @return create jkstatus reset link
- */
- protected StringBuffer createLink() {
- // Building URL
- StringBuffer sb = new StringBuffer();
- try {
- sb.append("?cmd=reset");
- sb.append("&mime=txt");
- sb.append("&w=");
- sb.append(URLEncoder.encode(loadbalancer, getCharset()));
- if(worker != null) {
- sb.append("&sw=");
- sb.append(URLEncoder.encode(worker, getCharset()));
- }
-
- } catch (UnsupportedEncodingException e) {
- throw new BuildException("Invalid 'charset' attribute: "
- + getCharset());
- }
- return sb;
- }
-
- /**
- * check correct pararmeter
- */
- protected void checkParameter() {
- if (loadbalancer == null) {
- throw new BuildException("Must specify 'loadbalanacer' attribute");
- }
- }
-} \ No newline at end of file
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusTask.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusTask.java
deleted file mode 100644
index 73d11eab..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusTask.java
+++ /dev/null
@@ -1,735 +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.util.Iterator;
-import java.util.List;
-
-import org.apache.catalina.ant.BaseRedirectorHelperTask;
-import org.apache.tomcat.util.IntrospectionUtils;
-import org.apache.tools.ant.BuildException;
-import org.apache.tools.ant.Project;
-
-/**
- * Ant task that implements the show <code>/jkstatus</code> command, supported
- * by the mod_jk status (1.2.13) application.
- *
- * @author Peter Rossbach
- * @version $Revision: 752644 $
- * @since 5.5.10
- */
-public class JkStatusTask extends BaseRedirectorHelperTask {
-
- /**
- * The descriptive information about this implementation.
- */
- private static final String info = "org.apache.jk.status.JkStatusTask/1.2";
-
- /**
- * Store status as <code>resultProperty</code> prefix.
- */
- protected String resultproperty;
-
- /**
- * Echo status at ant console
- */
- protected boolean echo = false;
-
- /**
- * The login password for the <code>mod_jk status</code> page.
- */
- protected String password = null;
-
- /**
- * The URL of the <code>mod_jk status</code> page to be used.
- */
- protected String url = "http://localhost:80/jkstatus";
-
- /**
- * The login username for the <code>mod_jk status</code> page.
- */
- protected String username = null;
-
- private String errorProperty;
-
- private String worker;
-
- private String loadbalancer;
-
- /**
- * Return descriptive information about this implementation and the
- * corresponding version number, in the format
- * <code>&lt;description&gt;/&lt;version&gt;</code>.
- */
- public String getInfo() {
-
- return (info);
-
- }
-
- public String getPassword() {
- return (this.password);
- }
-
- public void setPassword(String password) {
- this.password = password;
- }
-
- public String getUrl() {
- return (this.url);
- }
-
- public void setUrl(String url) {
- this.url = url;
- }
-
- public String getUsername() {
- return (this.username);
- }
-
- public void setUsername(String username) {
- this.username = username;
- }
-
- /**
- * @return Returns the echo.
- */
- public boolean isEcho() {
- return echo;
- }
-
- /**
- * @param echo
- * The echo to set.
- */
- public void setEcho(boolean echo) {
- this.echo = echo;
- }
-
- /**
- * @return Returns the resultproperty.
- */
- public String getResultproperty() {
- return resultproperty;
- }
-
- /**
- * @param resultproperty
- * The resultproperty to set.
- */
- public void setResultproperty(String resultproperty) {
- this.resultproperty = resultproperty;
- }
-
- /**
- * @return Returns the loadbalancer.
- */
- public String getLoadbalancer() {
- return loadbalancer;
- }
- /**
- * @param loadbalancer The loadbalancer to set.
- */
- public void setLoadbalancer(String loadbalancer) {
- this.loadbalancer = loadbalancer;
- }
- /**
- * @return Returns the worker.
- */
- public String getWorker() {
- return worker;
- }
- /**
- * @param worker The worker to set.
- */
- public void setWorker(String worker) {
- this.worker = worker;
- }
- // --------------------------------------------------------- Public Methods
-
- /**
- * Get jkstatus from server.
- *
- * @exception BuildException
- * if a validation error occurs
- */
- public void execute() throws BuildException {
-
- if (url == null) {
- throw new BuildException("Must specify an 'url'");
- }
- boolean isWorkerOnly = worker != null && !"".equals(worker);
- boolean isLoadbalancerOnly = loadbalancer != null
- && !"".equals(loadbalancer);
-
- StringBuffer error = new StringBuffer();
- try {
- JkStatusAccessor accessor = new JkStatusAccessor();
- JkStatus status = accessor.status(url, username, password);
- if (status.result != null && !"OK".equals(status.result.type) ) {
- if (getErrorProperty() != null) {
- getProject().setNewProperty(errorProperty, status.result.message);
- }
- if (isFailOnError()) {
- throw new BuildException(status.result.message);
- } else {
- handleErrorOutput(status.result.message);
- return;
- }
-
- }
-
- if (!isWorkerOnly && !isLoadbalancerOnly) {
- JkServer server = status.getServer();
- JkSoftware software = status.getSoftware();
- JkResult result = status.getResult();
- if (resultproperty != null) {
- createProperty(server, "server", "name");
- createProperty(server, "server", "port");
- createProperty(software, "web_server");
- createProperty(software, "jk_version");
- createProperty(result, "result", "type");
- createProperty(result, "result", "message");
- }
- if (isEcho()) {
- handleOutput("server name=" + server.getName() + ":"
- + server.getPort() + " - " + software.getWeb_server() + " - " + software.getJk_version());
- }
- }
- List balancers = status.getBalancers();
- for (Iterator iter = balancers.iterator(); iter.hasNext();) {
- JkBalancer balancer = (JkBalancer) iter.next();
- String balancerIndex = null;
- if (isLoadbalancerOnly) {
- if (loadbalancer.equals(balancer.getName())) {
- if (resultproperty != null) {
- setPropertyBalancerOnly(balancer);
- }
- echoBalancer(balancer);
- return;
- }
- } else {
- if (!isWorkerOnly) {
- if (resultproperty != null) {
- if ( balancer.getId() >= 0)
- balancerIndex = Integer.toString(balancer.getId());
- else
- balancerIndex = balancer.getName() ;
-
- setPropertyBalancer(balancer,balancerIndex);
- }
- echoBalancer(balancer);
- }
- List members = balancer.getBalancerMembers();
- for (Iterator iterator = members.iterator(); iterator
- .hasNext();) {
- JkBalancerMember member = (JkBalancerMember) iterator
- .next();
- if (isWorkerOnly) {
- if (worker.equals(member.getName())) {
- if (resultproperty != null) {
- setPropertyWorkerOnly(balancer, member);
- }
- echoWorker(member);
- return;
- }
- } else {
- if (resultproperty != null) {
- setPropertyWorker(null, member);
- }
- echoWorker(member);
- if (member.getStatus() != null && !"OK".equals(member.getStatus())) {
- error.append(" worker name=" + member.getName()
- + " status=" + member.getStatus()
- + " host=" + member.getAddress());
- }
- if (member.getState() != null &&
- !("OK".equals(member.getState()) ||
- "N/A".equals(member.getState()) ||
- "OK/IDLE".equals(member.getState())) ){
- error.append(" worker name=" + member.getName()
- + " state=" + member.getState()
- + " host=" + member.getAddress());
- }
- }
- }
- if (!isWorkerOnly) {
- if (resultproperty != null && members.size() > 0) {
- getProject().setNewProperty(
- resultproperty + "."
- + balancer.getName() + ".length",
- Integer.toString(members.size()));
- }
- List mappings = balancer.getBalancerMappings();
- int j = 0;
- String mapIndex ;
- if( balancerIndex != null )
- mapIndex = balancerIndex + ".map" ;
- else
- mapIndex = "map" ;
- for (Iterator iterator = mappings.iterator(); iterator
- .hasNext(); j++) {
- JkBalancerMapping mapping = (JkBalancerMapping) iterator
- .next();
- if (resultproperty != null) {
- String stringIndex2 ;
- if( mapping.getId() >= 0) {
- stringIndex2 = Integer.toString(mapping.getId()) ;
- } else {
- stringIndex2 = Integer.toString(j);
- }
- createProperty(mapping, mapIndex,
- stringIndex2, "type");
- createProperty(mapping, mapIndex,
- stringIndex2, "uri");
- createProperty(mapping, mapIndex,
- stringIndex2, "context");
- createProperty(mapping, mapIndex,
- stringIndex2, "source");
- }
- if (isEcho()) {
- String mappingOut ;
-
- if(mapping.source != null) {
- mappingOut =
- "balancer name="
- + balancer.getName() + " mappingtype="
- + mapping.getType() + " uri="
- + mapping.getUri() + " source="
- + mapping.getSource() ;
- } else {
- mappingOut = "balancer name="
- + balancer.getName() + " mappingtype="
- + mapping.getType() + " uri="
- + mapping.getUri() + " context="
- + mapping.getContext() ;
- }
- handleOutput(mappingOut);
- }
- }
- if (resultproperty != null && mappings.size() > 0) {
- getProject().setNewProperty(
- resultproperty + "."
- + mapIndex + ".length",
- Integer.toString(mappings.size()));
- }
- }
- }
- }
- if (!isWorkerOnly && !isLoadbalancerOnly) {
- if (resultproperty != null && balancers.size() > 0) {
- getProject().setNewProperty(
- resultproperty + ".length",
- Integer.toString(balancers.size()));
- }
- }
- } catch (Throwable t) {
- error.append(t.getMessage());
- if (getErrorProperty() != null) {
- getProject().setNewProperty(errorProperty, error.toString());
- }
- if (isFailOnError()) {
- throw new BuildException(t);
- } else {
- handleErrorOutput(t.getMessage());
- return;
- }
- }
- if (error.length() != 0) {
- if (getErrorProperty() != null) {
- getProject().setNewProperty(errorProperty, error.toString());
- }
- if (isFailOnError()) {
- // exception should be thrown only if failOnError == true
- // or error line will be logged twice
- throw new BuildException(error.toString());
- }
- }
-
- }
-
- /**
- * @param member
- */
- private void echoWorker(JkBalancerMember member) {
- if (isEcho()) {
- StringBuffer state = new StringBuffer("worker name=") ;
- state.append( member.getName()) ;
- if(member.getStatus() != null) {
- state.append(" status=");
- state.append(member.getStatus());
- }
- if(member.getState() != null) {
- state.append(" state=");
- state.append(member.getState()) ;
- }
- state.append(" host=");
- state.append(member.getAddress());
- handleOutput(state.toString());
- }
- }
-
- /**
- * @param balancer
- */
- private void echoBalancer(JkBalancer balancer) {
- if (isEcho()) {
- handleOutput("balancer name=" + balancer.getName() + " type="
- + balancer.getType());
- }
- }
-
- /**
- * @param balancer
- */
- private void setPropertyBalancerOnly(JkBalancer balancer) {
- String prefix = resultproperty + "." + balancer.getName();
- if(balancer.getId() >= 0 ) {
- getProject().setNewProperty(prefix + ".id",
- Integer.toString(balancer.getId()));
- }
- getProject().setNewProperty(prefix + ".type", balancer.getType());
- getProject().setNewProperty(prefix + ".stick_session",
- Boolean.toString(balancer.isSticky_session()));
- getProject().setNewProperty(prefix + ".sticky_session_force",
- Boolean.toString(balancer.isSticky_session_force()));
- getProject().setNewProperty(prefix + ".retries",
- Integer.toString(balancer.getRetries()));
- getProject().setNewProperty(prefix + ".recover_time",
- Integer.toString(balancer.getRecover_time()));
- getProject().setNewProperty(prefix + ".method",
- balancer.getMethod());
- getProject().setNewProperty(prefix + ".good",
- Integer.toString(balancer.getGood()));
- getProject().setNewProperty(prefix + ".degraded",
- Integer.toString(balancer.getDegraded()));
- getProject().setNewProperty(prefix + ".bad",
- Integer.toString(balancer.getBad()));
- getProject().setNewProperty(prefix + ".busy",
- Integer.toString(balancer.getBusy()));
- getProject().setNewProperty(prefix + ".map_count",
- Integer.toString(balancer.getMap_count()));
- getProject().setNewProperty(prefix + ".member_count",
- Integer.toString(balancer.getMember_count()));
- getProject().setNewProperty(prefix + ".max_busy",
- Integer.toString(balancer.getMax_busy()));
- getProject().setNewProperty(prefix + ".time_to_maintenance_min",
- Integer.toString(balancer.getTime_to_maintenance_min()));
- getProject().setNewProperty(prefix + ".time_to_maintenance_max",
- Integer.toString(balancer.getTime_to_maintenance_max()));
- getProject().setNewProperty(prefix + ".lock",
- balancer.getLock());
-
- }
-
- /**
- * @param balancer
- * @param balancerIndex
- */
- private void setPropertyBalancer(JkBalancer balancer,String balancerIndex) {
- if(balancer.id >= 0) {
- createProperty(balancer, balancerIndex, "id");
- }
-
- createProperty(balancer, balancerIndex, "name");
- createProperty(balancer, balancerIndex, "type");
- createProperty(balancer, balancerIndex, "sticky_session");
- createProperty(balancer, balancerIndex, "sticky_session_force");
- createProperty(balancer, balancerIndex, "retries");
- createProperty(balancer, balancerIndex, "recover_time");
- if(balancer.getMethod() != null) {
- createProperty(balancer, balancerIndex, "method");
- }
- if(balancer.getLock() != null) {
- createProperty(balancer, balancerIndex, "lock");
- }
- if(balancer.getGood() >= 0) {
- createProperty(balancer, balancerIndex, "good");
- }
- if(balancer.getDegraded() >= 0) {
- createProperty(balancer, balancerIndex, "degraded");
- }
- if(balancer.getBad() >= 0) {
- createProperty(balancer, balancerIndex, "bad");
- }
- if(balancer.getBusy() >= 0) {
- createProperty(balancer, balancerIndex, "busy");
- }
- if(balancer.getMax_busy() >= 0) {
- createProperty(balancer, balancerIndex, "max_busy");
- }
- if(balancer.getMember_count() >=0) {
- createProperty(balancer, balancerIndex, "member_count");
- }
- if(balancer.getMap_count() >=0) {
- createProperty(balancer, balancerIndex, "map_count");
- }
- if(balancer.getTime_to_maintenance_min() >=0) {
- createProperty(balancer, balancerIndex, "time_to_maintenance_min");
- }
- if(balancer.getTime_to_maintenance_max() >=0) {
- createProperty(balancer, balancerIndex, "time_to_maintenance_max");
- }
- }
-
- /**
- * @param balancerIndex
- * @param member
- */
- private void setPropertyWorker(String balancerIndex, JkBalancerMember member) {
- String workerIndex ;
- if(member.getId() >= 0) {
- workerIndex = Integer.toString(member.getId());
- createProperty(member, balancerIndex, workerIndex, "id");
- createProperty(member, balancerIndex, workerIndex, "name");
- } else {
- workerIndex = member.getName();
- }
- createProperty(member, balancerIndex, workerIndex, "type");
- createProperty(member, balancerIndex, workerIndex, "host");
- createProperty(member, balancerIndex, workerIndex, "port");
- createProperty(member, balancerIndex, workerIndex, "address");
- if(member.getJvm_route() != null) {
- createProperty(member, balancerIndex, workerIndex, "jvm_route");
- }
- if(member.getRoute() != null) {
- createProperty(member, balancerIndex, workerIndex, "route");
- }
- if(member.getStatus() != null) {
- createProperty(member, balancerIndex, workerIndex, "status");
- }
- if(member.getActivation() != null) {
- createProperty(member, balancerIndex, workerIndex, "activation");
- }
- if(member.getState() != null) {
- createProperty(member, balancerIndex, workerIndex, "state");
- }
- createProperty(member, balancerIndex, workerIndex, "lbfactor");
- createProperty(member, balancerIndex, workerIndex, "lbvalue");
- if(member.getLbmult() >= 0) {
- createProperty(member, balancerIndex, workerIndex, "lbmult");
- }
- createProperty(member, balancerIndex, workerIndex, "elected");
- createProperty(member, balancerIndex, workerIndex, "readed");
- createProperty(member, balancerIndex, workerIndex, "busy");
- if(member.getMax_busy() >= 0) {
- createProperty(member, balancerIndex, workerIndex, "max_busy");
- }
- createProperty(member, balancerIndex, workerIndex, "transferred");
- createProperty(member, balancerIndex, workerIndex, "errors");
- if(member.getClient_errors() >= 0) {
- createProperty(member, balancerIndex, workerIndex, "client_errors");
- }
- if(member.getDistance() >= 0) {
- createProperty(member, balancerIndex, workerIndex, "distance");
- }
- if (member.getDomain() != null) {
- createProperty(member, balancerIndex, workerIndex, "domain");
- } else {
- getProject().setNewProperty(resultproperty + "." + balancerIndex + "." + workerIndex +
- ".domain", "");
- }
- if (member.getRedirect() != null) {
- createProperty(member, balancerIndex, workerIndex, "redirect");
- } else {
- getProject().setNewProperty(resultproperty + "." + balancerIndex + "." + workerIndex +
- ".redirect", "");
- }
- }
-
- /**
- * @param balancer
- * @param member
- */
- private void setPropertyWorkerOnly(JkBalancer balancer,
- JkBalancerMember member) {
- //String prefix = resultproperty + "." + balancer.getName() + "." + member.getName();
- String prefix = resultproperty + "." + member.getName();
- Project currentProject = getProject();
- if ( balancer.getId() >= 0) {
- currentProject.setNewProperty(prefix + ".lb.id",
- Integer.toString(balancer.getId()));
- }
- //currentProject.setNewProperty(prefix + ".lb.name", balancer.getName());
- if( member.getId() >= 0) {
- currentProject.setNewProperty(prefix + ".id",
- Integer.toString(member.getId()));
- }
- currentProject.setNewProperty(prefix + ".type", member.getType());
- if (member.getJvm_route() != null) {
- currentProject.setNewProperty(prefix + ".jvm_route", member.getJvm_route());
- }
- if (member.getRoute() != null) {
- currentProject.setNewProperty(prefix + ".route", member.getRoute());
- }
- if (member.getStatus() != null) {
- currentProject.setNewProperty(prefix + ".status", member.getStatus());
- }
- if (member.getActivation() != null) {
- currentProject.setNewProperty(prefix + ".activation", member.getActivation());
- }
- if (member.getState() != null) {
- currentProject.setNewProperty(prefix + ".state", member.getState());
- }
- currentProject.setNewProperty(prefix + ".host", member.getHost());
- currentProject.setNewProperty(prefix + ".address", member.getAddress());
- currentProject.setNewProperty(prefix + ".port",
- Integer.toString(member.getPort()));
- currentProject.setNewProperty(prefix + ".lbfactor",
- Integer.toString(member.getLbfactor()));
- currentProject.setNewProperty(prefix + ".lbvalue",
- Long.toString(member.getLbvalue()));
- if(member.getLbmult() >= 0) {
- currentProject.setNewProperty(prefix + ".lbmult",
- Long.toString(member.getLbmult()));
- }
- currentProject.setNewProperty(prefix + ".elected",
- Long.toString(member.getElected()));
- currentProject.setNewProperty(prefix + ".readed",
- Long.toString(member.getReaded()));
- currentProject.setNewProperty(prefix + ".transferred",
- Long.toString(member.getTransferred()));
- currentProject.setNewProperty(prefix + ".busy",
- Integer.toString(member.getBusy()));
- if(member.getMax_busy() >= 0) {
- currentProject.setNewProperty(prefix + ".max_busy",
- Long.toString(member.getMax_busy()));
- }
- currentProject.setNewProperty(prefix + ".errors",
- Long.toString(member.getErrors()));
- if(member.getClient_errors() >= 0) {
- currentProject.setNewProperty(prefix + ".client_errors",
- Long.toString(member.getClient_errors()));
- }
- if(member.getDistance() >= 0) {
- currentProject.setNewProperty(prefix + ".distance",
- Integer.toString(member.getDistance()));
- }
- if (member.getDomain() != null) {
- currentProject.setNewProperty(prefix + ".domain", member.getDomain());
- } else {
- currentProject.setNewProperty(prefix + ".domain", "");
- }
- if (member.getRedirect() != null) {
- currentProject.setNewProperty(prefix + ".redirect",
- member.getRedirect());
- } else {
- currentProject.setNewProperty(prefix + ".redirect", "");
- }
- if(member.getTime_to_recover() >= 0) {
- currentProject.setNewProperty(prefix + ".time_to_recover",
- Integer.toString(member.getTime_to_recover()));
- }
- if(member.getTime_to_recover_min() >= 0) {
- currentProject.setNewProperty(prefix + ".time_to_recover_min",
- Integer.toString(member.getTime_to_recover_min()));
- }
- if(member.getTime_to_recover_max() >= 0) {
- currentProject.setNewProperty(prefix + ".time_to_recover_max",
- Integer.toString(member.getTime_to_recover_max()));
- currentProject.setNewProperty(prefix + ".time_to_recover",
- (Integer.toString((member.getTime_to_recover_min()
- + member.getTime_to_recover_max()) / 2)));
- }
-
- }
-
- /*
- * Set ant property for save error state
- *
- * @see org.apache.catalina.ant.BaseRedirectorHelperTask#setErrorProperty(java.lang.String)
- */
- public void setErrorProperty(String arg0) {
- errorProperty = arg0;
- super.setErrorProperty(arg0);
- }
-
- /**
- * @return Returns the errorProperty.
- */
- public String getErrorProperty() {
- return errorProperty;
- }
-
- protected void createProperty(Object result, String attribute) {
- createProperty(result, null, null, attribute);
- }
-
- protected void createProperty(Object result, String arraymark,
- String attribute) {
- createProperty(result, arraymark, null, attribute);
- }
-
- /**
- * create result as property with name from attribute resultproperty
- */
- protected void createProperty(Object result, String arraymark,
- String arraymark2, String attribute) {
- if (resultproperty != null) {
- Object value = IntrospectionUtils.getProperty(result, attribute);
- if (value != null ) {
- StringBuffer propertyname = new StringBuffer(resultproperty);
-
- if (result instanceof JkBalancer) {
- if (arraymark != null) {
- propertyname.append(".");
- propertyname.append(arraymark);
- }
- } else if (result instanceof JkServer) {
- if (arraymark != null) {
- propertyname.append(".");
- propertyname.append(arraymark);
- }
- } else if (result instanceof JkSoftware) {
- if (arraymark != null) {
- propertyname.append(".");
- propertyname.append(arraymark);
- }
- } else if (result instanceof JkResult) {
- if (arraymark != null) {
- propertyname.append(".");
- propertyname.append(arraymark);
- }
- } else if (result instanceof JkBalancerMember) {
- if (arraymark != null) {
- propertyname.append(".");
- propertyname.append(arraymark);
- }
- if (arraymark2 != null) {
- propertyname.append(".");
- propertyname.append(arraymark2);
- }
- } else if (result instanceof JkBalancerMapping) {
- if (arraymark != null) {
- propertyname.append(".");
- propertyname.append(arraymark);
- }
- if (arraymark2 != null) {
- propertyname.append(".");
- propertyname.append(arraymark2);
- }
- }
- propertyname.append(".");
- propertyname.append(attribute);
- getProject().setNewProperty(propertyname.toString(),
- value.toString());
- }
- }
- }
-
-}
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>&lt;description&gt;/&lt;version&gt;</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");
- }
- }
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateTask.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateTask.java
deleted file mode 100644
index d43c6c9d..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateTask.java
+++ /dev/null
@@ -1,529 +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.catalina.ant.AbstractCatalinaTask;
-import org.apache.tools.ant.BuildException;
-
-/**
- * Ant task that implements the <code>/status</code> command, supported by the
- * mod_jk status (1.2.13) application.
- *
- *
- * @author Peter Rossbach
- * @version $Revision: 611693 $
- * @since 5.5.10
- * @deprecated
- */
-public class JkStatusUpdateTask extends AbstractCatalinaTask {
-
- /**
- * The descriptive information about this implementation.
- */
- private static final String info = "org.apache.jk.status.JkStatusUpdateTask/1.1";
-
- private String worker = "lb";
-
- private String workerType = "lb";
-
- private int internalid = 0;
-
- private Integer lbRetries;
-
- private Integer lbRecovertime;
-
- private Boolean lbStickySession = Boolean.TRUE;
-
- private Boolean lbForceSession = Boolean.FALSE;
-
- private Integer workerLoadFactor;
-
- private String workerJvmRoute ;
-
- private int workerDistance = -1;
-
- private String workerRedirect;
-
- private String workerClusterDomain;
-
- private Boolean workerDisabled ;
-
- private Boolean workerStopped ;
-
- private int workerActivation = -1;
-
- private boolean isLBMode = true;
-
-
-
- private String workerLb;
-
- /**
- * Return descriptive information about this implementation and the
- * corresponding version number, in the format
- * <code>&lt;description&gt;/&lt;version&gt;</code>.
- */
- public String getInfo() {
-
- return (info);
-
- }
-
- /**
- *
- */
- public JkStatusUpdateTask() {
- super();
- setUrl("http://localhost/jkstatus");
- }
-
- /**
- * @return Returns the workerDistance.
- */
- public int getWorkerDistance() {
- return workerDistance;
- }
-
- /**
- * @param workerDistance The workerDistance to set.
- */
- public void setWorkerDistance(int workerDistance) {
- this.workerDistance = workerDistance;
- }
-
- /**
- * @return Returns the workerJvmRoute.
- */
- public String getWorkerJvmRoute() {
- return workerJvmRoute;
- }
-
- /**
- * @param workerJvmRoute The workerJvmRoute to set.
- */
- public void setWorkerJvmRoute(String workerJvmRoute) {
- this.workerJvmRoute = workerJvmRoute;
- }
-
- /**
- * @return Returns the internalid.
- */
- public int getInternalid() {
- return internalid;
- }
-
- /**
- * @param internalid
- * The internalid to set.
- */
- public void setInternalid(int internalid) {
- this.internalid = internalid;
- }
-
- /**
- * @return Returns the lbForceSession.
- */
- public Boolean getLbForceSession() {
- return lbForceSession;
- }
-
- /**
- * @param lbForceSession
- * The lbForceSession to set.
- */
- public void setLbForceSession(Boolean lbForceSession) {
- this.lbForceSession = lbForceSession;
- }
-
- /**
- * @return Returns the lbRecovertime.
- */
- public Integer getLbRecovertime() {
- return lbRecovertime;
- }
-
- /**
- * @param lbRecovertime
- * The lbRecovertime to set.
- */
- public void setLbRecovertime(Integer lbRecovertime) {
- this.lbRecovertime = lbRecovertime;
- }
-
- /**
- * @return Returns the lbRetries.
- */
- public Integer getLbRetries() {
- return lbRetries;
- }
-
- /**
- * @param lbRetries
- * The lbRetries to set.
- */
- public void setLbRetries(Integer lbRetries) {
- this.lbRetries = lbRetries;
- }
-
- /**
- * @return Returns the lbStickySession.
- */
- public Boolean getLbStickySession() {
- return lbStickySession;
- }
-
- /**
- * @param lbStickySession
- * The lbStickySession to set.
- */
- public void setLbStickySession(Boolean lbStickySession) {
- this.lbStickySession = lbStickySession;
- }
-
- /**
- * @return Returns the worker.
- */
- public String getWorker() {
- return worker;
- }
-
- /**
- * @param worker
- * The worker to set.
- */
- public void setWorker(String worker) {
- this.worker = worker;
- }
-
- /**
- * @return Returns the workerType.
- */
- public String getWorkerType() {
- return workerType;
- }
-
- /**
- * @param workerType
- * The workerType to set.
- */
- public void setWorkerType(String workerType) {
- this.workerType = workerType;
- }
-
- /**
- * @return Returns the workerLb.
- */
- public String getWorkerLb() {
- return workerLb;
- }
-
- /**
- * @param workerLb
- * The workerLb to set.
- */
- public void setWorkerLb(String workerLb) {
- this.workerLb = workerLb;
- }
-
- /**
- * @return Returns the workerClusterDomain.
- */
- public String getWorkerClusterDomain() {
- return workerClusterDomain;
- }
-
- /**
- * @param workerClusterDomain
- * The workerClusterDomain to set.
- */
- public void setWorkerClusterDomain(String workerClusterDomain) {
- this.workerClusterDomain = workerClusterDomain;
- }
-
- /**
- * @return Returns the workerDisabled.
- */
- public Boolean getWorkerDisabled() {
- return workerDisabled;
- }
-
- /**
- * @param workerDisabled
- * The workerDisabled to set.
- */
- public void setWorkerDisabled(Boolean workerDisabled) {
- this.workerDisabled = workerDisabled;
- }
-
- /**
- * @return Returns the workerActivation.
- */
- public int getWorkerActivation() {
- return workerActivation;
- }
-
- /**
- * <ul>
- * <li>0 active</li>
- * <li>1 disabled</li>
- * <li>2 stopped</li>
- * </ul>
- * @param workerActivation The workerActivation to set.
- *
- */
- public void setWorkerActivation(int workerActivation) {
- this.workerActivation = workerActivation;
- }
-
- /**
- * @return Returns the workerStopped.
- */
- public Boolean getWorkerStopped() {
- return workerStopped;
- }
-
- /**
- * @param workerStopped The workerStopped to set.
- */
- public void setWorkerStopped(Boolean workerStopped) {
- this.workerStopped = workerStopped;
- }
-
- /**
- * @return Returns the workerLoadFactor.
- */
- public Integer getWorkerLoadFactor() {
- return workerLoadFactor;
- }
-
- /**
- * @param workerLoadFactor
- * The workerLoadFactor to set.
- */
- public void setWorkerLoadFactor(Integer workerLoadFactor) {
- this.workerLoadFactor = workerLoadFactor;
- }
-
- /**
- * @return Returns the workerRedirect.
- */
- public String getWorkerRedirect() {
- return workerRedirect;
- }
-
- /**
- * @param workerRedirect
- * The workerRedirect to set.
- */
- public void setWorkerRedirect(String workerRedirect) {
- this.workerRedirect = workerRedirect;
- }
-
- /**
- * Execute the requested operation.
- *
- * @exception BuildException
- * if an error occurs
- */
- public void execute() throws BuildException {
-
- super.execute();
- checkParameter();
- StringBuffer sb = createLink();
- execute(sb.toString(), null, null, -1);
-
- }
-
- /**
- * Create JkStatus link
- * <ul>
- * <li><b>load balance example:
- * </b>http://localhost/jkstatus?cmd=update&mime=txt&w=lb&vlf=false&vls=true</li>
- * <li><b>worker example:
- * </b>http://localhost/jkstatus?cmd=update&mime=txt&w=lb&sw=node1&vwn=node01&vwf=1&vwa=2&vwx=0
- * <br/>
- * <ul>
- * <li>vwa=0 active</li>
- * <li>vwa=1 disabled</li>
- * <li>vwa=2 stopped</li>
- * </ul>
- * </li>
- * </ul>
- *
- * <br/>Loadbalacing parameter:
- * <br/>
- * <ul>
- * <li><b>w:<b/> name lb worker</li>
- * <li><b>vlr:<b/> Number of Retries</li>
- * <li><b>vlt:<b/> recover wait time</li>
- * <li><b>vlf:<b/> Force Sticky Session</li>
- * <li><b>vls:<b/> Sticky session</li>
- * </ul>
- *
- * <br/>Tcp worker parameter:
- * <br/>
- * <ul>
- * <li><b>w:<b/> name worker</li>
- * <li><b>sw:<b/> name lb sub worker</li>
- * <li><b>vwf:<b/> load factor</li>
- * <li><b>vwn:<b/> jvm route</li>
- * <li><b>vwx:<b/> distance</li>
- * <li><b>vwa:<b/> activation state</li>
- * <li><b>vwr:<b/> redirect route</li>
- * <li><b>vwd:<b/> cluster domain</li>
- * <li><b>ws:<b/> stopped deprecated 1.2.16</li>
- * <li><b>wd:<b/> disabled deprecated 1.2.16</li>
- * </ul>
- *
- * @return create jkstatus link
- */
- private StringBuffer createLink() {
- // Building URL
- StringBuffer sb = new StringBuffer();
- try {
- sb.append("?cmd=update&mime=txt");
- sb.append("&w=");
-
- if (isLBMode) {
- sb.append(URLEncoder.encode(worker, getCharset()));
- //http://localhost/jkstatus?cmd=update&mime=txt&w=lb&vlf=false&vls=true
- if ((lbRetries != null)) { // > 0
- sb.append("&vlr=");
- sb.append(lbRetries);
- }
- if ((lbRecovertime != null)) { // > 59
- sb.append("&vlt=");
- sb.append(lbRecovertime);
- }
- if ((lbStickySession != null)) {
- sb.append("&vls=");
- sb.append(lbStickySession);
- }
- if ((lbForceSession != null)) {
- sb.append("&vlf=");
- sb.append(lbForceSession);
- }
- } else {
- //http://localhost/status?cmd=update&mime=txt&sw=node1&w=lb&vwf=1&wd=false&ws=false
- if (workerLb != null) { // must be configured
- sb.append(URLEncoder.encode(workerLb, getCharset()));
- }
- sb.append("&sw=");
- sb.append(URLEncoder.encode(worker, getCharset()));
- if (workerLoadFactor != null) { // >= 1
- sb.append("&vwf=");
- sb.append(workerLoadFactor);
- }
- if (workerJvmRoute != null) {
- sb.append("&vwn=");
- sb.append(URLEncoder.encode(workerJvmRoute, getCharset()));
- }
- if (workerDisabled != null) {
- sb.append("&vwd=");
- sb.append(workerDisabled);
- }
- if (workerStopped != null) {
- sb.append("&vws=");
- sb.append(workerStopped);
- }
- if (workerActivation >= 0 && workerActivation < 3) {
- sb.append("&vwa=");
- sb.append(workerActivation);
- }
- if (workerDistance >= 0) {
- sb.append("&vwx=");
- sb.append(workerDistance);
- }
- if (workerRedirect != null) { // other worker conrecte lb's
- sb.append("&vwr=");
- sb.append(URLEncoder.encode(workerRedirect,
- getCharset()));
- }
- if (workerClusterDomain != null) {
- sb.append("&vwc=");
- sb.append(URLEncoder.encode(workerClusterDomain,
- getCharset()));
- }
- }
-
- } catch (UnsupportedEncodingException e) {
- throw new BuildException("Invalid 'charset' attribute: "
- + getCharset());
- }
- return sb;
- }
-
- /**
- * check correct lb and worker pararmeter
- */
- protected void checkParameter() {
- if (worker == null) {
- throw new BuildException("Must specify 'worker' attribute");
- }
- if (workerType == null) {
- throw new BuildException("Must specify 'workerType' attribute");
- }
- if ("lb".equals(workerType)) {
- if (lbRecovertime == null && lbRetries == null) {
- throw new BuildException(
- "Must specify at a lb worker either 'lbRecovertime' or"
- + "'lbRetries' attribute");
- }
- if (lbStickySession == null || lbForceSession == null) {
- throw new BuildException("Must specify at a lb worker either"
- + "'lbStickySession' and 'lbForceSession' attribute");
- }
- if (null != lbRecovertime && 60 < lbRecovertime.intValue()) {
- throw new BuildException(
- "The 'lbRecovertime' must be greater than 59");
- }
- if (null != lbRetries && 1 < lbRetries.intValue()) {
- throw new BuildException(
- "The 'lbRetries' must be greater than 1");
- }
- isLBMode = true;
- } else if ("worker".equals(workerType)) {
- if (workerLoadFactor == null ) {
- throw new BuildException(
- "Must specify at a node worker 'workerLoadFactor' attribute");
- }
- if (workerClusterDomain == null) {
- throw new BuildException(
- "Must specify at a node worker 'workerClusterDomain' attribute");
- }
- if (workerRedirect == null) {
- throw new BuildException(
- "Must specify at a node worker 'workerRedirect' attribute");
- }
- if (workerLb == null) {
- throw new BuildException("Must specify 'workerLb' attribute");
- }
- if (workerLoadFactor.intValue() < 1) {
- throw new BuildException(
- "The 'workerLoadFactor' must be greater or equal 1");
- }
- isLBMode = false;
- } else {
- throw new BuildException(
- "Only 'lb' and 'worker' supported as workerType attribute");
- }
- }
-}
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateWorkerTask.java b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateWorkerTask.java
deleted file mode 100644
index e150e53a..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/JkStatusUpdateWorkerTask.java
+++ /dev/null
@@ -1,291 +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 worker command, supported by the
- * mod_jk status (1.2.20) application.
- *
- *
- * @author Peter Rossbach
- * @version $Revision: 802231 $
- * @since mod_jk 1.2.20
- */
-public class JkStatusUpdateWorkerTask extends AbstractJkStatusTask {
-
- /**
- * The descriptive information about this implementation.
- */
- private static final String info = "org.apache.jk.status.JkStatusUpdateWorkerTask/1.0";
-
- protected String loadbalancer ;
-
- protected String worker ;
-
- protected int loadfactor =-1;
-
- protected String route ;
-
- protected int distance = -1;
-
- protected String redirect;
-
- protected String domain;
-
- protected int activationCode = -1;
-
- protected String activation ;
-
- /**
- * Return descriptive information about this implementation and the
- * corresponding version number, in the format
- * <code>&lt;description&gt;/&lt;version&gt;</code>.
- */
- public String getInfo() {
-
- return (info);
-
- }
-
- /**
- *
- */
- public JkStatusUpdateWorkerTask() {
- super();
- setUrl("http://localhost/jkstatus");
- }
-
- /**
- * @return the activation
- */
- public String getActivation() {
- return activation;
- }
-
- /**
- * @param activation the activation to set
- */
- public void setActivation(String activation) {
- this.activation = activation;
- }
-
- /**
- * @return the activationCode
- */
- public int getActivationCode() {
- return activationCode;
- }
-
- /**
- * @param activationCode the activationCode to set
- */
- public void setActivationCode(int activationCode) {
- this.activationCode = activationCode;
- }
-
- /**
- * @return the distance
- */
- public int getDistance() {
- return distance;
- }
-
- /**
- * @param distance the distance to set
- */
- public void setDistance(int distance) {
- this.distance = distance;
- }
-
- /**
- * @return the domain
- */
- public String getDomain() {
- return domain;
- }
-
- /**
- * @param domain the domain to set
- */
- public void setDomain(String domain) {
- this.domain = domain;
- }
-
- /**
- * @return the loadbalancer
- */
- public String getLoadbalancer() {
- return loadbalancer;
- }
-
- /**
- * @param loadbalancer the loadbalaner to set
- */
- public void setLoadbalancer(String loadbalancer) {
- this.loadbalancer = loadbalancer;
- }
-
- /**
- * @return the loadfactor
- */
- public int getLoadfactor() {
- return loadfactor;
- }
-
- /**
- * @param loadfactor the loadfactor to set
- */
- public void setLoadfactor(int loadfactor) {
- this.loadfactor = loadfactor;
- }
-
- /**
- * @return the redirect
- */
- public String getRedirect() {
- return redirect;
- }
-
- /**
- * @param redirect the redirect to set
- */
- public void setRedirect(String redirect) {
- this.redirect = redirect;
- }
-
- /**
- * @return the route
- */
- public String getRoute() {
- return route;
- }
-
- /**
- * @param route the route to set
- */
- public void setRoute(String route) {
- this.route = route;
- }
-
- /**
- * @return the worker
- */
- public String getWorker() {
- return worker;
- }
-
- /**
- * @param worker the worker to set
- */
- public void setWorker(String worker) {
- this.worker = worker;
- }
-
-
-
- /**
- * Create JkStatus worker update link
- * <ul>
- * </b>http://localhost/jkstatus?cmd=update&mime=txt&w=loadbalancer&sw=node01&wn=node01&l=lb&wf=1&wa=1&wd=0
- * <br/>
- *
- *
- * <br/>Tcp worker parameter:
- * <br/>
- * <ul>
- * <li><b>w:<b/> name loadbalancer</li>
- * <li><b>sw:<b/> name tcp worker node</li>
- * <li><b>wf:<b/> load factor</li>
- * <li><b>wn:<b/> route</li>
- * <li><b>wd:<b/> distance</li>
- * <li><b>wa:<b/> activation state</li>
- * <li><b>wr:<b/> redirect route</li>
- * <li><b>wc:<b/> cluster domain</li>
- * </ul>
- * <ul>
- * <li>wa=1 active</li>
- * <li>wa=2 disabled</li>
- * <li>wa=3 stopped</li>
- * </ul>
- * </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()));
- sb.append("&sw=");
- sb.append(URLEncoder.encode(worker, getCharset()));
- if (loadfactor >= 0) {
- sb.append("&wf=");
- sb.append(loadfactor);
- }
- if (route != null) {
- sb.append("&wn=");
- sb.append(URLEncoder.encode(route, getCharset()));
- }
- if (activation == null && activationCode > 0 && activationCode < 4) {
- sb.append("&wa=");
- sb.append(activation);
- }
- if (activation != null) {
- sb.append("&wa=");
- sb.append(URLEncoder.encode(activation, getCharset()));
- }
- if (distance >= 0) {
- sb.append("&wd=");
- sb.append(distance);
- }
- if (redirect != null) { // other worker conrecte lb's
- sb.append("&wr=");
- sb.append(URLEncoder.encode(redirect, getCharset()));
- }
- if (domain != null) {
- sb.append("&wc=");
- sb.append(URLEncoder.encode(domain, getCharset()));
- }
-
- } catch (UnsupportedEncodingException e) {
- throw new BuildException("Invalid 'charset' attribute: "
- + getCharset());
- }
- return sb;
- }
-
- /**
- * check correct lb and worker pararmeter
- */
- protected void checkParameter() {
- if (worker == null) {
- throw new BuildException("Must specify 'worker' attribute");
- }
- if (loadbalancer == null) {
- throw new BuildException("Must specify 'loadbalancer' attribute");
- }
- }
-} \ No newline at end of file
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/LocalStrings.properties b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/LocalStrings.properties
deleted file mode 100644
index 09697dce..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/LocalStrings.properties
+++ /dev/null
@@ -1,15 +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.
-
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/antlib.xml b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/antlib.xml
deleted file mode 100644
index f9516026..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/antlib.xml
+++ /dev/null
@@ -1,34 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- 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.
--->
-<antlib>
- <typedef
- name="updateworker"
- classname="org.apache.jk.status.JkStatusUpdateWorkerTask" />
- <typedef
- name="updateloadbalancer"
- classname="org.apache.jk.status.JkStatusUpdateLoadbalancerTask" />
- <typedef
- name="update"
- classname="org.apache.jk.status.JkStatusUpdateTask" />
- <typedef
- name="reset"
- classname="org.apache.jk.status.JkStatusResetTask" />
- <typedef
- name="status"
- classname="org.apache.jk.status.JkStatusTask" />
-</antlib> \ No newline at end of file
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/jkstatus.tasks b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/jkstatus.tasks
deleted file mode 100644
index d7dea055..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/jkstatus.tasks
+++ /dev/null
@@ -1,22 +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.
-
-# Apache mod_jk jk status tasks
-jkUpdateWorker=org.apache.jk.status.JkStatusUpdateWorkerTask
-jkUpdateLoadbalancer=org.apache.jk.status.JkStatusUpdateLoadbalancerTask
-jkUpdate=org.apache.jk.status.JkStatusUpdateTask
-jkReset=org.apache.jk.status.JkStatusResetTask
-jkStatus=org.apache.jk.status.JkStatusTask
-
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/mbeans-descriptors.xml b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/mbeans-descriptors.xml
deleted file mode 100644
index 0ce42418..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/mbeans-descriptors.xml
+++ /dev/null
@@ -1,48 +0,0 @@
-<?xml version="1.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.
--->
-<mbeans-descriptors>
-
-<!--
- <mbean name="JkStatus"
- description="represent the apache mod_jk status"
- domain="Jk"
- group="Status"
- type="org.apache.jk.status.JkStatusMbean">
-
- <attribute name="className"
- description="Fully qualified class name of the managed object"
- type="java.lang.String"
- writeable="false"/>
-
- <attribute name="info"
- description="The base directory for Context configuration files"
- type="java.lang.String"
- writeable="false" />
-
- <operation name="check"
- description="Check a web application name for updates"
- impact="ACTION"
- returnType="void">
- <parameter name="name"
- description="Application name"
- type="java.lang.String"/>
- </operation>
-
- </mbean>
--->
-</mbeans-descriptors>
diff --git a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/package.html b/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/package.html
deleted file mode 100644
index b390e7f6..00000000
--- a/rubbos/app/tomcat-connectors-1.2.32-src/jkstatus/src/share/org/apache/jk/status/package.html
+++ /dev/null
@@ -1,224 +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.
--->
-<body>
-
-<p>This package contains a set of <code>Task</code> implementations for
-<em>Ant (version 1.6.x or later)</em> that can be used to interact with the
-Apaache mod_jk status page to show, update, disable and stop mod_jk worker.
-For more information, see
-<a href="http://tomcat.apache.org/connectors-doc/index.html"><strong>JK Documenation</strong></a>.</p>
-
-<p>The attributes of each task element correspond
-exactly to the request parameters that are included with an HTTP request
-sent directly to jk status page. They are summarized as follows:
-</p>
-
-<b>General parameter</b><br/>
-<table>
- <tr>
- <th align="center" width="15%">Attribute</th>
- <th align="center" width="85%">Description</th>
- </tr>
- <tr>
- <td align="center">url</td>
- <td>
- The URL of the jk status page you will use to
- perform the requested operations. If not specified, defaults to
- <code>http://localhost:80/jkstatus</code> (which corresponds
- to a standard installation of Apache mod_jk).
- </td>
- </tr>
- <tr>
- <td align="center">username</td>
- <td>
- The username of a mod_jk status user that has been configured with the
- <code>Allow user</code> Apache Location constraint. This attribute is optional.
- </td>
- </tr>
- <tr>
- <td align="center">password</td>
- <td>
- The password of a mod_jk status user that has been configured with the
- <code>Allow user</code> Apache Location constraint. This attribute is optional.
- </td>
- </tr>
- <tr>
- <td align="center">resultProperty</td>
- <td>
- Bind all show results with this prefix property name. This attribute is optional.
- </td>
- </tr>
- <tr>
- <td align="center">echo</td>
- <td>
- show result at ant console. (default false)
- </td>
- </tr>
- <tr>
- <td align="center">errorProperty</td>
- <td>
- set this property, as a failure detected. This attribute is optional.
- </td>
- </tr>
-</table>
-
-<b>Command show parameter</b><br/>
-<table>
- <tr>
- <th align="center" width="15%">Attribute</th>
- <th align="center" width="85%">Description</th>
- </tr>
- <tr>
- <td align="center">worker</td>
- <td>
- only bind properties from this balancer tcp worker (node)
- </td>
- </tr>
- <tr>
- <td align="center">loadbalancer</td>
- <td>
- only bind properties from this loadbalancer worker
- </td>
- </tr>
-</table>
-
-<b>Command reset parameter</b><br/>
-<table>
- <tr>
- <th align="center" width="15%">Attribute</th>
- <th align="center" width="85%">Description</th>
- </tr>
- <tr>
- <td align="center">workerLb</td>
- <td>
- name of loadbalancer worker.
- </td>
- </tr>
-</table>
-
-<b>Command update loadbalancer parameter</b><br/>
-<table>
- <tr>
- <th align="center" width="15%">Attribute</th>
- <th align="center" width="85%">Description</th>
- </tr>
- <tr>
- <td align="center">workerType=loadbalancer</td>
- <td>
- type of update
- </td>
- </tr>
- <tr>
- <td align="center">workerLb</td>
- <td>
- name of loadbalancer worker.
- </td>
- </tr>
- <tr>
- <td align="center">lbForceSession</td>
- <td>
- Force Sticky Session. (true/false)
- </td>
- </tr>
- <tr>
- <td align="center">lbStickySession</td>
- <td>
- Sticky Session. (true/false)
- </td>
- </tr>
- <tr>
- <td align="center">lbRetries</td>
- <td>
- loadbalancer retries after worker connection failure (int)
- </td>
- </tr>
- <tr>
- <td align="center">lbRecovertime</td>
- <td>
- Recover timeout after a worker set to "error" state (int sec's)
- </td>
- </tr>
-</table>
-
-<b>Command update worker parameter</b><br/>
-<table>
- <tr>
- <th align="center" width="15%">Attribute</th>
- <th align="center" width="85%">Description</th>
- </tr>
- <tr>
- <td align="center">workerType=worker</td>
- <td>
- type of update
- </td>
- </tr>
- <tr>
- <td align="center">worker</td>
- <td>
- name of tcp worker.
- </td>
- </tr>
- <tr>
- <td align="center">workerActivation (>=1.2.19</td>
- <td>
- set worker activation (1 Active, 2 Disabled, 3 Stopped)
- </td>
- </tr>
- <tr>
- <td align="center">workerDisabled (< 1.2.19)</td>
- <td>
- set disable state. (true/false)
- </td>
- </tr>
- <tr>
- <td align="center">workerStoppend (< 1.2.19)</td>
- <td>
- set stopped state. (true/false)
- </td>
- </tr>
- <tr>
- <td align="center">workerJvmRoute</td>
- <td>
- set jvm route
- </td>
- </tr>
- <tr>
- <td align="center">workerLaodFactor</td>
- <td>
- set load factor (int)
- </td>
- </tr>
- <tr>
- <td align="center">workerDistance</td>
- <td>
- set worker distance (int)
- </td>
- <tr>
- <td align="center">workerRedirect</td>
- <td>
- other worker name to redirect after failure
- </td>
- </tr>
- <tr>
- <td align="center">workerClusterDomain</td>
- <td>
- cluster domain name, group of worker at a repliation cluster.
- </td>
- </tr>
-</table>
-
-</body>