Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 847 for contention (0.2 seconds)

  1. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/BwcVersions.java

     * version number to server in all branches when a version is released.
     * E.x when M.N.c is released M.N.c+1 is added to the Version class mentioned above in all the following branches:
     *  `M.N`, `M.x` and `master` so we can reliably assume that the leafs of the version tree are unreleased.
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 16.8K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb1/http/NtlmHttpURLConnection.java

        }
    
        /**
         * Creates a new NTLM HTTP URL connection that wraps an existing HTTP connection.
         *
         * @param connection the HTTP connection to wrap for NTLM authentication
         */
        public NtlmHttpURLConnection(final HttpURLConnection connection) {
            super(connection.getURL());
            this.connection = connection;
            requestProperties = new HashMap();
        }
    
        @Override
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  3. 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)
          call.acquireConnectionNoEvents(connection)
        }
    
        call.eventListener.connectionAcquired(call, connection)
        connection.connectionListener.connectionAcquired(connection, call)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

          }
        }
        return null
      }
    
      fun put(connection: RealConnection) {
        connection.assertLockHeld()
    
        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.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 11.1K bytes
    - Click Count (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;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 25.6K bytes
    - Click Count (0)
  6. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleBuildDocumentationPlugin.java

                task.into(extension.getDocumentationRenderedRoot());
            });
    
            extension.getSourceRoot().convention(layout.getProjectDirectory().dir("src/docs"));
            extension.getDocumentationRenderedRoot().convention(layout.getBuildDirectory().dir("docs"));
            extension.getStagingRoot().convention(layout.getBuildDirectory().dir("working"));
    
            ConfigurableFileTree css = objects.fileTree();
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Mar 19 17:06:32 GMT 2026
    - 7.6K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        assertLockNotHeld()
    
        val connection = this.connection
        if (connection != null) {
          connection.assertLockNotHeld()
          val toClose: Socket? =
            connection.withLock {
              // Sets this.connection to null.
              releaseConnectionNoEvents()
            }
          if (this.connection == null) {
            toClose?.closeQuietly()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/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,
      ) {}
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri May 30 21:28:20 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  9. 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
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 22 07:44:50 GMT 2025
    - 11.1K bytes
    - Click Count (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)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
Back to Top