- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 166 for Connection (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/Connection.kt
*/ interface Connection { /** Returns the route used by this connection. */ fun route(): Route /** * Returns the socket that this connection is using. Returns an * [SSL socket][javax.net.ssl.SSLSocket] if this connection is HTTPS. If this is an HTTP/2 * connection the socket may be shared by multiple concurrent calls. */ fun socket(): Socket
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
} } return null } fun put(connection: RealConnection) { connection.lock.assertHeld() connections.add(connection) // connection.queueEvent { connectionListener.connectEnd(connection) } scheduleCloser() } /** * Notify this pool that [connection] has become idle. Returns true if the connection has been * removed from the pool and should be closed.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/PoolConnectionUser.kt
return null } override fun connectionReleased(connection: Connection) { } override fun connectionConnectionAcquired(connection: RealConnection) { } override fun connectionConnectionReleased(connection: RealConnection) { } override fun connectionConnectionClosed(connection: RealConnection) { } override fun noNewExchanges(connection: RealConnection) { }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
override val connection: Connection, val call: Call, ) : ConnectionEvent() data class ConnectionReleased( override val timestampNs: Long, override val connection: Connection, val call: Call, ) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectionAcquired && connection == event.connection && call == event.call }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
} /** * Invoked after a connection has been acquired for the `call`. * * This can be invoked more than 1 time for a single [Call]. For example, if the response * to the [Call.request] is a redirect to a different address. */ open fun connectionAcquired( call: Call, connection: Connection, ) { } /** * Invoked after a connection has been released for the `call`. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
// flow-control window is fully depleted. if (!flushHeaders) { this.withLock { flushHeaders = (connection.writeBytesTotal >= connection.writeBytesMaximum) } } connection.writeHeaders(id, outFinished, responseHeaders) if (flushHeaders) { connection.flush() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val http2SocketHandler = Http2SocketHandler(socket, protocol) val connection = Http2Connection.Builder(false, taskRunner) .socket(socket) .listener(http2SocketHandler) .build() connection.start() openConnections.add(connection) openClientSockets.remove(socket) return } else if (protocol !== Protocol.HTTP_1_1) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
import okhttp3.internal.ws.RealWebSocket import okio.BufferedSink import okio.BufferedSource /** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection( val taskRunner: TaskRunner, val connectionPool: RealConnectionPool,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.FastFallbackExchangeFinder import okhttp3.internal.connection.ForceConnectRoutePlanner import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.connection.RealRoutePlanner import okhttp3.internal.connection.RouteDatabase /** * Manages reuse of HTTP and HTTP/2 connections for reduced network latency. HTTP requests that
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
lock.assertNotHeld() val connection = this.connection if (connection != null) { connection.lock.assertNotHeld() val toClose: Socket? = connection.withLock { // Sets this.connection to null. releaseConnectionNoEvents() } if (this.connection == null) { toClose?.closeQuietly()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2)