Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.apache.jk.common
Class JkInputStream  view JkInputStream download JkInputStream.java

java.lang.Object
  extended byorg.apache.jk.common.JkInputStream
All Implemented Interfaces:
org.apache.coyote.InputBuffer, org.apache.coyote.OutputBuffer

public class JkInputStream
extends java.lang.Object
implements org.apache.coyote.InputBuffer, org.apache.coyote.OutputBuffer

Generic input stream impl on top of ajp


Field Summary
private  org.apache.tomcat.util.buf.MessageBytes bodyBuff
           
private  org.apache.jk.core.Msg bodyMsg
           
private  boolean end_of_stream
           
private  boolean isEmpty
           
private  boolean isFirst
           
private  boolean isReadRequired
           
private  boolean isReplay
           
private static org.apache.commons.logging.Log log
           
private  org.apache.jk.core.MsgContext mc
           
private  org.apache.jk.core.Msg outputMsg
           
private  org.apache.tomcat.util.buf.MessageBytes tempMB
           
 
Constructor Summary
JkInputStream(org.apache.jk.core.MsgContext context)
           
 
Method Summary
 void appendHead(org.apache.coyote.Response res)
           
 int doRead(org.apache.tomcat.util.buf.ByteChunk responseChunk, org.apache.coyote.Request req)
          Return from the input stream.
 int doWrite(org.apache.tomcat.util.buf.ByteChunk chunk, org.apache.coyote.Response res)
          Write the response.
 void endMessage()
           
 boolean isReadRequired()
          Return the flag saying that the server is sending a body
 boolean receive()
          Receive a chunk of data.
 void recycle()
          Must be called before or after each request
private  boolean refillReadBuffer()
          Get more request body data from the web server and store it in the internal buffer.
 void setIsReadRequired(boolean irr)
          Set the flag saying that the server is sending a body
 void setReplay(org.apache.tomcat.util.buf.ByteChunk replay)
          Set the replay buffer for Form auth
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

private static org.apache.commons.logging.Log log

bodyMsg

private org.apache.jk.core.Msg bodyMsg

outputMsg

private org.apache.jk.core.Msg outputMsg

mc

private org.apache.jk.core.MsgContext mc

bodyBuff

private org.apache.tomcat.util.buf.MessageBytes bodyBuff

tempMB

private org.apache.tomcat.util.buf.MessageBytes tempMB

end_of_stream

private boolean end_of_stream

isEmpty

private boolean isEmpty

isFirst

private boolean isFirst

isReplay

private boolean isReplay

isReadRequired

private boolean isReadRequired
Constructor Detail

JkInputStream

public JkInputStream(org.apache.jk.core.MsgContext context)
Method Detail

setIsReadRequired

public void setIsReadRequired(boolean irr)
Set the flag saying that the server is sending a body


isReadRequired

public boolean isReadRequired()
Return the flag saying that the server is sending a body


recycle

public void recycle()
Must be called before or after each request


endMessage

public void endMessage()
                throws java.io.IOException

doWrite

public int doWrite(org.apache.tomcat.util.buf.ByteChunk chunk,
                   org.apache.coyote.Response res)
            throws java.io.IOException
Description copied from interface: org.apache.coyote.OutputBuffer
Write the response. The caller ( tomcat ) owns the chunks.

Specified by:
doWrite in interface org.apache.coyote.OutputBuffer

doRead

public int doRead(org.apache.tomcat.util.buf.ByteChunk responseChunk,
                  org.apache.coyote.Request req)
           throws java.io.IOException
Description copied from interface: org.apache.coyote.InputBuffer
Return from the input stream. IMPORTANT: the current model assumes that the protocol will 'own' the buffer and return a pointer to it in ByteChunk ( i.e. the param will have chunk.getBytes()==null before call, and the result after the call ).

Specified by:
doRead in interface org.apache.coyote.InputBuffer

receive

public boolean receive()
                throws java.io.IOException
Receive a chunk of data. Called to implement the 'special' packet in ajp13 and to receive the data after we send a GET_BODY packet


refillReadBuffer

private boolean refillReadBuffer()
                          throws java.io.IOException
Get more request body data from the web server and store it in the internal buffer.


appendHead

public void appendHead(org.apache.coyote.Response res)
                throws java.io.IOException

setReplay

public void setReplay(org.apache.tomcat.util.buf.ByteChunk replay)
Set the replay buffer for Form auth