HTTPByteWriter (Wowza Streaming Engine 4 API)

Object
- com.wowza.io.HTTPByteWriter

public class HTTPByteWriter
extends Object

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

protected class HTTPByteWriter.SendResult

Nested Classes
Modifier and Type	Class and Description
`protected class`	`HTTPByteWriter.SendResult`

Field Summary

Fields
Modifier and Type	Field and Description
`protected int`	`addrIdx`
`static int`	`BUFFERINCSIZE`
`protected Class<? extends HTTPByteWriter>`	`CLASS`
`protected String`	`CLASSNAME`
`protected int`	`connectionTimeout`
`static 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`
`protected boolean`	`isSSL`
`static int`	`LOG_ALL`
`static int`	`LOG_DEBUG`
`static int`	`LOG_DEFAULT`
`static int`	`LOG_DNS`
`static int`	`LOG_FRAGMENTS`
`static int`	`LOG_QUIET`
`static int`	`LOG_REQHEADERS`
`static int`	`LOG_TIMEOUTS`
`protected int`	`logOptions`
`static int`	`MAXHEADERSIZE`
`protected int`	`maxRetries`
`static int`	`MAXRETRIES`
`protected int`	`maxUsesBeforeReconnect`
`protected StringBuffer`	`msgBuf`
`protected Boolean`	`nonblocked`
`protected String[]`	`parseDateFormats`
`protected int`	`port`
`protected String`	`proxyHost`
`protected int`	`proxyPort`
`protected int`	`readWriteTimeout`
`static int`	`READWRITETIMEOUT`
`protected int`	`receiveBufferSize`
`static int`	`RECEIVEBUFFERSIZE`
`protected String`	`reqPath`
`protected boolean`	`requestFullURL`
`protected long`	`retryTimeout`
`static long`	`RETRYWAITTIME`
`protected int`	`sendBufferSize`
`static int`	`SENDBUFFERSIZE`
`protected java.net.Socket`	`socket`
`protected java.nio.channels.SocketChannel`	`socketChannel`
`protected String`	`userAgent`
`protected int`	`uses`

Constructor Summary

Constructors
Constructor and Description

HTTPByteWriter(String host, int port, Boolean nonblocked)

Constructors
Constructor and Description
`HTTPByteWriter(String host, int port, Boolean nonblocked)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addLogOptions(int options)`
`void`	`close()`
`void`	`connect()`
`HTTPByteReaderResult`	`delete(String path)`
`HTTPByteReaderResult`	`deleteDirect(String path)`
`protected void`	`dumpDebug()`
`int`	`getConnectionTimeout()`
`protected String`	`getContextPath()`
`protected void`	`getDeleteCommand(String path)`
`boolean`	`getIsSSL()`
`int`	`getLogOptions()`
`int`	`getMaxRetries()`
`int`	`getMaxUsesBeforeReconnect()`
`protected void`	`getPostMessage(String method, String path, PacketFragmentList fragmentList)`
`int`	`getReadWriteTimeout()`
`int`	`getReceiveBufferSize()`
`protected String`	`getRequestPath(String path, String host, int port)`
`long`	`getRetryTimeout()`
`int`	`getSendBufferSize()`
`String`	`getUserAgent()`
`protected boolean`	`init()`
`protected void`	`initHandShake()`
`protected boolean`	`innerConnect()`
`boolean`	`isLogOption(int option)`
`boolean`	`isOpen()`
`boolean`	`isRequestFullURL()`
`protected void`	`parseHeader(HTTPByteWriter.SendResult result, byte[] buffer, int offset, int len, boolean isHead)`
`static int`	`parseLogOptions(String options)`
`protected void`	`reconnect()`
`void`	`removeLogOptions(int options)`
`HTTPByteWriter.SendResult`	`sendRequest(byte[] request, boolean isHead)`
`HTTPByteWriter.SendResult`	`sendRequest(byte[] request, PacketFragmentList fragmentList, int len, boolean isHead)`
`HTTPByteWriter.SendResult`	`sendRequestBlocked(byte[] request, PacketFragmentList fragmentList, int len, boolean isHead)`
`HTTPByteWriter.SendResult`	`sendRequestNonBlocked(byte[] request, PacketFragmentList fragmentList, int len, boolean isHead)`
`void`	`setConnectionTimeout(int connectionTimeout)`
`void`	`setIsSSL(boolean ssl)`
`void`	`setLogOptions(int options)`
`void`	`setMaxRetries(int maxRetries)`
`void`	`setMaxUsesBeforeReconnect(int maxUsesBeforeReconnect)`
`void`	`setProxyAddress(String host, int port)`
`void`	`setReadWriteTimeout(int readWriteTimeout)`
`void`	`setReceiveBufferSize(int receiveBufferSize)`
`void`	`setRequestFullURL(boolean requestFullURL)`
`void`	`setRetryTimeout(long timeout)`
`void`	`setSendBufferSize(int sendBufferSize)`
`void`	`setUserAgent(String userAgent)`
`protected int`	`socketRead(java.nio.ByteBuffer readBuffer)`
`protected int`	`socketWrite(java.nio.ByteBuffer reqBuffer)`
`HTTPByteReaderResult`	`write(String method, String path, byte[] buffer, int offset, int len)`
`HTTPByteReaderResult`	`write(String method, String path, PacketFragmentList fragmentList)`
`HTTPByteReaderResult`	`write(String method, String path, String str)`
`HTTPByteReaderResult`	`writeDirect(String method, String path, PacketFragmentList fragmentList)`

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

