- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for Connection (0.34 sec)
-
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/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) -
internal/http/listener.go
ClientReadTimeout time.Duration // When the net.Conn is idle for more than WriteTimeout duration, we close the connection on the client proactively. ClientWriteTimeout time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectionUser.kt
) fun connectionConnectEnd( connection: Connection, route: Route, ) fun connectFailed( route: Route, protocol: Protocol?, e: IOException, ) fun connectionAcquired(connection: Connection) fun acquireConnectionNoEvents(connection: RealConnection) fun releaseConnectionNoEvents(): Socket? fun connectionReleased(connection: Connection)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.2K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt
} } @Test fun testUrlConnectionDirect() { testRequest { val url = URI(mockServer.endpoint + "/person?name=peter").toURL() val connection = url.openConnection() as HttpURLConnection assertThat(connection.inputStream.source().buffer().readUtf8()).contains("Peter the person") } } @Test fun testUrlConnectionPlaintextProxied() { testRequest {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.CallConnectionUser import okhttp3.internal.connection.FastFallbackExchangeFinder import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.connection.RealRoutePlanner import okhttp3.internal.connection.RouteDatabase
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
override fun connectionConnectEnd( connection: Connection, route: Route, ) { poolConnectionListener.connectEnd(connection, route, call) } override fun connectionAcquired(connection: Connection) { eventListener.connectionAcquired(call, connection) } override fun acquireConnectionNoEvents(connection: RealConnection) { call.acquireConnectionNoEvents(connection) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 3.6K bytes - Viewed (0) -
internal/grid/manager.go
} } // AuthFn should provide an authentication string for the given aud. type AuthFn func(aud string) string // Connection will return the connection for the specified host. // If the host does not exist nil will be returned. func (m *Manager) Connection(host string) *Connection { return m.targets[host] } // RegisterSingleHandler will register a stateless handler that serves
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/project/inheritance/t12scm/ProjectInheritanceTest.java
System.out.println(); System.out.println("Parent SCM connection is: " + project0.getScm().getConnection()); System.out.println("Child SCM connection is: " + project1.getScm().getConnection()); System.out.println(); System.out.println( "Parent SCM developer connection is: " + project0.getScm().getDeveloperConnection()); System.out.println(
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/NativeImageTestsAccessors.kt
* limitations under the License. */ package okhttp3.internal import okhttp3.Cache import okhttp3.Dispatcher import okhttp3.Response import okhttp3.internal.connection.Exchange import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealConnection import okio.FileSystem import okio.Path internal fun buildCache( file: Path, maxSize: Long, fileSystem: FileSystem, ): Cache {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 1.3K bytes - Viewed (0)