Author: pferraro
Date: 2008-10-23 11:34:18 -0400 (Thu, 23 Oct 2008)
New Revision: 1994
Modified:
trunk/mod_cluster/src/main/java/org/jboss/modcluster/mcmp/impl/DefaultMCMPHandler.java
Log:
Fixed regression in sendRequest()
Modified:
trunk/mod_cluster/src/main/java/org/jboss/modcluster/mcmp/impl/DefaultMCMPHandler.java
===================================================================
---
trunk/mod_cluster/src/main/java/org/jboss/modcluster/mcmp/impl/DefaultMCMPHandler.java 2008-10-23
13:30:41 UTC (rev 1993)
+++
trunk/mod_cluster/src/main/java/org/jboss/modcluster/mcmp/impl/DefaultMCMPHandler.java 2008-10-23
15:34:18 UTC (rev 1994)
@@ -459,7 +459,11 @@
{
Map<String, ResetRequestSource.EngineStatus> parsedResponse =
this.parseInfoResponse(response);
-
this.sendRequests(this.resetRequestSource.getResetRequests(parsedResponse));
+ List<MCMPRequest> requests =
this.resetRequestSource.getResetRequests(parsedResponse);
+
+ log.trace(requests);
+
+ this.sendRequests(requests);
}
}
}
@@ -475,6 +479,8 @@
{
if (response == null) return Collections.emptyMap();
+ log.trace(response);
+
Map<String, ResetRequestSource.EngineStatus> result = new HashMap<String,
ResetRequestSource.EngineStatus>();
ResetRequestSource.EngineStatus engineStatus = null;
@@ -558,6 +564,8 @@
}
}
+ log.trace(result);
+
return result;
}
@@ -735,14 +743,17 @@
}
builder.append(" HTTP/1.0");
-
+
writer.write(builder.toString());
writer.write("\r\n");
- writer.write("Content-Length: " + encoder.getLength() +
"\r\n");
+
+ int length = encoder.getLength();
+
+ writer.write("Content-Length: " + length + "\r\n");
writer.write("User-Agent: ClusterListener/1.0\r\n");
writer.write("Connection: Keep-Alive\r\n");
writer.write("\r\n");
- writer.write(encoder.getBuffer());
+ writer.write(encoder.getBuffer(), 0, length);
writer.write("\r\n");
writer.flush();
Show replies by date