Author: jfrederic.clere(a)jboss.com
Date: 2008-07-11 05:25:48 -0400 (Fri, 11 Jul 2008)
New Revision: 707
Modified:
trunk/java/org/jboss/web/cluster/ClusterListener.java
Log:
Add a synchronized for reset().
Add a space for easier parsing in getProxyConfiguration and getProxyInfo.
Modified: trunk/java/org/jboss/web/cluster/ClusterListener.java
===================================================================
--- trunk/java/org/jboss/web/cluster/ClusterListener.java 2008-07-10 16:50:49 UTC (rev
706)
+++ trunk/java/org/jboss/web/cluster/ClusterListener.java 2008-07-11 09:25:48 UTC (rev
707)
@@ -661,7 +661,7 @@
Proxy[] local = proxies;
StringBuffer result = new StringBuffer();
for (int i = 0; i < local.length; i++) {
-
result.append("Proxy[").append(i).append("]:[").append(local[i].address)
+ result.append("Proxy[").append(i).append("]:
[").append(local[i].address)
.append(':').append(local[i].port).append("]: \r\n");
result.append(sendRequest("DUMP", true, parameters, i));
result.append("\r\n");
@@ -680,7 +680,7 @@
Proxy[] local = proxies;
StringBuffer result = new StringBuffer();
for (int i = 0; i < local.length; i++) {
-
result.append("Proxy[").append(i).append("]:[").append(local[i].address)
+ result.append("Proxy[").append(i).append("]:
[").append(local[i].address)
.append(':').append(local[i].port).append("]: \r\n");
result.append(sendRequest("INFO", true, parameters, i));
result.append("\r\n");
@@ -897,8 +897,8 @@
/**
* Reset configuration for a particular proxy following an error.
*/
- protected void reset(int pos) {
-
+ protected synchronized void reset(int pos) {
+
Service[] services = ServerFactory.getServer().findServices();
for (int i = 0; i < services.length; i++) {
Engine engine = (Engine) services[i].getContainer();
Show replies by date