Returns a reference to {@code this} so multiple operations can be appended together.
269270271272273274275276277278279
thisTime=chunkSize; } len-=thisTime; msg.reset(); msg.appendByte( HandlerRequest.JK_AJP13_SEND_BODY_CHUNK); if( log.isDebugEnabled() ) log.debug("doWrite " + off + " " + thisTime + " " + len ); msg.appendBytes( chunk.getBytes(), chunk.getOffset() + off, thisTime ); off+=thisTime; ep.setType( JkHandler.HANDLE_SEND_PACKET ); ep.getSource().invoke( msg, ep );
367368369370371372373374375376377
} MsgContext ep=(MsgContext)res.getNote( epNote ); MsgAjp msg=(MsgAjp)ep.getNote( headersMsgNote ); msg.reset(); msg.appendByte(HandlerRequest.JK_AJP13_SEND_HEADERS); msg.appendInt( res.getStatus() ); MessageBytes mb=(MessageBytes)ep.getNote( tmpMessageBytesNote ); if( mb==null ) { mb=new MessageBytes();
463464465466467468469470471472473
if( !res.isCommitted() ) this.action( ActionCode.ACTION_COMMIT, param ); MsgAjp msg=(MsgAjp)ep.getNote( headersMsgNote ); msg.reset(); msg.appendByte( HandlerRequest.JK_AJP13_END_RESPONSE ); msg.appendByte( 1 ); ep.setType( JkHandler.HANDLE_SEND_PACKET ); ep.getSource().invoke( msg, ep );
464465466467468469470471472473474
this.action( ActionCode.ACTION_COMMIT, param ); MsgAjp msg=(MsgAjp)ep.getNote( headersMsgNote ); msg.reset(); msg.appendByte( HandlerRequest.JK_AJP13_END_RESPONSE ); msg.appendByte( 1 ); ep.setType( JkHandler.HANDLE_SEND_PACKET ); ep.getSource().invoke( msg, ep ); ep.setType( JkHandler.HANDLE_FLUSH );
249250251252253254255256257258259
thisTime=chunkSize; } len-=thisTime; msg.reset(); msg.appendByte( HandlerRequest.JK_AJP13_SEND_BODY_CHUNK); if( log.isDebugEnabled() ) log.debug("doWrite " + off + " " + thisTime + " " + len ); msg.appendBytes( chunk.getBytes(), chunk.getOffset() + off, thisTime ); off+=thisTime; ep.setType( JkHandler.HANDLE_SEND_PACKET ); ep.getSource().send( msg, ep );
349350351352353354355356357358359
445446447448449450451452453454455
if( !res.isCommitted() ) this.action( ActionCode.ACTION_COMMIT, param ); MsgAjp msg=(MsgAjp)ep.getNote( headersMsgNote ); msg.reset(); msg.appendByte( HandlerRequest.JK_AJP13_END_RESPONSE ); msg.appendByte( 1 ); try { ep.setType( JkHandler.HANDLE_SEND_PACKET ); ep.getSource().send( msg, ep );
446447448449450451452453454455456
this.action( ActionCode.ACTION_COMMIT, param ); MsgAjp msg=(MsgAjp)ep.getNote( headersMsgNote ); msg.reset(); msg.appendByte( HandlerRequest.JK_AJP13_END_RESPONSE ); msg.appendByte( 1 ); try { ep.setType( JkHandler.HANDLE_SEND_PACKET ); ep.getSource().send( msg, ep );
241242243244245246247248249250251
339340341342343344345346347348349