weblogic.net.http

Class AsyncResponseHandler.MuxableSocketHTTPAsyncResponse

java.lang.Object

weblogic.socket.BaseAbstractMuxableSocket

weblogic.socket.AbstractMuxableSocket

weblogic.net.http.AsyncResponseHandler.MuxableSocketHTTPAsyncResponse

All Implemented Interfaces:

java.io.Serializable, SocketRuntime, MessageReceiverStatistics, ContextHandler, weblogic.socket.MuxableSocket

Enclosing class:

AsyncResponseHandler

static class AsyncResponseHandler.MuxableSocketHTTPAsyncResponse
extends weblogic.socket.AbstractMuxableSocket

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	AsyncResponseHandler.MuxableSocketHTTPAsyncResponse.EOFInputStream
private static class	AsyncResponseHandler.MuxableSocketHTTPAsyncResponse.RunnableCallback

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncResponseCallback	callback
private HttpURLConnection	connection
private static boolean	DEBUG
private java.lang.Throwable	exception
private boolean	responseAvailable
private java.lang.Runnable	runnable
private java.io.InputStream	socketInputStream
private weblogic.work.WorkManager	workManager

Fields inherited from class weblogic.socket.BaseAbstractMuxableSocket

availBytes, channel, closeLatch, filter, head, info, maxMessageSize, msgLength, sis, socket, socketFactory, sos, soTimeout, tail

Constructor Summary

Constructors

Constructor and Description
MuxableSocketHTTPAsyncResponse(HttpURLConnection connection, AsyncResponseCallback callback, weblogic.work.WorkManager workManager)

Method Summary

Modifier and Type	Method and Description
boolean	closeSocketOnError()
private void	debug(java.lang.String s)
void	dispatch()
void	endOfStream()
int	getIdleTimeoutMillis()
private java.lang.Runnable	getRunnable()
private void	handleError(java.lang.Throwable t)
private void	handleTimeout()
void	hasException(java.lang.Throwable t)
private void	init(HttpURLConnection connection, AsyncResponseCallback callback, weblogic.work.WorkManager workManager)
private void	invokeCallback()
private void	invokeCallbackWithErrorStream(java.io.InputStream errorStream)
boolean	isMessageComplete()
(package private) void	reRegister(HttpURLConnection connection, AsyncResponseCallback callback, weblogic.work.WorkManager workManager)
private void	reset()
boolean	timeout()

Methods inherited from class weblogic.socket.AbstractMuxableSocket

addSenderStatistics, cleanup, p, prepareForReuse, registerForRuntimeMonitoring

Methods inherited from class weblogic.socket.BaseAbstractMuxableSocket

close, connect, connect, connect, createSocket, createSocket, dispatch, getAvailableBytes, getBuffer, getBufferOffset, getByteBuffer, getBytesReceivedCount, getChannel, getChunk, getCloseDebugReasonString, getCompleteMessageTimeoutMillis, getConnectTime, getFileDescriptor, getHeaderByte, getHeaderLength, getLocalAddress, getLocalPort, getMessageLength, getMessagesReceivedCount, getNames, getProtocol, getRemoteAddress, getRemotePort, getSocket, getSocketFilter, getSocketInfo, getSocketInputStream, getSocketOutputStream, getSoTimeout, getValue, getValues, incrementBufferOffset, incrementBufferOffset, isClosed, makeChunkList, read, requestTimeout, resetData, setSocketFactory, setSocketFilter, setSocketInfo, setSoTimeout, size, supportsScatteredRead, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface weblogic.protocol.MessageReceiverStatistics

getBytesReceivedCount, getConnectTime, getMessagesReceivedCount

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

callback

private AsyncResponseCallback callback

connection

private HttpURLConnection connection

socketInputStream

private java.io.InputStream socketInputStream

workManager

private weblogic.work.WorkManager workManager

runnable

private java.lang.Runnable runnable

exception

private java.lang.Throwable exception

responseAvailable

private boolean responseAvailable

Constructor Detail

MuxableSocketHTTPAsyncResponse

MuxableSocketHTTPAsyncResponse(HttpURLConnection connection,
                               AsyncResponseCallback callback,
                               weblogic.work.WorkManager workManager)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getIdleTimeoutMillis

public int getIdleTimeoutMillis()

Specified by:

getIdleTimeoutMillis in interface weblogic.socket.MuxableSocket

Overrides:

getIdleTimeoutMillis in class weblogic.socket.BaseAbstractMuxableSocket

isMessageComplete

public boolean isMessageComplete()

Specified by:

isMessageComplete in interface weblogic.socket.MuxableSocket

Overrides:

isMessageComplete in class weblogic.socket.BaseAbstractMuxableSocket

dispatch

public void dispatch()

Specified by:

dispatch in interface weblogic.socket.MuxableSocket

Overrides:

dispatch in class weblogic.socket.BaseAbstractMuxableSocket

invokeCallback

private void invokeCallback()

handleError

private void handleError(java.lang.Throwable t)

handleTimeout

private void handleTimeout()

invokeCallbackWithErrorStream

private void invokeCallbackWithErrorStream(java.io.InputStream errorStream)

init

private void init(HttpURLConnection connection,
                  AsyncResponseCallback callback,
                  weblogic.work.WorkManager workManager)
           throws java.io.IOException

Throws:

java.io.IOException

closeSocketOnError

public boolean closeSocketOnError()

Specified by:

closeSocketOnError in interface weblogic.socket.MuxableSocket

Overrides:

closeSocketOnError in class weblogic.socket.BaseAbstractMuxableSocket

reset

private void reset()

reRegister

void reRegister(HttpURLConnection connection,
                AsyncResponseCallback callback,
                weblogic.work.WorkManager workManager)
         throws java.io.IOException

Throws:

java.io.IOException

hasException

public void hasException(java.lang.Throwable t)

Specified by:

hasException in interface weblogic.socket.MuxableSocket

Overrides:

hasException in class weblogic.socket.BaseAbstractMuxableSocket

endOfStream

public void endOfStream()

Specified by:

endOfStream in interface weblogic.socket.MuxableSocket

Overrides:

endOfStream in class weblogic.socket.BaseAbstractMuxableSocket

timeout

public boolean timeout()

Specified by:

timeout in interface weblogic.socket.MuxableSocket

Overrides:

timeout in class weblogic.socket.BaseAbstractMuxableSocket

getRunnable

private java.lang.Runnable getRunnable()

debug

private void debug(java.lang.String s)