common/src/main/java/HTTPClient/StreamDemultiplexor.java
/**
     * Retries outstanding requests. Well, actually the RetryModule does
     * that. Here we just throw a RetryException for each request so that
     * the RetryModule can catch and handle them.
     *
     * @param exception the exception that led to this call.
     * @param was_reset this flag is passed to the RetryException and is
     *                  used by the RetryModule to distinguish abnormal closes
     *                  from expected closes.
     */
Retries outstanding requests. Well, actually the RetryModule does
that. Here we just throw a RetryException for each request so that
the RetryModule can catch and handle them.

@param exception the exception that led to this call.
@param was_reset this flag is passed to the RetryException and is
used by the RetryModule to distinguish abnormal closes
from expected closes.
Retries outstanding requests . Well actually the RetryModule does that . Here we just throw a RetryException for each request so that the RetryModule can catch and handle them . @param exception the exception that led to this call . @param was_reset this flag is passed to the RetryException and is used by the RetryModule to distinguish abnormal closes from expected closes .
private void retry_requests(IOException exception, boolean was_reset)
    {
	RetryException  first = null,
			prev  = null;
	ResponseHandler resph = (ResponseHandler) RespHandlerList.enumerate();
	while (resph != null)
	{
	    /* if the application is already reading the data then the
	     * response has already been handled. In this case we must
	     * throw the real exception.
	     */
	    if (resph.resp.got_headers)
	    {
		resph.exception = exception;
	    }
	    else
	    {
		RetryException tmp = new RetryException(exception.getMessage());
		if (first == null)  first = tmp;
		tmp.request    = resph.request;
		tmp.response   = resph.resp;
		tmp.exception  = exception;
		tmp.conn_reset = was_reset;
		tmp.first      = first;
		tmp.addToListAfter(prev);
		prev = tmp;
		resph.exception = tmp;
	    }
	    RespHandlerList.remove(resph);
	    resph = (ResponseHandler) RespHandlerList.next();
	}
    }
private void retry_requests ( IOException exception , boolean was_reset ) { RetryException first = null , prev = null ; ResponseHandler resph = ( ResponseHandler ) RespHandlerList . enumerate ( ) ; while ( resph != null ) { /* if the application is already reading the data then the
	     * response has already been handled. In this case we must
	     * throw the real exception.
	     */ if ( resph . resp . got_headers ) { resph . exception = exception ; } else { RetryException tmp = new RetryException ( exception . getMessage ( ) ) ; if ( first == null ) first = tmp ; tmp . request = resph . request ; tmp . response = resph . resp ; tmp . exception = exception ; tmp . conn_reset = was_reset ; tmp . first = first ; tmp . addToListAfter ( prev ) ; prev = tmp ; resph . exception = tmp ; } RespHandlerList . remove ( resph ) ; resph = ( ResponseHandler ) RespHandlerList . next ( ) ; } }
Retries outstanding requests.
Retries outstanding requests .