Package org.apache.http.impl.nio.conn
Class CPoolProxy
- java.lang.Object
-
- org.apache.http.impl.nio.conn.CPoolProxy
-
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable,org.apache.http.HttpConnection,org.apache.http.HttpInetConnection,ManagedNHttpClientConnection,org.apache.http.nio.IOControl,org.apache.http.nio.NHttpClientConnection,org.apache.http.nio.NHttpConnection
class CPoolProxy extends java.lang.Object implements ManagedNHttpClientConnection
-
-
Field Summary
Fields Modifier and Type Field Description private CPoolEntrypoolEntry
-
Constructor Summary
Constructors Constructor Description CPoolProxy(CPoolEntry entry)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidbind(org.apache.http.nio.reactor.IOSession iosession)Binds connection to the given I/O session.voidclose()(package private) CPoolEntrydetach()static CPoolEntrydetach(org.apache.http.nio.NHttpClientConnection proxy)(package private) ManagedNHttpClientConnectiongetConnection()org.apache.http.protocol.HttpContextgetContext()org.apache.http.HttpRequestgetHttpRequest()org.apache.http.HttpResponsegetHttpResponse()java.lang.StringgetId()Returns connection ID which is expected to be unique for the life span of the connection manager.org.apache.http.nio.reactor.IOSessiongetIOSession()Returns the underlying I/O session.java.net.InetAddressgetLocalAddress()intgetLocalPort()org.apache.http.HttpConnectionMetricsgetMetrics()(package private) CPoolEntrygetPoolEntry()static CPoolEntrygetPoolEntry(org.apache.http.nio.NHttpClientConnection proxy)private static CPoolProxygetProxy(org.apache.http.nio.NHttpClientConnection conn)java.net.InetAddressgetRemoteAddress()intgetRemotePort()intgetSocketTimeout()javax.net.ssl.SSLSessiongetSSLSession()Obtains the SSL session of the underlying connection, if any.intgetStatus()(package private) ManagedNHttpClientConnectiongetValidConnection()booleanisOpen()booleanisRequestSubmitted()booleanisStale()static org.apache.http.nio.NHttpClientConnectionnewProxy(CPoolEntry poolEntry)voidrequestInput()voidrequestOutput()voidresetInput()voidresetOutput()voidsetSocketTimeout(int i)voidshutdown()voidsubmitRequest(org.apache.http.HttpRequest request)voidsuspendInput()voidsuspendOutput()java.lang.StringtoString()
-
-
-
Field Detail
-
poolEntry
private volatile CPoolEntry poolEntry
-
-
Constructor Detail
-
CPoolProxy
CPoolProxy(CPoolEntry entry)
-
-
Method Detail
-
getPoolEntry
CPoolEntry getPoolEntry()
-
detach
CPoolEntry detach()
-
getConnection
ManagedNHttpClientConnection getConnection()
-
getValidConnection
ManagedNHttpClientConnection getValidConnection()
-
close
public void close() throws java.io.IOException- Specified by:
closein interfacejava.lang.AutoCloseable- Specified by:
closein interfacejava.io.Closeable- Specified by:
closein interfaceorg.apache.http.HttpConnection- Throws:
java.io.IOException
-
shutdown
public void shutdown() throws java.io.IOException- Specified by:
shutdownin interfaceorg.apache.http.HttpConnection- Specified by:
shutdownin interfaceorg.apache.http.nio.IOControl- Throws:
java.io.IOException
-
getMetrics
public org.apache.http.HttpConnectionMetrics getMetrics()
- Specified by:
getMetricsin interfaceorg.apache.http.HttpConnection
-
requestInput
public void requestInput()
- Specified by:
requestInputin interfaceorg.apache.http.nio.IOControl
-
suspendInput
public void suspendInput()
- Specified by:
suspendInputin interfaceorg.apache.http.nio.IOControl
-
requestOutput
public void requestOutput()
- Specified by:
requestOutputin interfaceorg.apache.http.nio.IOControl
-
suspendOutput
public void suspendOutput()
- Specified by:
suspendOutputin interfaceorg.apache.http.nio.IOControl
-
getLocalAddress
public java.net.InetAddress getLocalAddress()
- Specified by:
getLocalAddressin interfaceorg.apache.http.HttpInetConnection
-
getLocalPort
public int getLocalPort()
- Specified by:
getLocalPortin interfaceorg.apache.http.HttpInetConnection
-
getRemoteAddress
public java.net.InetAddress getRemoteAddress()
- Specified by:
getRemoteAddressin interfaceorg.apache.http.HttpInetConnection
-
getRemotePort
public int getRemotePort()
- Specified by:
getRemotePortin interfaceorg.apache.http.HttpInetConnection
-
isOpen
public boolean isOpen()
- Specified by:
isOpenin interfaceorg.apache.http.HttpConnection
-
isStale
public boolean isStale()
- Specified by:
isStalein interfaceorg.apache.http.HttpConnection
-
setSocketTimeout
public void setSocketTimeout(int i)
- Specified by:
setSocketTimeoutin interfaceorg.apache.http.HttpConnection
-
getSocketTimeout
public int getSocketTimeout()
- Specified by:
getSocketTimeoutin interfaceorg.apache.http.HttpConnection
-
submitRequest
public void submitRequest(org.apache.http.HttpRequest request) throws java.io.IOException, org.apache.http.HttpException- Specified by:
submitRequestin interfaceorg.apache.http.nio.NHttpClientConnection- Throws:
java.io.IOExceptionorg.apache.http.HttpException
-
isRequestSubmitted
public boolean isRequestSubmitted()
- Specified by:
isRequestSubmittedin interfaceorg.apache.http.nio.NHttpClientConnection
-
resetOutput
public void resetOutput()
- Specified by:
resetOutputin interfaceorg.apache.http.nio.NHttpClientConnection
-
resetInput
public void resetInput()
- Specified by:
resetInputin interfaceorg.apache.http.nio.NHttpClientConnection
-
getStatus
public int getStatus()
- Specified by:
getStatusin interfaceorg.apache.http.nio.NHttpConnection
-
getHttpRequest
public org.apache.http.HttpRequest getHttpRequest()
- Specified by:
getHttpRequestin interfaceorg.apache.http.nio.NHttpConnection
-
getHttpResponse
public org.apache.http.HttpResponse getHttpResponse()
- Specified by:
getHttpResponsein interfaceorg.apache.http.nio.NHttpConnection
-
getContext
public org.apache.http.protocol.HttpContext getContext()
- Specified by:
getContextin interfaceorg.apache.http.nio.NHttpConnection
-
newProxy
public static org.apache.http.nio.NHttpClientConnection newProxy(CPoolEntry poolEntry)
-
getProxy
private static CPoolProxy getProxy(org.apache.http.nio.NHttpClientConnection conn)
-
getPoolEntry
public static CPoolEntry getPoolEntry(org.apache.http.nio.NHttpClientConnection proxy)
-
detach
public static CPoolEntry detach(org.apache.http.nio.NHttpClientConnection proxy)
-
getId
public java.lang.String getId()
Description copied from interface:ManagedNHttpClientConnectionReturns connection ID which is expected to be unique for the life span of the connection manager.- Specified by:
getIdin interfaceManagedNHttpClientConnection
-
bind
public void bind(org.apache.http.nio.reactor.IOSession iosession)
Description copied from interface:ManagedNHttpClientConnectionBinds connection to the given I/O session.- Specified by:
bindin interfaceManagedNHttpClientConnection
-
getIOSession
public org.apache.http.nio.reactor.IOSession getIOSession()
Description copied from interface:ManagedNHttpClientConnectionReturns the underlying I/O session.- Specified by:
getIOSessionin interfaceManagedNHttpClientConnection
-
getSSLSession
public javax.net.ssl.SSLSession getSSLSession()
Description copied from interface:ManagedNHttpClientConnectionObtains the SSL session of the underlying connection, if any.- Specified by:
getSSLSessionin interfaceManagedNHttpClientConnection- Returns:
- the underlying SSL session if available,
nullotherwise
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-