addrIdx
```
protected int addrIdx
```

BUFFERINCSIZE
```
public static final int BUFFERINCSIZE
```
See Also:
Constant Field Values

CLASS

protected Class<? extends HTTPByteWriter> CLASS

CLASSNAME
```
protected String CLASSNAME
```

connectionTimeout
```
protected int connectionTimeout
```

CONNECTIONTIMEOUT
```
public static final int CONNECTIONTIMEOUT
```
See Also:
Constant Field Values

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
```

isSSL
```
protected boolean isSSL
```

LOG_ALL
```
public static final int LOG_ALL
```
See Also:
Constant Field Values

LOG_DEBUG
```
public static final int LOG_DEBUG
```
See Also:
Constant Field Values

LOG_DEFAULT
```
public static final int LOG_DEFAULT
```
See Also:
Constant Field Values

LOG_DNS
```
public static final int LOG_DNS
```
See Also:
Constant Field Values

LOG_FRAGMENTS
```
public static final int LOG_FRAGMENTS
```
See Also:
Constant Field Values

LOG_QUIET
```
public static final int LOG_QUIET
```
See Also:
Constant Field Values

LOG_REQHEADERS
```
public static final int LOG_REQHEADERS
```
See Also:
Constant Field Values

LOG_TIMEOUTS
```
public static final int LOG_TIMEOUTS
```
See Also:
Constant Field Values

logOptions
```
protected int logOptions
```

MAXHEADERSIZE
```
public static final int MAXHEADERSIZE
```
See Also:
Constant Field Values

maxRetries
```
protected int maxRetries
```

MAXRETRIES
```
public static final int MAXRETRIES
```
See Also:
Constant Field Values

maxUsesBeforeReconnect
```
protected int maxUsesBeforeReconnect
```

msgBuf
```
protected StringBuffer msgBuf
```

nonblocked
```
protected Boolean nonblocked
```

parseDateFormats
```
protected String[] parseDateFormats
```

port
```
protected int port
```

proxyHost
```
protected String proxyHost
```

proxyPort
```
protected int proxyPort
```

readWriteTimeout
```
protected int readWriteTimeout
```

READWRITETIMEOUT
```
public static final int READWRITETIMEOUT
```
See Also:
Constant Field Values

receiveBufferSize
```
protected int receiveBufferSize
```

RECEIVEBUFFERSIZE
```
public static final int RECEIVEBUFFERSIZE
```
See Also:
Constant Field Values

reqPath
```
protected String reqPath
```

requestFullURL
```
protected boolean requestFullURL
```

retryTimeout
```
protected long retryTimeout
```

RETRYWAITTIME
```
public static final long RETRYWAITTIME
```
See Also:
Constant Field Values

sendBufferSize
```
protected int sendBufferSize
```

SENDBUFFERSIZE
```
public static final int SENDBUFFERSIZE
```
See Also:
Constant Field Values

socket
```
protected java.net.Socket socket
```

socketChannel

protected java.nio.channels.SocketChannel socketChannel

userAgent
```
protected String userAgent
```

uses
```
protected int uses
```

Constructor Detail

HTTPByteWriter

public HTTPByteWriter(String host,
              int port,
              Boolean nonblocked)

Method Detail

addLogOptions

public void addLogOptions(int options)

close
```
public void close()
```

connect
```
public void connect()
```

delete

public HTTPByteReaderResult delete(String path)

deleteDirect

public HTTPByteReaderResult deleteDirect(String path)

dumpDebug
```
protected void dumpDebug()
```

getConnectionTimeout
```
public int getConnectionTimeout()
```

getContextPath
```
protected String getContextPath()
```

getDeleteCommand

protected void getDeleteCommand(String path)

getIsSSL
```
public boolean getIsSSL()
```

getLogOptions
```
public int getLogOptions()
```

getMaxRetries
```
public int getMaxRetries()
```

getMaxUsesBeforeReconnect

public int getMaxUsesBeforeReconnect()

getPostMessage

protected void getPostMessage(String method,
                  String path,
                  PacketFragmentList fragmentList)

getReadWriteTimeout
```
public int getReadWriteTimeout()
```

getReceiveBufferSize
```
public int getReceiveBufferSize()
```

getRequestPath

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

getRetryTimeout
```
public long getRetryTimeout()
```

getSendBufferSize
```
public int getSendBufferSize()
```

getUserAgent
```
public String getUserAgent()
```

init
```
protected boolean init()
```

initHandShake

protected void initHandShake()
                      throws java.io.IOException

Throws:: java.io.IOException

innerConnect
```
protected boolean innerConnect()
```

isLogOption

public boolean isLogOption(int option)

isOpen
```
public boolean isOpen()
```

isRequestFullURL
```
public boolean isRequestFullURL()
```

parseHeader

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

parseLogOptions

public static int parseLogOptions(String options)

reconnect
```
protected void reconnect()
```

removeLogOptions

public void removeLogOptions(int options)

sendRequest

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

sendRequest

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

sendRequestBlocked

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

sendRequestNonBlocked

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

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)

setIsSSL
```
public void setIsSSL(boolean ssl)
```

setLogOptions

public void setLogOptions(int options)

setMaxRetries

public void setMaxRetries(int maxRetries)

setMaxUsesBeforeReconnect

public void setMaxUsesBeforeReconnect(int maxUsesBeforeReconnect)

setProxyAddress

public void setProxyAddress(String host,
                   int port)

setReadWriteTimeout

public void setReadWriteTimeout(int readWriteTimeout)

setReceiveBufferSize

public void setReceiveBufferSize(int receiveBufferSize)

setRequestFullURL

public void setRequestFullURL(boolean requestFullURL)

setRetryTimeout

public void setRetryTimeout(long timeout)

setSendBufferSize

public void setSendBufferSize(int sendBufferSize)

setUserAgent

public void setUserAgent(String userAgent)

socketRead

protected int socketRead(java.nio.ByteBuffer readBuffer)
                  throws java.io.IOException,
                         InterruptedException

Throws:: java.io.IOException; InterruptedException

socketWrite

protected int socketWrite(java.nio.ByteBuffer reqBuffer)
                   throws java.io.IOException

Throws:: java.io.IOException

write

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

write

public HTTPByteReaderResult write(String method,
                         String path,
                         PacketFragmentList fragmentList)

write

public HTTPByteReaderResult write(String method,
                         String path,
                         String str)

writeDirect

public HTTPByteReaderResult writeDirect(String method,
                               String path,
                               PacketFragmentList fragmentList)

Class HTTPByteWriter

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class Object

Field Detail

addrIdx

BUFFERINCSIZE

CLASS

CLASSNAME

connectionTimeout

CONNECTIONTIMEOUT

CRLF

dateFormat

debugInfo

debugPrefix

HEADINDEX_CONTENTLENGTH

HEADINDEX_LASTMODIFIED

HEADINDEX_SIZE

HEADINDEX_STATUS

host

isSSL

LOG_ALL

LOG_DEBUG

LOG_DEFAULT

LOG_DNS

LOG_FRAGMENTS

LOG_QUIET

LOG_REQHEADERS

LOG_TIMEOUTS

logOptions

MAXHEADERSIZE

maxRetries

MAXRETRIES

maxUsesBeforeReconnect

msgBuf

nonblocked

parseDateFormats

port

proxyHost

proxyPort

readWriteTimeout

READWRITETIMEOUT

receiveBufferSize

RECEIVEBUFFERSIZE

reqPath

requestFullURL

retryTimeout

RETRYWAITTIME

sendBufferSize

SENDBUFFERSIZE

socket

socketChannel

userAgent

uses

Constructor Detail

HTTPByteWriter

Method Detail

addLogOptions

close

connect

delete

deleteDirect

dumpDebug

getConnectionTimeout

getContextPath

getDeleteCommand

getIsSSL

getLogOptions

getMaxRetries

getMaxUsesBeforeReconnect

getPostMessage

getReadWriteTimeout

getReceiveBufferSize

getRequestPath

getRetryTimeout

getSendBufferSize

getUserAgent

init