Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 285 for compactor (2.34 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    		}
    
    		if foundBefore {
    			// replace compactor
    			compactor.cancel()
    			compactor.client.Close()
    		} else {
    			// start new compactor
    			compactor = &runningCompactor{}
    			compactors[key] = compactor
    		}
    
    		ctx, cancel := context.WithCancel(context.Background())
    
    		compactor.interval = interval
    		compactor.cancel = cancel
    		compactor.client = compactorClient
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    	}
    
    	if !into.Compacted && f.newCache.Info.Name != folder.name {
    		flat := f.newCache.sizeRecursive(thisHash.Key())
    		flat.Compacted = true
    		var compact bool
    		if flat.Objects < dataScannerCompactLeastObject {
    			compact = true
    		} else {
    			// Compact if we only have objects as children...
    			compact = true
    			for k := range into.Children {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:43:17 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  3. platforms/core-runtime/base-services/src/main/java/org/gradle/util/internal/CollectionUtils.java

        }
    
    
        /**
         * Returns a sorted copy of the provided collection of things. Uses the provided comparator to sort.
         */
        public static <T> List<T> sort(Iterable<? extends T> things, Comparator<? super T> comparator) {
            List<T> copy = toMutableList(things);
            Collections.sort(copy, comparator);
            return copy;
        }
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 06:47:40 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  4. subprojects/core-api/src/main/java/org/gradle/util/CollectionUtils.java

        }
    
    
        /**
         * Returns a sorted copy of the provided collection of things. Uses the provided comparator to sort.
         */
        public static <T> List<T> sort(Iterable<? extends T> things, Comparator<? super T> comparator) {
            List<T> copy = toMutableList(things);
            Collections.sort(copy, comparator);
            return copy;
        }
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Feb 22 11:17:19 UTC 2024
    - 26K bytes
    - Viewed (0)
  5. platforms/core-runtime/base-services/src/test/groovy/org/gradle/util/internal/CollectionUtilsTest.groovy

            toStringList(list) == ["42", "string"]
        }
    
        def "list compacting"() {
            expect:
            compact([1, null, 2]) == [1, 2]
            compact([null, 1, 2]) == [1, 2]
            compact([1, 2, null]) == [1, 2]
    
            def l = [1, 2, 3]
            compact(l).is l
    
        }
    
        def "collect array"() {
            expect:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    	e, ok := d.Cache[path.Key()]
    	if !ok {
    		return
    	}
    	if e.Compacted {
    		return
    	}
    	// If direct children have more, compact all.
    	if len(e.Children) > limit && compactSelf {
    		flat := d.sizeRecursive(path.Key())
    		flat.Compacted = true
    		d.deleteRecursive(path)
    		d.replaceHashed(path, nil, *flat)
    		return
    	}
    	total := d.totalChildrenRec(path.Key())
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 10 14:49:50 UTC 2024
    - 42.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/compatibility.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	{
    		// compact before decoding since embedded RawExtension fields retain indenting
    		compacted := &bytes.Buffer{}
    		if err := gojson.Compact(compacted, actualJSON); err != nil {
    			t.Error(err)
    		}
    
    		jsonDecoded := emptyObj.DeepCopyObject()
    		jsonDecoded, _, err = c.JSON.Decode(compacted.Bytes(), &gvk, jsonDecoded)
    		if err != nil {
    			t.Error(err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 16:38:32 UTC 2023
    - 17.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/MinMaxPriorityQueue.java

         */
        private static final int UNSET_EXPECTED_SIZE = -1;
    
        private final Comparator<B> comparator;
        private int expectedSize = UNSET_EXPECTED_SIZE;
        private int maximumSize = Integer.MAX_VALUE;
    
        private Builder(Comparator<B> comparator) {
          this.comparator = checkNotNull(comparator);
        }
    
        /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 34K bytes
    - Viewed (0)
  9. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedSet.java

          Comparator<? super E> comparator, Iterable<? extends E> elements) {
        checkNotNull(comparator);
        return copyOfInternal(comparator, elements, false);
      }
    
      public static <E> ImmutableSortedSet<E> copyOf(
          Comparator<? super E> comparator, Collection<? extends E> elements) {
        checkNotNull(comparator);
        return copyOfInternal(comparator, elements, false);
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 08 03:01:02 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  10. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedMap.java

       * should be identical to the one the user passed in. We touch only the
       * "secret" comparator used by the delegate implementation.
       */
    
      private static <K, V> SortedMap<K, V> newModifiableDelegate(Comparator<? super K> comparator) {
        return newTreeMap(nullAccepting(comparator));
      }
    
      private static <E> Comparator<@Nullable E> nullAccepting(Comparator<E> comparator) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 27 19:19:19 UTC 2024
    - 16.4K bytes
    - Viewed (0)
Back to top