Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for Capacity (0.11 sec)

  1. internal/bpool/bpool_test.go

    		bp.Get() // discard
    	}
    
    	// Try putting some invalid buffers into pool
    	bp.Put(make([]byte, bp.w, bp.wcap-1)) // wrong capacity is rejected (less)
    	bp.Put(make([]byte, bp.w, bp.wcap+1)) // wrong capacity is rejected (more)
    	bp.Put(make([]byte, width))           // wrong capacity is rejected (very less)
    	if len(bp.c) > 0 {
    		t.Fatal("bytepool should have rejected invalid packets")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/storage/v1alpha1/generated.proto

    //
    // The following three cases all imply that no capacity is available for
    // a certain combination:
    // - no object exists with suitable topology and storage class name
    // - such an object exists, but the capacity is unset
    // - such an object exists, but the capacity is zero
    //
    // The producer of these objects can decide which approach is more suitable.
    //
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cluster-health.go

    var (
    	healthCapacityRawTotalBytesMD = NewGaugeMD(healthCapacityRawTotalBytes,
    		"Total cluster raw storage capacity in bytes")
    	healthCapacityRawFreeBytesMD = NewGaugeMD(healthCapacityRawFreeBytes,
    		"Total cluster raw storage free in bytes")
    	healthCapacityUsableTotalBytesMD = NewGaugeMD(healthCapacityUsableTotalBytes,
    		"Total cluster usable storage capacity in bytes")
    	healthCapacityUsableFreeBytesMD = NewGaugeMD(healthCapacityUsableFreeBytes,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. cmd/notification-summary.go

    )
    
    // GetTotalCapacity gets the total capacity in the cluster.
    func GetTotalCapacity(diskInfo []madmin.Disk) (capacity uint64) {
    	for _, disk := range diskInfo {
    		capacity += disk.TotalSpace
    	}
    	return
    }
    
    // GetTotalUsableCapacity gets the total usable capacity in the cluster.
    func GetTotalUsableCapacity(diskInfo []madmin.Disk, s StorageInfo) (capacity uint64) {
    	for _, disk := range diskInfo {
    		// Ignore invalid.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/ReaderInputStream.java

              return 0; // Not called.
            }
          }
        }
      }
    
      /** Returns a new CharBuffer identical to buf, except twice the capacity. */
      private static CharBuffer grow(CharBuffer buf) {
        char[] copy = Arrays.copyOf(buf.array(), buf.capacity() * 2);
        CharBuffer bigger = CharBuffer.wrap(copy);
        Java8Compatibility.position(bigger, buf.position());
        Java8Compatibility.limit(bigger, buf.limit());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/ReaderInputStream.java

              return 0; // Not called.
            }
          }
        }
      }
    
      /** Returns a new CharBuffer identical to buf, except twice the capacity. */
      private static CharBuffer grow(CharBuffer buf) {
        char[] copy = Arrays.copyOf(buf.array(), buf.capacity() * 2);
        CharBuffer bigger = CharBuffer.wrap(copy);
        Java8Compatibility.position(bigger, buf.position());
        Java8Compatibility.limit(bigger, buf.limit());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  7. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBenchmark.java

        queue = (BlockingQueue<String>) constructor.newInstance(capacity);
    
        strings = new String[capacity];
        for (int i = 0; i < capacity; i++) {
          strings[i] = String.valueOf(Math.random());
        }
      }
    
      @Benchmark
      void addsAndRemoves(int reps) {
        int capacity = this.capacity;
        BlockingQueue<String> queue = this.queue;
        String[] strings = this.strings;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/collection/CaseInsensitiveMap.java

         */
        public CaseInsensitiveMap() {
        }
    
        /**
         * {@link CaseInsensitiveMap}を作成します。
         *
         * @param capacity
         *            初期容量
         */
        public CaseInsensitiveMap(final int capacity) {
            super(capacity);
        }
    
        /**
         * キーが含まれているかどうかを返します。
         *
         * @param key
         *            キー
         * @return キーが含まれているかどうか
         */
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. internal/bpool/bpool.go

    func NewBytePoolCap(maxSize uint64, width int, capwidth int) (bp *BytePoolCap) {
    	if capwidth <= 0 {
    		panic("total buffer capacity must be provided")
    	}
    	if capwidth < 64 {
    		panic("buffer capped with smaller than 64 bytes is not supported")
    	}
    	if width > capwidth {
    		panic("minimum buffer length cannot be > capacity of the buffer")
    	}
    	return &BytePoolCap{
    		c:    make(chan []byte, maxSize),
    		w:    width,
    		wcap: capwidth,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  10. guava-tests/benchmark/com/google/common/cache/SegmentBenchmark.java

      @Param({"16", "32", "64", "128", "256", "512", "1024", "2048", "4096", "8192"})
      int capacity;
    
      private Segment<Object, Object> segment;
    
      @BeforeExperiment
      void setUp() {
        LocalCache<Object, Object> cache =
            new LocalCache<>(
                CacheBuilder.newBuilder().concurrencyLevel(1).initialCapacity(capacity), null);
        checkState(cache.segments.length == 1);
        segment = cache.segments[0];
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 23 16:59:39 UTC 2019
    - 2.1K bytes
    - Viewed (0)
Back to top