anon.proxy
Class AnonProxyRequest

java.lang.Object
  anon.proxy.AnonProxyRequest

All Implemented Interfaces:

java.lang.Runnable

public final class AnonProxyRequest
extends java.lang.Object
implements java.lang.Runnable

Nested Class Summary

(package private) class

AnonProxyRequest.Response

Field Summary

private static int	CHUNK_SIZE
private java.lang.String[]	contentEncodings
private boolean	internalEncodingRequired
private boolean	m_bRequestIsAlive
private ProxyCallbackHandler	m_callbackHandler
private AnonChannel	m_Channel
private java.net.Socket	m_clientSocket
private java.io.InputStream	m_InChannel
private java.io.InputStream	m_InSocket
private int	m_iProtocol
private java.io.OutputStream	m_OutChannel
private java.io.OutputStream	m_OutSocket
private AnonProxy	m_Proxy
private java.lang.Object	m_syncObject
private java.lang.Thread	m_threadRequest
private java.lang.Thread	m_threadResponse
private static int	ms_currentRequest
private static int	ms_nrOfRequests
private static long	TIMEOUT_RECONNECT

Constructor Summary

AnonProxyRequest(AnonProxy proxy, java.net.Socket clientSocket, java.lang.Object a_syncObject, ProxyCallbackHandler callbackHandler)

Method Summary

private void	closeRequest()
java.lang.String[]	getContentEncodings()
static int	getNrOfRequests()
boolean	isInternalEncodingRequired()
void	run()
private static void	sendRemainingBytesRecursion(ProxyCallbackBuffer pcBuffer, int sentBytes, java.io.OutputStream outputStream)
void	setContentEncodings(java.lang.String[] contentEncodings)
void	setInternalEncodingRequired(boolean internalEncodingRequired)

Methods inherited from class java.lang.Object

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

Field Detail

ms_nrOfRequests

private static int ms_nrOfRequests

TIMEOUT_RECONNECT

private static final long TIMEOUT_RECONNECT

See Also:

Constant Field Values

CHUNK_SIZE

private static final int CHUNK_SIZE

See Also:

Constant Field Values

ms_currentRequest

private static int ms_currentRequest

m_InChannel

private java.io.InputStream m_InChannel

m_OutChannel

private java.io.OutputStream m_OutChannel

m_InSocket

private java.io.InputStream m_InSocket

m_OutSocket

private java.io.OutputStream m_OutSocket

m_clientSocket

private java.net.Socket m_clientSocket

m_threadResponse

private java.lang.Thread m_threadResponse

m_threadRequest

private java.lang.Thread m_threadRequest

m_Channel

private AnonChannel m_Channel

m_Proxy

private AnonProxy m_Proxy

m_bRequestIsAlive

private volatile boolean m_bRequestIsAlive

m_iProtocol

private int m_iProtocol

m_syncObject

private java.lang.Object m_syncObject

m_callbackHandler

private ProxyCallbackHandler m_callbackHandler

contentEncodings

private java.lang.String[] contentEncodings

internalEncodingRequired

private boolean internalEncodingRequired

Constructor Detail

AnonProxyRequest

AnonProxyRequest(AnonProxy proxy,
                 java.net.Socket clientSocket,
                 java.lang.Object a_syncObject,
                 ProxyCallbackHandler callbackHandler)
           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getNrOfRequests

public static int getNrOfRequests()

run

public void run()

Specified by:

run in interface java.lang.Runnable

sendRemainingBytesRecursion

private static void sendRemainingBytesRecursion(ProxyCallbackBuffer pcBuffer,
                                                int sentBytes,
                                                java.io.OutputStream outputStream)
                                         throws java.io.IOException

Throws:

java.io.IOException

closeRequest

private void closeRequest()

isInternalEncodingRequired

public boolean isInternalEncodingRequired()

setInternalEncodingRequired

public void setInternalEncodingRequired(boolean internalEncodingRequired)

getContentEncodings

public java.lang.String[] getContentEncodings()

setContentEncodings

public void setContentEncodings(java.lang.String[] contentEncodings)