Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 174 for Connection (0.23 sec)

  1. 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)
  2. internal/grid/connection_test.go

    	// Killing should cancel the context on the request.
    	<-gotCall
    }
    
    func dummyRequestValidate(r *http.Request) error {
    	return nil
    }
    
    func TestShouldConnect(t *testing.T) {
    	var c Connection
    	var cReverse Connection
    	hosts := []string{"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", "x", "y", "z", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9"}
    	for x := range hosts {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 6K bytes
    - Viewed (0)
  3. 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)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *
     *  4. If there's no existing connection, make a list of routes (which may require blocking DNS
     *     lookups) and attempt a new connection them. When failures occur, retries iterate the list of
     *     available routes.
     *
     * If the pool gains an eligible connection while DNS, TCP, or TLS work is in flight, this finder
     * will prefer pooled connections. Only pooled HTTP/2 connections are used for such de-duplication.
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 4.2K bytes
    - Viewed (0)
  5. internal/grid/README.md

    A **Manager** is used to manage all incoming and outgoing connections to a server.
    
    On startup all remote servers must be specified. 
    From that individual connections will be spawned to each remote server, 
    or incoming requests will be hooked up to the appropriate connection.
    
    To get a connection to a specific server, use `Manager.Connection(host)` to get a connection to the specified host.
    From this connection individual requests can be made.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  6. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

      /**
       * Half close connection (InputStream for client) after reading the request but before
       * writing the response. Use this to simulate late connection pool failures.
       */
      object HalfCloseAfterRequest : SocketPolicy
    
      /** Close connection after reading half of the request body (if present). */
      object DisconnectDuringRequestBody : SocketPolicy
    
      /** Close connection after writing half of the response body (if present). */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt

        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,
      ) {}
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 2.2K bytes
    - Viewed (0)
Back to top