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 CPoolEntry
poolEntry
-
Constructor Summary
Constructors Constructor Description CPoolProxy(CPoolEntry entry)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
bind(org.apache.http.nio.reactor.IOSession iosession)
Binds connection to the given I/O session.void
close()
(package private) CPoolEntry
detach()
static CPoolEntry
detach(org.apache.http.nio.NHttpClientConnection proxy)
(package private) ManagedNHttpClientConnection
getConnection()
org.apache.http.protocol.HttpContext
getContext()
org.apache.http.HttpRequest
getHttpRequest()
org.apache.http.HttpResponse
getHttpResponse()
java.lang.String
getId()
Returns connection ID which is expected to be unique for the life span of the connection manager.org.apache.http.nio.reactor.IOSession
getIOSession()
Returns the underlying I/O session.java.net.InetAddress
getLocalAddress()
int
getLocalPort()
org.apache.http.HttpConnectionMetrics
getMetrics()
(package private) CPoolEntry
getPoolEntry()
static CPoolEntry
getPoolEntry(org.apache.http.nio.NHttpClientConnection proxy)
private static CPoolProxy
getProxy(org.apache.http.nio.NHttpClientConnection conn)
java.net.InetAddress
getRemoteAddress()
int
getRemotePort()
int
getSocketTimeout()
javax.net.ssl.SSLSession
getSSLSession()
Obtains the SSL session of the underlying connection, if any.int
getStatus()
(package private) ManagedNHttpClientConnection
getValidConnection()
boolean
isOpen()
boolean
isRequestSubmitted()
boolean
isStale()
static org.apache.http.nio.NHttpClientConnection
newProxy(CPoolEntry poolEntry)
void
requestInput()
void
requestOutput()
void
resetInput()
void
resetOutput()
void
setSocketTimeout(int i)
void
shutdown()
void
submitRequest(org.apache.http.HttpRequest request)
void
suspendInput()
void
suspendOutput()
java.lang.String
toString()
-
-
-
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:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceorg.apache.http.HttpConnection
- Throws:
java.io.IOException
-
shutdown
public void shutdown() throws java.io.IOException
- Specified by:
shutdown
in interfaceorg.apache.http.HttpConnection
- Specified by:
shutdown
in interfaceorg.apache.http.nio.IOControl
- Throws:
java.io.IOException
-
getMetrics
public org.apache.http.HttpConnectionMetrics getMetrics()
- Specified by:
getMetrics
in interfaceorg.apache.http.HttpConnection
-
requestInput
public void requestInput()
- Specified by:
requestInput
in interfaceorg.apache.http.nio.IOControl
-
suspendInput
public void suspendInput()
- Specified by:
suspendInput
in interfaceorg.apache.http.nio.IOControl
-
requestOutput
public void requestOutput()
- Specified by:
requestOutput
in interfaceorg.apache.http.nio.IOControl
-
suspendOutput
public void suspendOutput()
- Specified by:
suspendOutput
in interfaceorg.apache.http.nio.IOControl
-
getLocalAddress
public java.net.InetAddress getLocalAddress()
- Specified by:
getLocalAddress
in interfaceorg.apache.http.HttpInetConnection
-
getLocalPort
public int getLocalPort()
- Specified by:
getLocalPort
in interfaceorg.apache.http.HttpInetConnection
-
getRemoteAddress
public java.net.InetAddress getRemoteAddress()
- Specified by:
getRemoteAddress
in interfaceorg.apache.http.HttpInetConnection
-
getRemotePort
public int getRemotePort()
- Specified by:
getRemotePort
in interfaceorg.apache.http.HttpInetConnection
-
isOpen
public boolean isOpen()
- Specified by:
isOpen
in interfaceorg.apache.http.HttpConnection
-
isStale
public boolean isStale()
- Specified by:
isStale
in interfaceorg.apache.http.HttpConnection
-
setSocketTimeout
public void setSocketTimeout(int i)
- Specified by:
setSocketTimeout
in interfaceorg.apache.http.HttpConnection
-
getSocketTimeout
public int getSocketTimeout()
- Specified by:
getSocketTimeout
in interfaceorg.apache.http.HttpConnection
-
submitRequest
public void submitRequest(org.apache.http.HttpRequest request) throws java.io.IOException, org.apache.http.HttpException
- Specified by:
submitRequest
in interfaceorg.apache.http.nio.NHttpClientConnection
- Throws:
java.io.IOException
org.apache.http.HttpException
-
isRequestSubmitted
public boolean isRequestSubmitted()
- Specified by:
isRequestSubmitted
in interfaceorg.apache.http.nio.NHttpClientConnection
-
resetOutput
public void resetOutput()
- Specified by:
resetOutput
in interfaceorg.apache.http.nio.NHttpClientConnection
-
resetInput
public void resetInput()
- Specified by:
resetInput
in interfaceorg.apache.http.nio.NHttpClientConnection
-
getStatus
public int getStatus()
- Specified by:
getStatus
in interfaceorg.apache.http.nio.NHttpConnection
-
getHttpRequest
public org.apache.http.HttpRequest getHttpRequest()
- Specified by:
getHttpRequest
in interfaceorg.apache.http.nio.NHttpConnection
-
getHttpResponse
public org.apache.http.HttpResponse getHttpResponse()
- Specified by:
getHttpResponse
in interfaceorg.apache.http.nio.NHttpConnection
-
getContext
public org.apache.http.protocol.HttpContext getContext()
- Specified by:
getContext
in 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:ManagedNHttpClientConnection
Returns connection ID which is expected to be unique for the life span of the connection manager.- Specified by:
getId
in interfaceManagedNHttpClientConnection
-
bind
public void bind(org.apache.http.nio.reactor.IOSession iosession)
Description copied from interface:ManagedNHttpClientConnection
Binds connection to the given I/O session.- Specified by:
bind
in interfaceManagedNHttpClientConnection
-
getIOSession
public org.apache.http.nio.reactor.IOSession getIOSession()
Description copied from interface:ManagedNHttpClientConnection
Returns the underlying I/O session.- Specified by:
getIOSession
in interfaceManagedNHttpClientConnection
-
getSSLSession
public javax.net.ssl.SSLSession getSSLSession()
Description copied from interface:ManagedNHttpClientConnection
Obtains the SSL session of the underlying connection, if any.- Specified by:
getSSLSession
in interfaceManagedNHttpClientConnection
- Returns:
- the underlying SSL session if available,
null
otherwise
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-