com.wowza.io

Class HTTPByteReader

Object

com.wowza.io.HTTPByteReader

Direct Known Subclasses:

HTTPByteReaderS3

public class HTTPByteReader
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	HTTPByteReader.SendResult

Field Summary

Fields

Modifier and Type	Field and Description
static int	BUFFERINCSIZE
protected int	connectionTimeout
static String	CRLF
protected org.apache.commons.lang.time.FastDateFormat	dateFormat
protected java.util.List<String>	debugInfo
protected String	debugPrefix
static int	HEADINDEX_CONTENTLENGTH
static int	HEADINDEX_LASTMODIFIED
static int	HEADINDEX_SIZE
static int	HEADINDEX_STATUS
protected String	host
static int	MAXHEADERSIZE
protected int	maxRetries
protected int	maxUsesBeforeReconnect
protected StringBuffer	msgBuf
protected String[]	parseDateFormats
protected int	port
protected String	proxyHost
protected int	proxyPort
protected int	readTimeout
protected int	receiveBufferSize
static int	RECEIVEBUFFERSIZE
protected String	reqPath
protected boolean	requestFullURL
protected int	sendBufferSize
static int	SENDBUFFERSIZE
protected java.net.Socket	socket
static int	TIMEOUT
protected String	userAgent
protected int	uses

Constructor Summary

Constructors

Constructor and Description
HTTPByteReader(String host, int port)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	connect()
HTTPByteReaderResult	delete(String path)
HTTPByteReaderResult	deleteDirect(String path)
protected void	dumpDebug()
protected String	getConextPath()
int	getConnectionTimeout()
protected void	getDeleteCommand(String path)
protected void	getGetCommand(String path, long pos, int flen)
protected void	getHeadCommand(String path)
int	getMaxRetries()
int	getMaxUsesBeforeReconnect()
protected void	getPostCommand(String path, PacketFragmentList fragmentList)
int	getReadTimeout()
int	getReceiveBufferSize()
protected String	getRequestPath(String path, String host, int port)
int	getSendBufferSize()
String	getUserAgent()
long[]	head(String path)
boolean	isOpen()
boolean	isRequestFullURL()
protected void	parseHeader(HTTPByteReader.SendResult result, byte[] buffer, int offset, int len, boolean isHead)
HTTPByteReaderResult	read(String path, long pos, int flen)
HTTPByteReaderResult	readDirect(String path, long pos, int flen)
protected void	reconnect()
HTTPByteReader.SendResult	sendRequest(byte[] request, boolean isHead)
HTTPByteReader.SendResult	sendRequest(byte[] request, int len, boolean isHead)
HTTPByteReader.SendResult	sendRequest(byte[] request, PacketFragmentList fragmentList, int len, boolean isHead)
void	setConnectionTimeout(int connectionTimeout)
void	setMaxRetries(int maxRetries)
void	setMaxUsesBeforeReconnect(int maxUsesBeforeReconnect)
void	setProxyAddress(String host, int port)
void	setReadTimeout(int readTimeout)
void	setReceiveBufferSize(int receiveBufferSize)
void	setRequestFullURL(boolean requestFullURL)
void	setSendBufferSize(int sendBufferSize)
void	setUserAgent(String userAgent)
HTTPByteReaderResult	write(String path, byte[] buffer, int offset, int len)
HTTPByteReaderResult	write(String path, PacketFragmentList fragmentList)
HTTPByteReaderResult	write(String path, String str)
HTTPByteReaderResult	writeDirect(String path, PacketFragmentList fragmentList)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BUFFERINCSIZE

public static final int BUFFERINCSIZE

See Also:

Constant Field Values

connectionTimeout

protected int connectionTimeout

CRLF

public static final String CRLF

See Also:

Constant Field Values

dateFormat

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

debugInfo

protected java.util.List<String> debugInfo

debugPrefix

protected String debugPrefix

HEADINDEX_CONTENTLENGTH

public static final int HEADINDEX_CONTENTLENGTH

See Also:

Constant Field Values

HEADINDEX_LASTMODIFIED

public static final int HEADINDEX_LASTMODIFIED

See Also:

Constant Field Values

HEADINDEX_SIZE

public static final int HEADINDEX_SIZE

See Also:

Constant Field Values

HEADINDEX_STATUS

public static final int HEADINDEX_STATUS

See Also:

Constant Field Values

host

protected String host

MAXHEADERSIZE

public static final int MAXHEADERSIZE

See Also:

Constant Field Values

maxRetries

protected int maxRetries

maxUsesBeforeReconnect

protected int maxUsesBeforeReconnect

msgBuf

protected StringBuffer msgBuf

parseDateFormats

protected String[] parseDateFormats

port

protected int port

proxyHost

protected String proxyHost

proxyPort

protected int proxyPort

readTimeout

protected int readTimeout

receiveBufferSize

protected int receiveBufferSize

RECEIVEBUFFERSIZE

public static final int RECEIVEBUFFERSIZE

See Also:

Constant Field Values

reqPath

protected String reqPath

requestFullURL

protected boolean requestFullURL

sendBufferSize

protected int sendBufferSize

SENDBUFFERSIZE

public static final int SENDBUFFERSIZE

See Also:

Constant Field Values

socket

protected java.net.Socket socket

TIMEOUT

public static final int TIMEOUT

See Also:

Constant Field Values

userAgent

protected String userAgent

uses

protected int uses

Constructor Detail

HTTPByteReader

public HTTPByteReader(String host,
              int port)

Method Detail

close

public void close()

connect

public void connect()

delete

public HTTPByteReaderResult delete(String path)

deleteDirect

public HTTPByteReaderResult deleteDirect(String path)

dumpDebug

protected void dumpDebug()

getConextPath

protected String getConextPath()

getConnectionTimeout

public int getConnectionTimeout()

getDeleteCommand

protected void getDeleteCommand(String path)

getGetCommand

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

getHeadCommand

protected void getHeadCommand(String path)

getMaxRetries

public int getMaxRetries()

getMaxUsesBeforeReconnect

public int getMaxUsesBeforeReconnect()

getPostCommand

protected void getPostCommand(String path,
                  PacketFragmentList fragmentList)

getReadTimeout

public int getReadTimeout()

getReceiveBufferSize

public int getReceiveBufferSize()

getRequestPath

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

getSendBufferSize

public int getSendBufferSize()

getUserAgent

public String getUserAgent()

head

public long[] head(String path)

isOpen

public boolean isOpen()

isRequestFullURL

public boolean isRequestFullURL()

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)

readDirect

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

reconnect

protected void reconnect()

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)

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)

setMaxRetries

public void setMaxRetries(int maxRetries)

setMaxUsesBeforeReconnect

public void setMaxUsesBeforeReconnect(int maxUsesBeforeReconnect)

setProxyAddress

public void setProxyAddress(String host,
                   int port)

setReadTimeout

public void setReadTimeout(int readTimeout)

setReceiveBufferSize

public void setReceiveBufferSize(int receiveBufferSize)

setRequestFullURL

public void setRequestFullURL(boolean requestFullURL)

setSendBufferSize

public void setSendBufferSize(int sendBufferSize)

setUserAgent

public void setUserAgent(String userAgent)

write

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

write

public HTTPByteReaderResult write(String path,
                         PacketFragmentList fragmentList)

write

public HTTPByteReaderResult write(String path,
                         String str)

writeDirect

public HTTPByteReaderResult writeDirect(String path,
                               PacketFragmentList fragmentList)