Author: markt
Date: Sat Mar 7 15:16:50 2015
New Revision: 1664863
URL: http://svn.apache.org/r1664863
Log:
Make the packet size used by the test AJP client configurable
Modified:
tomcat/trunk/test/org/apache/coyote/ajp/SimpleAjpClient.java
Modified: tomcat/trunk/test/org/apache/coyote/ajp/SimpleAjpClient.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/test/org/apache/coyote/ajp/SimpleAjpClient.java?rev=1664863&r1=1664862&r2=1664863&view=diff
==============================================================================
--- tomcat/trunk/test/org/apache/coyote/ajp/SimpleAjpClient.java (original)
+++ tomcat/trunk/test/org/apache/coyote/ajp/SimpleAjpClient.java Sat Mar 7
15:16:50 2015
@@ -30,7 +30,7 @@ import javax.net.SocketFactory;
*/
public class SimpleAjpClient {
- private static final int AJP_PACKET_SIZE = 8192;
+ private static final int DEFAULT_AJP_PACKET_SIZE = 8192;
private static final byte[] AJP_CPING;
static {
@@ -43,6 +43,7 @@ public class SimpleAjpClient {
ajpCping.getLen());
}
+ private final int packetSize;
private String host = "localhost";
private int port = -1;
/* GET == 2 */
@@ -56,6 +57,14 @@ public class SimpleAjpClient {
private boolean ssl = false;
private Socket socket = null;
+ public SimpleAjpClient() {
+ this(DEFAULT_AJP_PACKET_SIZE);
+ }
+
+ public SimpleAjpClient(int packetSize) {
+ this.packetSize = packetSize;
+ }
+
public void setPort(int port) {
this.port = port;
}
@@ -284,7 +293,7 @@ public class SimpleAjpClient {
*/
public TesterAjpMessage createForwardMessage() {
- TesterAjpMessage message = new TesterAjpMessage(AJP_PACKET_SIZE);
+ TesterAjpMessage message = new TesterAjpMessage(packetSize);
message.reset();
// Set the header bytes
@@ -323,7 +332,7 @@ public class SimpleAjpClient {
public TesterAjpMessage createBodyMessage(byte[] data) {
- TesterAjpMessage message = new TesterAjpMessage(AJP_PACKET_SIZE);
+ TesterAjpMessage message = new TesterAjpMessage(packetSize);
message.reset();
// Set the header bytes
@@ -376,7 +385,7 @@ public class SimpleAjpClient {
InputStream is = socket.getInputStream();
- TesterAjpMessage message = new TesterAjpMessage(AJP_PACKET_SIZE);
+ TesterAjpMessage message = new TesterAjpMessage(packetSize);
byte[] buf = message.getBuffer();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
