private int socketTimeout = 0;
private boolean nioIsBroken = false;
private Selector selector = null;
- private int bufferSize = 8*1024;
- private int packetSize = 8*1024;
+ private int bufferSize = AjpConstants.MAX_PACKET_SIZE;
+ private int packetSize = AjpConstants.MAX_PACKET_SIZE;
private long requestCount=0;
}
public void setBufferSize(int bs) {
- if(bs > 8*1024) {
+ if(bs > AjpConstants.MAX_PACKET_SIZE) {
bufferSize = bs;
}
}
}
public void setPacketSize(int ps) {
- if(ps < 8*1024) {
- ps = 8*1024;
+ if(ps < AjpConstants.MAX_PACKET_SIZE) {
+ ps = AjpConstants.MAX_PACKET_SIZE;
}
packetSize = ps;
}
private int linger=100;
private int socketTimeout;
private int bufferSize = -1;
- private int packetSize = 8*1024;
+ private int packetSize = AjpConstants.MAX_PACKET_SIZE;
private long requestCount=0;
}
public void setPacketSize(int ps) {
- if(ps < 8*1024) {
- ps = 8*1024;
+ if(ps < AjpConstants.MAX_PACKET_SIZE) {
+ ps = AjpConstants.MAX_PACKET_SIZE;
}
packetSize = ps;
}
* Constructor that takes a buffer size
*/
public MsgAjp(int bsize) {
- if(bsize < 8*1024) {
- bsize = 8*1024;
+ if(bsize < AjpConstants.MAX_PACKET_SIZE) {
+ bsize = AjpConstants.MAX_PACKET_SIZE;
}
bufsize = bsize;
buf = new byte[bsize];
* @deprecated Use the buffer size constructor.
*/
public MsgAjp() {
- this(8*1024);
+ this(AjpConstants.MAX_PACKET_SIZE);
}
/**