Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 94 for capacity (0.1 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. android/guava/src/com/google/common/collect/Queues.java

       * @since 12.0
       */
      @J2ktIncompatible
      @GwtIncompatible // LinkedBlockingDeque
      public static <E> LinkedBlockingDeque<E> newLinkedBlockingDeque(int capacity) {
        return new LinkedBlockingDeque<>(capacity);
      }
    
      /**
       * Creates a {@code LinkedBlockingDeque} with a capacity of {@link Integer#MAX_VALUE}, containing
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/Queues.java

       * @since 12.0
       */
      @J2ktIncompatible
      @GwtIncompatible // LinkedBlockingDeque
      public static <E> LinkedBlockingDeque<E> newLinkedBlockingDeque(int capacity) {
        return new LinkedBlockingDeque<>(capacity);
      }
    
      /**
       * Creates a {@code LinkedBlockingDeque} with a capacity of {@link Integer#MAX_VALUE}, containing
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  4. 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)
  5. 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. cmd/metrics.go

    	totalDisks := offlineDisks.Merge(onlineDisks)
    
    	// Report total capacity
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "capacity_raw", "total"),
    			"Total capacity online in the cluster",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(GetTotalCapacity(server.Disks)),
    	)
    
    	// Report total capacity free
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. 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)
  8. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

        assertEquals(0, ArbitraryInstances.get(Buffer.class).capacity());
        assertEquals(0, ArbitraryInstances.get(CharBuffer.class).capacity());
        assertEquals(0, ArbitraryInstances.get(ByteBuffer.class).capacity());
        assertEquals(0, ArbitraryInstances.get(ShortBuffer.class).capacity());
        assertEquals(0, ArbitraryInstances.get(IntBuffer.class).capacity());
        assertEquals(0, ArbitraryInstances.get(LongBuffer.class).capacity());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  9. internal/grid/handlers.go

    		// Should not be set unless there are different handlers for the same HandlerID.
    		Subroute string
    
    		// OutCapacity is the output capacity. If <= 0 capacity will be 1.
    		OutCapacity int
    
    		// InCapacity is the output capacity.
    		// If == 0 no input is expected
    		InCapacity int
    	}
    )
    
    type subHandlerID [32]byte
    
    func makeSubHandlerID(id HandlerID, subRoute string) subHandlerID {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue.create();
        assertEquals(11, queue.capacity());
        checkUnbounded(queue);
        checkNatural(queue);
      }
    
      public void testCreation_comparator() {
        MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue.orderedBy(SOME_COMPARATOR).create();
        assertEquals(11, queue.capacity());
        checkUnbounded(queue);
        assertSame(SOME_COMPARATOR, queue.comparator());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35.9K bytes
    - Viewed (0)
Back to top