Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 737 for contention (0.37 sec)

  1. 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
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  2. docs/en/docs/deployment/https.md

    After this, the client and the server have an **encrypted TCP connection**, this is what TLS provides. And then they can use that connection to start the actual **HTTP communication**.
    
    And that's what **HTTPS** is, it's just plain **HTTP** inside a **secure TLS connection** instead of a pure (unencrypted) TCP connection.
    
    /// tip
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 19:34:08 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/util/transport/Transport.java

         */
        protected abstract void doDisconnect(boolean hard) throws IOException;
    
        /**
         * Establishes a connection to the remote endpoint.
         *
         * @param timeout the maximum time to wait for the connection in milliseconds
         * @throws TransportException if the connection fails or times out
         */
        public synchronized void connect(final long timeout) throws TransportException {
            try {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

       */
      @JvmField val minimumConcurrentCalls: Int = 0,
      /** How long to wait to retry pre-emptive connection attempts that fail. */
      @JvmField val backoffDelayMillis: Long = 60 * 1000,
      /** How much jitter to introduce in connection retry backoff delays */
      @JvmField val backoffJitterMillis: Int = 100,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      }
    
      /**
       * Return the route from [connection] if it should be retried, even if the connection itself is
       * unhealthy. The biggest gotcha here is that we shouldn't reuse routes from coalesced
       * connections.
       */
      private fun retryRoute(connection: RealConnection): Route? =
        connection.withLock {
          when {
            connection.routeFailureCount != 0 -> null
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okhttp3.internal.isHealthy
    import okhttp3.internal.tls.OkHostnameVerifier
    import okio.Buffer
    
    /**
     * A connection to a remote web server capable of carrying 1 or more concurrent streams.
     *
     * Connections are shared in a connection pool. Accesses to the connection's state must be guarded
     * by holding a lock on the connection.
     */
    class RealConnection internal constructor(
      val taskRunner: TaskRunner,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java

            CONNECTING,
            /** Connection is established but not ready for RDMA operations */
            CONNECTED,
            /** Connection is fully established and ready for RDMA operations */
            ESTABLISHED,
            /** Connection encountered an error */
            ERROR,
            /** Connection is being closed */
            CLOSING,
            /** Connection is closed */
            CLOSED
        }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/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,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java

            InetSocketAddress remote = new InetSocketAddress("localhost", 445);
            InetSocketAddress local = null;
    
            RdmaConnection connection = provider.createConnection(remote, local);
            assertNotNull(connection, "Connection should not be null");
            assertEquals(remote, connection.getRemoteAddress(), "Remote address should match");
        }
    
        @Test
        public void testRegisterMemory() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

    import java.io.IOException
    import java.util.concurrent.TimeUnit
    import okhttp3.Call
    import okhttp3.Connection
    import okhttp3.Interceptor
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.checkDuration
    import okhttp3.internal.connection.Exchange
    import okhttp3.internal.connection.RealCall
    
    /**
     * A concrete interceptor chain that carries the entire interceptor chain: all application
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top