Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for Connection (0.34 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top