costin 02/04/17 15:39:26
Modified: jk/java/org/apache/jk/server JkCoyoteHandler.java
Log:
Update.
Revision Changes Path
1.11 +6 -3
jakarta-tomcat-connectors/jk/java/org/apache/jk/server/JkCoyoteHandler.java
Index: JkCoyoteHandler.java
===================================================================
RCS file:
/home/cvs/jakarta-tomcat-connectors/jk/java/org/apache/jk/server/JkCoyoteHandler.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- JkCoyoteHandler.java 10 Apr 2002 23:53:11 -0000 1.10
+++ JkCoyoteHandler.java 17 Apr 2002 22:39:26 -0000 1.11
@@ -178,7 +178,8 @@
msg.reset();
msg.appendByte( HandlerRequest.JK_AJP13_SEND_BODY_CHUNK);
msg.appendBytes( chunk.getBytes(), chunk.getOffset(), chunk.getLength() );
- ep.getChannel().send( msg, ep );
+ ep.setType( JkHandler.HANDLE_SEND_PACKET );
+ ep.getSource().invoke( msg, ep );
return 0;
}
@@ -270,7 +271,8 @@
c2b.convert( hV );
msg.appendBytes( hV );
}
- ep.getChannel().send( msg, ep );
+ ep.setType( JkHandler.HANDLE_SEND_PACKET );
+ ep.getSource().invoke( msg, ep );
} else if( actionCode==ActionCode.ACTION_RESET ) {
if( log.isInfoEnabled() )
log.info("RESET " );
@@ -286,7 +288,8 @@
msg.appendByte( HandlerRequest.JK_AJP13_END_RESPONSE );
msg.appendInt( 1 );
- ep.getChannel().send(msg, ep );
+ ep.setType( JkHandler.HANDLE_SEND_PACKET );
+ ep.getSource().invoke( msg, ep );
} else if( actionCode==ActionCode.ACTION_REQ_SSL_ATTRIBUTE ) {
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
