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: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org