Attachment #20882 for bug #43478

View | Details | Raw Unified | Return to bug 43478
Collapse All | Expand All




            
        } else if( actionCode==ActionCode.ACTION_CLIENT_FLUSH ) {
            if( log.isDebugEnabled() ) log.debug("CLIENT_FLUSH " );
            Response res = (Response)param;
            if(!res.isCommitted()) {
		action(ActionCode.ACTION_COMMIT, res);
	    }
            try {
                source.flush( null, this );
            } catch(IOException iex) {
                // This is logged elsewhere, so debug only here
                log.debug("Error during flush",iex);
                Response res = (Response)param;
                res.setErrorException(iex);
                setStatus(JK_STATUS_ERROR);
            }

Return to bug 43478

Lines 276-287 Link Here

(-)MsgContext.java (-1 / +4 lines)
276		276
277	} else if( actionCode==ActionCode.ACTION_CLIENT_FLUSH ) {	277	} else if( actionCode==ActionCode.ACTION_CLIENT_FLUSH ) {
278	if( log.isDebugEnabled() ) log.debug("CLIENT_FLUSH " );	278	if( log.isDebugEnabled() ) log.debug("CLIENT_FLUSH " );
		279	Response res = (Response)param;
		280	if(!res.isCommitted()) {
		281	action(ActionCode.ACTION_COMMIT, res);
		282	}
279	try {	283	try {
280	source.flush( null, this );	284	source.flush( null, this );
281	} catch(IOException iex) {	285	} catch(IOException iex) {
282	// This is logged elsewhere, so debug only here	286	// This is logged elsewhere, so debug only here
283	log.debug("Error during flush",iex);	287	log.debug("Error during flush",iex);
284	Response res = (Response)param;
285	res.setErrorException(iex);	288	res.setErrorException(iex);
286	setStatus(JK_STATUS_ERROR);	289	setStatus(JK_STATUS_ERROR);
287	}	290	}