Package com.wowza.io

Class HTTPByteReader

Object
com.wowza.io.HTTPByteReader
Direct Known Subclasses:
HTTPByteReaderS3
public class HTTPByteReader extends Object

  • Field Details

    • MAXHEADERSIZE

      public static final int MAXHEADERSIZE
      See Also:

    • BUFFERINCSIZE

      public static final int BUFFERINCSIZE
      See Also:

    • TIMEOUT

      public static final int TIMEOUT
      See Also:

    • SENDBUFFERSIZE

      public static final int SENDBUFFERSIZE
      See Also:

    • RECEIVEBUFFERSIZE

      public static final int RECEIVEBUFFERSIZE
      See Also:

    • CRLF

      public static final String CRLF
      See Also:

    • HEADINDEX_STATUS

      public static final int HEADINDEX_STATUS
      See Also:

    • HEADINDEX_CONTENTLENGTH

      public static final int HEADINDEX_CONTENTLENGTH
      See Also:

    • HEADINDEX_LASTMODIFIED

      public static final int HEADINDEX_LASTMODIFIED
      See Also:

    • HEADINDEX_SIZE

      public static final int HEADINDEX_SIZE
      See Also:

    • host

      protected String host

    • port

      protected int port

    • reqPath

      protected String reqPath

    • proxyHost

      protected String proxyHost

    • proxyPort

      protected int proxyPort

    • dateFormat

      protected org.apache.commons.lang3.time.FastDateFormat dateFormat

    • socket

      protected Socket socket

    • msgBuf

      protected StringBuffer msgBuf

    • maxRetries

      protected int maxRetries

    • maxUsesBeforeReconnect

      protected int maxUsesBeforeReconnect

    • uses

      protected int uses

    • readTimeout

      protected int readTimeout

    • connectionTimeout

      protected int connectionTimeout

    • debugInfo

      protected List<String> debugInfo

    • debugPrefix

      protected String debugPrefix

    • requestFullURL

      protected boolean requestFullURL

    • parseDateFormats

      protected String[] parseDateFormats

    • sendBufferSize

      protected int sendBufferSize

    • receiveBufferSize

      protected int receiveBufferSize

    • userAgent

      protected String userAgent

  • Constructor Details

    • HTTPByteReader

      public HTTPByteReader(String host, int port)

  • Method Details

    • setProxyAddress

      public void setProxyAddress(String host, int port)

    • close

      public void close()

    • connect

      public void connect()

    • reconnect

      protected void reconnect()

    • isOpen

      public boolean isOpen()

    • parseHeader

      protected void parseHeader(HTTPByteReader.SendResult result, byte[] buffer, int offset, int len, boolean isHead)

    • read

      public HTTPByteReaderResult read(String path, long pos, int flen)

    • delete

      public HTTPByteReaderResult delete(String path)

    • getDeleteCommand

      protected void getDeleteCommand(String path)

    • deleteDirect

      public HTTPByteReaderResult deleteDirect(String path)

    • write

      public HTTPByteReaderResult write(String path, String str)

    • write

      public HTTPByteReaderResult write(String path, byte[] buffer, int offset, int len)

    • write

      public HTTPByteReaderResult write(String path, PacketFragmentList fragmentList)

    • getPostCommand

      protected void getPostCommand(String path, PacketFragmentList fragmentList)

    • writeDirect

      public HTTPByteReaderResult writeDirect(String path, PacketFragmentList fragmentList)

    • getRequestPath

      protected String getRequestPath(String path, String host, int port)

    • getConextPath

      protected String getConextPath()

    • getHeadCommand

      protected void getHeadCommand(String path)

    • head

      public long[] head(String path)

    • getGetCommand

      protected void getGetCommand(String path, long pos, int flen)

    • readDirect

      public HTTPByteReaderResult readDirect(String path, long pos, int flen)

    • dumpDebug

      protected void dumpDebug()

    • sendRequest

      public HTTPByteReader.SendResult sendRequest(byte[] request, boolean isHead)

    • sendRequest

      public HTTPByteReader.SendResult sendRequest(byte[] request, int len, boolean isHead)

    • sendRequest

      public HTTPByteReader.SendResult sendRequest(byte[] request, PacketFragmentList fragmentList, int len, boolean isHead)

    • getMaxUsesBeforeReconnect

      public int getMaxUsesBeforeReconnect()

    • setMaxUsesBeforeReconnect

      public void setMaxUsesBeforeReconnect(int maxUsesBeforeReconnect)

    • getMaxRetries

      public int getMaxRetries()

    • setMaxRetries

      public void setMaxRetries(int maxRetries)

    • getReadTimeout

      public int getReadTimeout()

    • setReadTimeout

      public void setReadTimeout(int readTimeout)

    • isRequestFullURL

      public boolean isRequestFullURL()

    • setRequestFullURL

      public void setRequestFullURL(boolean requestFullURL)

    • getConnectionTimeout

      public int getConnectionTimeout()

    • setConnectionTimeout

      public void setConnectionTimeout(int connectionTimeout)

    • getSendBufferSize

      public int getSendBufferSize()

    • setSendBufferSize

      public void setSendBufferSize(int sendBufferSize)

    • getReceiveBufferSize

      public int getReceiveBufferSize()

    • setReceiveBufferSize

      public void setReceiveBufferSize(int receiveBufferSize)

    • getUserAgent

      public String getUserAgent()

    • setUserAgent

      public void setUserAgent(String userAgent)