Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 542 for contention (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

        // 3 different lookups in the connection pool!
        val pooled3 = routePlanner.planReusePooledConnection(this, routes)
        if (pooled3 != null) return pooled3.connection
    
        connection.withLock {
          connectionPool.put(connection)
          user.acquireConnectionNoEvents(connection)
        }
    
        user.connectionAcquired(connection)
        user.connectionConnectionAcquired(connection)
        return connection
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

        // flow-control window is fully depleted.
        if (!flushHeaders) {
          withLock {
            flushHeaders = (connection.writeBytesTotal >= connection.writeBytesMaximum)
          }
        }
    
        connection.writeHeaders(id, outFinished, responseHeaders)
    
        if (flushHeaders) {
          connection.flush()
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            if (ex != null) {
                throw ex;
            }
            throw new TransportException("All connection attempts failed");
        }
    
        /**
         * Checks if the specified transport is contained in the connection pool
         * @param trans the transport to check for
         * @return whether (non-exclusive) connection is in the pool
         */
        public boolean contains(final SmbTransport trans) {
            cleanup();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/SmbTransportPool.java

        /**
         * Get transport connection
         *
         * @param tc
         *            context to use
         * @param address the server address
         * @param port the port number
         * @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 Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/http/NtlmHttpURLConnection.java

        /**
         * Creates a new NTLM HTTP URL connection that wraps an existing HTTP connection.
         *
         * @param connection
         *            connection to wrap
         * @param tc
         *            context to use
         */
        public NtlmHttpURLConnection(final HttpURLConnection connection, final CIFSContext tc) {
            super(connection.getURL());
            this.connection = connection;
            this.transportContext = tc;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  6. apache-maven/src/assembly/maven/conf/settings.xml

         | or the command line, profiles have to have an ID that is unique.
         |
         | An encouraged best practice for profile identification is to use a consistent naming convention
         | for profiles, such as 'env-dev', 'env-test', 'env-production', 'user-jdcasey', 'user-brett', etc.
         | This will make it more intuitive to understand what the set of introduced profiles is attempting
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jan 22 07:44:50 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbTransportPoolImplTest.java

            // Create an existing connection
            SmbTransportImpl first = testPool.getSmbTransport(ctx, address, 445, false);
    
            // When: Request another connection
            // Note: Real SmbTransportImpl will report as disconnected without actual socket
            SmbTransportImpl second = testPool.getSmbTransport(ctx, address, 445, false);
    
            // Then: Will create new connection since real transport has no socket
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 19.2K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

      }
    
      /**
       * Invoked after a connection has been acquired for the `call`.
       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response
       * to the [Call.request] is a redirect to a different address.
       */
      open fun connectionAcquired(
        call: Call,
        connection: Connection,
      ) {
      }
    
      /**
       * Invoked after a connection has been released for the `call`.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

              }
            } else {
              exchange.noRequestBody()
              if (!exchange.connection.isMultiplexed) {
                // If the "Expect: 100-continue" expectation wasn't met, prevent the HTTP/1 connection
                // from being reused. Otherwise we're still obligated to transmit the request body to
                // leave the connection in a consistent state.
                exchange.noNewExchangesOnConnection()
              }
            }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Play it back.
        val connection = connect(peer)
        connection.newStream(headerEntries("a", "android"), false)
        connection.withLock {
          if (!connection.isHealthy(System.nanoTime())) {
            throw ConnectionShutdownException()
          }
        }
        connection.writePing()
        connection.shutdown(ErrorCode.PROTOCOL_ERROR)
        assertThat(connection.openStreamCount()).isEqualTo(1)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
Back to top