this.endpoint = endpoint;
request = new Request();
- int readTimeout = endpoint.getFirstReadTimeout();
- if (readTimeout == 0) {
- readTimeout = 100;
- } else if (readTimeout < 0) {
- readTimeout = timeout;
- //readTimeout = -1;
- }
+ int readTimeout = endpoint.getSoTimeout();
inputBuffer = new InternalNioInputBuffer(request, maxHttpHeaderSize,readTimeout);
request.setInputBuffer(inputBuffer);
long soTimeout = endpoint.getSoTimeout();
int limit = 0;
- if (endpoint.getFirstReadTimeout() > 0 || endpoint.getFirstReadTimeout() < -1) {
- limit = endpoint.getMaxThreads() / 2;
- }
boolean keptAlive = false;
boolean openSocket = false;
setAttribute("port", "" + port);
}
- public int getFirstReadTimeout() {
- return ep.getFirstReadTimeout();
- }
-
- public void setFirstReadTimeout( int i ) {
- ep.setFirstReadTimeout(i);
- setAttribute("firstReadTimeout", "" + i);
- }
-
public InetAddress getAddress() {
return ep.getAddress();
}
public void setSoTimeout(int soTimeout) { socketProperties.setSoTimeout(soTimeout); }
/**
- * Timeout on first request read before going to the poller, in ms.
- */
- protected int firstReadTimeout = 60000;
- public int getFirstReadTimeout() { return firstReadTimeout; }
- public void setFirstReadTimeout(int firstReadTimeout) { this.firstReadTimeout = firstReadTimeout; }
-
- /**
* The default is true - the created threads will be
* in daemon mode. If set to false, the control thread
* will not be daemon - and will keep the process alive.