Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 556 for loom (0.02 seconds)

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

       * simultaneously adopted and removed.
       */
      private val connections = ConcurrentLinkedQueue<RealConnection>()
    
      init {
        // Put a floor on the keep alive duration, otherwise cleanup will spin loop.
        require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" }
      }
    
      fun idleConnectionCount(): Int =
        connections.count {
          it.withLock { it.calls.isEmpty() }
        }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/ForwardingMap.java

       * #remove} to forward to this implementation.
       *
       * <p>Alternately, you may wish to override {@link #remove} with {@code keySet().remove}, assuming
       * that approach would not lead to an infinite loop.
       *
       * @since 7.0
       */
      protected @Nullable V standardRemove(@Nullable Object key) {
        Iterator<Entry<K, V>> entryIterator = entrySet().iterator();
        while (entryIterator.hasNext()) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Aug 06 17:32:30 GMT 2025
    - 9.8K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                             * with node status so we need to check to make sure that
                             * the record type matches the question type and if not,
                             * loop around and try again.
                             */
                            if (response.received && request.questionType == response.recordType) {
                                return;
                            }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/SIDTest.java

            void testResolveWeakCIFSExceptionIsIgnored() throws Exception {
                SID sid = new SID("S-1-5-21-1-2-3");
                doThrow(new CIFSException("boom")).when(mockResolver).resolveSids(any(), anyString(), any());
                sid.initContext("srv", mockCtx);
    
                // Accessor should swallow CIFSException and proceed
                sid.getType();
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/reflection/ReflectionValueExtractor.java

                return expression.substring(start, idx);
            }
    
            public int getPosition() {
                return idx < expression.length() ? idx : EOF;
            }
    
            // to make tokenizer look pretty in debugger
            @Override
            public String toString() {
                return idx < expression.length() ? expression.substring(idx) : "<EOF>";
            }
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  6. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * the beginning, thanks to using different `-source -target` values for compiling our `-jre` and
     * `-android` "flavors.")
     *
     * (We could consider releasing a listenablefuture:1.0.1 someday. But we would want to look into how
     * that affects users, especially users of the Android Gradle Plugin, since the plugin developers
     * put in a special hack for us: https://issuetracker.google.com/issues/131431257)
     */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * the beginning, thanks to using different `-source -target` values for compiling our `-jre` and
     * `-android` "flavors.")
     *
     * (We could consider releasing a listenablefuture:1.0.1 someday. But we would want to look into how
     * that affects users, especially users of the Android Gradle Plugin, since the plugin developers
     * put in a special hack for us: https://issuetracker.google.com/issues/131431257)
     */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. docs/bucket/lifecycle/README.md

    ------------|----------|------------|--------|--------------|--------------|------------------|------------------|------------------
    ```
    
    ## 3. Activate ILM versioning features
    
    This will only work with a versioned bucket, take a look at [Bucket Versioning Guide](https://docs.min.io/community/minio-object-store/administration/object-management/object-versioning.html) for more understanding.
    
    ### 3.1 Automatic removal of non current objects versions
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  9. helm-releases/minio-4.0.13.tgz

    event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 23 18:18:14 GMT 2022
    - 19.5K bytes
    - Click Count (0)
  10. helm-releases/minio-4.0.5.tgz

    event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Jul 16 06:42:56 GMT 2022
    - 18.3K bytes
    - Click Count (0)
Back to Top