|
Lines 742-753
Link Here
|
| 742 |
} |
742 |
} |
| 743 |
|
743 |
|
| 744 |
/** |
744 |
/** |
| 745 |
* Process pipelined HTTP requests using the specified input and output |
745 |
* Process pipelined HTTP requests on the specified socket. |
| 746 |
* streams. |
|
|
| 747 |
* |
746 |
* |
| 748 |
* @param input stream from which the HTTP requests will be read |
747 |
* @param socket socket from which the HTTP requests will be read |
| 749 |
* @param output stream which will be used to output the HTTP |
748 |
* and the HTTP responses will be written |
| 750 |
* responses |
|
|
| 751 |
* @throws IOException error during an I/O operation |
749 |
* @throws IOException error during an I/O operation |
| 752 |
*/ |
750 |
*/ |
| 753 |
public void process(Socket socket) |
751 |
public void process(Socket socket) |
|
Lines 774-780
Link Here
|
| 774 |
|
772 |
|
| 775 |
int keepAliveLeft = maxKeepAliveRequests; |
773 |
int keepAliveLeft = maxKeepAliveRequests; |
| 776 |
int soTimeout = socket.getSoTimeout(); |
774 |
int soTimeout = socket.getSoTimeout(); |
| 777 |
int oldSoTimeout = soTimeout; |
|
|
| 778 |
|
775 |
|
| 779 |
int threadRatio = (endpoint.getCurrentThreadsBusy() * 100) |
776 |
int threadRatio = (endpoint.getCurrentThreadsBusy() * 100) |
| 780 |
/ endpoint.getMaxThreads(); |
777 |
/ endpoint.getMaxThreads(); |
|
Lines 782-796
Link Here
|
| 782 |
keepAliveLeft = 1; |
779 |
keepAliveLeft = 1; |
| 783 |
} |
780 |
} |
| 784 |
|
781 |
|
| 785 |
if (soTimeout != oldSoTimeout) { |
|
|
| 786 |
try { |
| 787 |
socket.setSoTimeout(soTimeout); |
| 788 |
} catch (Throwable t) { |
| 789 |
log.debug(sm.getString("http11processor.socket.timeout"), t); |
| 790 |
error = true; |
| 791 |
} |
| 792 |
} |
| 793 |
|
| 794 |
boolean keptAlive = false; |
782 |
boolean keptAlive = false; |
| 795 |
|
783 |
|
| 796 |
while (started && !error && keepAlive) { |
784 |
while (started && !error && keepAlive) { |