if (!endpoint.isPaused()) {
request.setStartTime(System.currentTimeMillis());
keptAlive = true;
+ inputBuffer.parseHeaders();
if (!disableUploadTimeout) {
Socket.timeoutSet(socketRef,
connectionUploadTimeout * 1000);
}
- inputBuffer.parseHeaders();
}
} catch (IOException e) {
if (log.isDebugEnabled()) {
} else {
request.setStartTime(System.currentTimeMillis());
keptAlive = true;
- if (disableUploadTimeout) {
- socket.getSocket().setSoTimeout(soTimeout);
- } else {
+ // Reset timeout for reading headers
+ socket.getSocket().setSoTimeout(soTimeout);
+ inputBuffer.parseHeaders();
+ if (!disableUploadTimeout) {
socket.getSocket().setSoTimeout(connectionUploadTimeout);
}
- inputBuffer.parseHeaders();
}
} catch (IOException e) {
if (log.isDebugEnabled()) {