- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for connectionClosed (0.06 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt
assertThat(clientTestRule.recordedConnectionEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "NoNewExchanges", "ConnectionReleased", "ConnectionClosed", "ConnectStart", "ConnectEnd", "ConnectionAcquired", "ConnectionReleased", ) } @Test fun http2OneBadHostOneGoodNoRetryOnConnectionFailureFastFallback() {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 11.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
connection.noNewExchanges = true call.releaseConnectionNoEvents() } if (toClose != null) { toClose.closeQuietly() connectionListener.connectionClosed(connection) } else if (noNewExchangesEvent) { connectionListener.noNewExchanges(connection) } } return null } fun put(connection: RealConnection) {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 11.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
connection: Connection, route: Route, call: Call, ) { logEvent(ConnectionEvent.ConnectEnd(System.nanoTime(), connection, route, call)) } override fun connectionClosed(connection: Connection) = logEvent(ConnectionEvent.ConnectionClosed(System.nanoTime(), connection)) override fun connectionAcquired( connection: Connection, call: Call, ) {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 5.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt
*/ open fun connectEnd( connection: Connection, route: Route, call: Call, ) {} /** * Invoked when a connection is released as no longer required. */ open fun connectionClosed(connection: Connection) {} /** * Invoked when a call is assigned a particular connection. */ open fun connectionAcquired( connection: Connection, call: Call, ) {} /**
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 2.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
val route: Route, val call: Call, ) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route } data class ConnectionClosed( override val timestampNs: Long, override val connection: Connection, ) : ConnectionEvent() data class ConnectionAcquired( override val timestampNs: Long, override val connection: Connection,Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 2.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
} assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "NoNewExchanges", "ConnectionReleased", "ConnectionClosed", ) } @Throws(IOException::class) private fun assertSuccessfulEventOrder() { val call = client.newCall( Request .Builder()Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 18:33:48 UTC 2025 - 9.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
eventListener.connectionReleased(this, connection) connection.connectionListener.connectionReleased(connection, this) if (toClose != null) { connection.connectionListener.connectionClosed(connection) } } else { check(toClose == null) // If we still have a connection we shouldn't be closing any sockets. } } val result = timeoutExit(e)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 19.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
toClose?.closeQuietly() call.eventListener.connectionReleased(call, candidate) candidate.connectionListener.connectionReleased(candidate, call) if (toClose != null) { candidate.connectionListener.connectionClosed(candidate) } else if (noNewExchangesEvent) { candidate.connectionListener.noNewExchanges(candidate) } return null }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 12K bytes - Viewed (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
/** * Security event types */ public enum EventType {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 26.6K bytes - Viewed (0)