okhttp3.internal.connection

Class RealConnection

java.lang.Object

okhttp3.internal.http2.Http2Connection.Listener

okhttp3.internal.connection.RealConnection

All Implemented Interfaces:

Connection

public final class RealConnection
extends Http2Connection.Listener
implements Connection

Field Summary

Fields

Modifier and Type	Field and Description
int	allocationLimit The maximum number of concurrent streams that can be carried by this connection.
List<Reference<StreamAllocation>>	allocations Current streams carried by this connection.
long	idleAtNanos Nanotime timestamp when allocations.size() reached zero.
boolean	noNewStreams If true, no new streams can be created on this connection.
int	successCount

Fields inherited from class okhttp3.internal.http2.Http2Connection.Listener

REFUSE_INCOMING_STREAMS

Constructor Summary

Constructors

Constructor and Description
RealConnection(ConnectionPool connectionPool, Route route)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	connect(int connectTimeout, int readTimeout, int writeTimeout, boolean connectionRetryEnabled)
Handshake	handshake() Returns the TLS handshake used to establish this connection, or null if the connection is not HTTPS.
boolean	isEligible(Address address, Route route) Returns true if this connection can carry a stream allocation to address.
boolean	isHealthy(boolean doExtensiveChecks) Returns true if this connection is ready to host new streams.
boolean	isMultiplexed() Returns true if this is an HTTP/2 connection.
HttpCodec	newCodec(OkHttpClient client, StreamAllocation streamAllocation)
RealWebSocket.Streams	newWebSocketStreams(StreamAllocation streamAllocation)
void	onSettings(Http2Connection connection) When settings are received, adjust the allocation limit.
void	onStream(Http2Stream stream) Refuse incoming streams.
Protocol	protocol() Returns the protocol negotiated by this connection, or Protocol.HTTP_1_1 if no protocol has been negotiated.
Route	route() Returns the route used by this connection.
Socket	socket() Returns the socket that this connection is using.
boolean	supportsUrl(HttpUrl url)
static RealConnection	testConnection(ConnectionPool connectionPool, Route route, Socket socket, long idleAtNanos)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

noNewStreams

public boolean noNewStreams

If true, no new streams can be created on this connection. Once true this is always true.

successCount

public int successCount

allocationLimit

public int allocationLimit

The maximum number of concurrent streams that can be carried by this connection. If allocations.size() < allocationLimit then new streams can be created on this connection.

allocations

public final List<Reference<StreamAllocation>> allocations

Current streams carried by this connection.

idleAtNanos

public long idleAtNanos

Nanotime timestamp when allocations.size() reached zero.

Constructor Detail

RealConnection

public RealConnection(ConnectionPool connectionPool,
                      Route route)

Method Detail

testConnection

public static RealConnection testConnection(ConnectionPool connectionPool,
                                            Route route,
                                            Socket socket,
                                            long idleAtNanos)

connect

public void connect(int connectTimeout,
                    int readTimeout,
                    int writeTimeout,
                    boolean connectionRetryEnabled)

isEligible

public boolean isEligible(Address address,
                          @Nullable
                          Route route)

Returns true if this connection can carry a stream allocation to address. If non-null route is the resolved route for a connection.

supportsUrl

public boolean supportsUrl(HttpUrl url)

newCodec

public HttpCodec newCodec(OkHttpClient client,
                          StreamAllocation streamAllocation)
                   throws SocketException

Throws:

SocketException

newWebSocketStreams

public RealWebSocket.Streams newWebSocketStreams(StreamAllocation streamAllocation)

route

public Route route()

Description copied from interface: Connection

Returns the route used by this connection.

Specified by:

route in interface Connection

cancel

public void cancel()

socket

public Socket socket()

Description copied from interface: Connection

Returns the socket that this connection is using. Returns an SSL socket if this connection is HTTPS. If this is an HTTP/2 connection the socket may be shared by multiple concurrent calls.

Specified by:

socket in interface Connection

isHealthy

public boolean isHealthy(boolean doExtensiveChecks)

Returns true if this connection is ready to host new streams.

onStream

public void onStream(Http2Stream stream)
              throws IOException

Refuse incoming streams.

Specified by:

onStream in class Http2Connection.Listener

Throws:

IOException

onSettings

public void onSettings(Http2Connection connection)

When settings are received, adjust the allocation limit.

Overrides:

onSettings in class Http2Connection.Listener

handshake

public Handshake handshake()

Description copied from interface: Connection

Returns the TLS handshake used to establish this connection, or null if the connection is not HTTPS.

Specified by:

handshake in interface Connection

isMultiplexed

public boolean isMultiplexed()

Returns true if this is an HTTP/2 connection. Such connections can be used in multiple HTTP requests simultaneously.

protocol

public Protocol protocol()

Description copied from interface: Connection

Returns the protocol negotiated by this connection, or Protocol.HTTP_1_1 if no protocol has been negotiated. This method returns Protocol.HTTP_1_1 even if the remote peer is using Protocol.HTTP_1_0.

Specified by:

protocol in interface Connection

toString

public String toString()

Overrides:

toString in class Object