Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 659 for Connection (0.06 sec)

  1. internal/grid/connection.go

    func gridLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, "grid", err, id, errKind...)
    }
    
    // A Connection is a remote connection.
    // There is no distinction externally whether the connection was initiated from
    // this server or from the remote.
    type Connection struct {
    	// NextID is the next ID that can be used (atomic).
    	NextID uint64
    
    	// LastPong is last pong time (atomic)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. 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
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. docs/features/connections.md

    address may also share the same underlying TCP socket connection. Sharing a connection has substantial performance benefits: lower latency, higher throughput (due to [TCP slow start](https://www.igvita.com/2011/10/20/faster-web-vs-tcp-slow-start/)) and conserved battery. OkHttp uses a [ConnectionPool](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-pool/) that automatically reuses HTTP/1.x connections and multiplexes HTTP/2 connections.
    
    In OkHttp some fields of the address come...
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  4. 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.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  5. 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,
      ) {}
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/http/NtlmHttpURLConnection.java

                }
                connection.setRequestProperty(key, value.toString());
            }
            connection.setAllowUserInteraction(allowUserInteraction);
            connection.setDoInput(doInput);
            connection.setDoOutput(doOutput);
            connection.setIfModifiedSince(ifModifiedSince);
            connection.setUseCaches(useCaches);
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 20.4K bytes
    - Viewed (0)
  7. docs/contribute/concurrency.md

     * **ExchangeFinder** chooses which connection carries each exchange. Where possible it will use the same connection for all exchanges in a single call. It prefers reusing pooled connections over establishing new connections.      
    
    #### Per-Connection Locks
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/SmbTransportPool.java

    
        /**
         * Get transport connection
         * 
         * @param tc
         *            context to use
         * @param address
         * @param port
         * @param exclusive
         *            whether to acquire an unshared connection
         * @param forceSigning
         *            whether to enforce SMB signing on this connection
         * @return a transport connection to the target
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 09:02:44 UTC 2020
    - 6.3K bytes
    - Viewed (0)
  9. 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()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. 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.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.2K bytes
    - Viewed (0)
Back to top