Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for maxElements (0.05 sec)

  1. src/main/java/jcifs/util/ServerResponseValidator.java

         *
         * @param size array size to allocate
         * @param elementSize size of each element
         * @param maxElements maximum allowed elements
         * @throws SmbException if allocation would be too large
         */
        public void validateArrayAllocation(int size, int elementSize, int maxElements) throws SmbException {
            totalValidations.incrementAndGet();
    
            if (size < 0) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

      @Override
      protected abstract BlockingQueue<E> delegate();
    
      @CanIgnoreReturnValue
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    
      @CanIgnoreReturnValue
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

      @Override
      protected abstract BlockingQueue<E> delegate();
    
      @CanIgnoreReturnValue
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    
      @CanIgnoreReturnValue
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/QueuesTest.java

          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
          TimeUnit unit,
          boolean interruptibly)
          throws InterruptedException {
        return interruptibly
            ? Queues.drain(q, buffer, maxElements, timeout, unit)
            : Queues.drainUninterruptibly(q, buffer, maxElements, timeout, unit);
      }
    
      public void testMultipleProducers() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java

      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        return delegate().drainTo(c, maxElements);
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

      public int drainTo(Collection<? super E> c, int maxElements) {
        if (c == null) throw new NullPointerException();
        if (c == this) throw new IllegalArgumentException();
        if (maxElements <= 0) return 0;
        E[] items = this.items;
        Monitor monitor = this.monitor;
        monitor.enter();
        try {
          int i = takeIndex;
          int n = 0;
          int max = (maxElements < count) ? maxElements : count;
          while (n < max) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

      @Override
      public int drainTo(Collection<? super E> c, int maxElements) {
        if (c == null) throw new NullPointerException();
        if (c == this) throw new IllegalArgumentException();
        if (maxElements <= 0) return 0;
        Monitor monitor = this.monitor;
        monitor.enter();
        try {
          int n = 0;
          E e;
          while (n < maxElements && (e = q.poll()) != null) {
            c.add(e);
            ++n;
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        override fun remainingCapacity() = error("unsupported")
    
        override fun drainTo(sink: MutableCollection<in T>) = error("unsupported")
    
        override fun drainTo(
          sink: MutableCollection<in T>,
          maxElements: Int,
        ) = error("unsupported")
      }
    
      /** Returns true if no tasks have been scheduled. This runs the coordinator for confirmation. */
      fun isIdle() = taskRunner.activeQueues().isEmpty()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
Back to top