Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 230 for peak (0.04 sec)

  1. guava-tests/test/com/google/common/cache/EmptyCachesTest.java

              }
            });
      }
    
      private CacheBuilderFactory cacheFactory() {
        return new CacheBuilderFactory()
            .withKeyStrengths(ImmutableSet.of(Strength.STRONG, Strength.WEAK))
            .withValueStrengths(ImmutableSet.copyOf(Strength.values()))
            .withConcurrencyLevels(ImmutableSet.of(1, 4, 16, 64))
            .withMaximumSizes(ImmutableSet.of(0, 1, 10, 100, 1000))
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/TreeTraverser.java

          this.queue = new ArrayDeque<>();
          queue.add(root);
        }
    
        @Override
        public boolean hasNext() {
          return !queue.isEmpty();
        }
    
        @Override
        public T peek() {
          return queue.element();
        }
    
        @Override
        public T next() {
          T result = queue.remove();
          Iterables.addAll(queue, children(result));
          return result;
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. docs/features/https.md

    versions](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-tls-version/) and [cipher suites](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-cipher-suite/) to offer. A client that wants to maximize connectivity would include obsolete TLS versions and weak-by-design cipher suites. A strict client that wants to maximize security would be limited to only the latest TLS version and strongest cipher suites.
    
    Specific security vs. connectivity decisions are implemented by [ConnectionSpec](https:/...
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Dec 24 00:16:30 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

            delegate.put(element)
            editCount++
          }
        }
    
        override fun iterator() = error("unsupported")
    
        override fun offer(e: T) = error("unsupported")
    
        override fun peek(): T = error("unsupported")
    
        override fun offer(
          element: T,
          timeout: Long,
          unit: TimeUnit,
        ) = error("unsupported")
    
        override fun take() = error("unsupported")
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Object one = new Object();
        assertSame(one, cache.getUnchecked(one));
        assertTrue(segment.recencyQueue.isEmpty());
        assertSame(one, map.get(one));
        assertSame(one, segment.recencyQueue.peek().getKey());
        assertSame(one, cache.getUnchecked(one));
        assertFalse(segment.recencyQueue.isEmpty());
      }
    
      public void testRecursiveComputation() throws InterruptedException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Object one = new Object();
        assertSame(one, cache.getUnchecked(one));
        assertTrue(segment.recencyQueue.isEmpty());
        assertSame(one, map.get(one));
        assertSame(one, segment.recencyQueue.peek().getKey());
        assertSame(one, cache.getUnchecked(one));
        assertFalse(segment.recencyQueue.isEmpty());
      }
    
      public void testRecursiveComputation() throws InterruptedException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbFileInputStream.java

         * This stream class is unbuffered. Therefore this method will always
         * return 0 for streams connected to regular files. However, a
         * stream created from a Named Pipe this method will query the server using a
         * "peek named pipe" operation and return the number of available bytes
         * on the server.
         */
        @Override
        public int available () throws IOException {
            return 0;
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/ztunnelserver_test.go

    func podAndNetns() (*v1.Pod, *fakeNs) {
    	devNull, err := os.Open(os.DevNull)
    	if err != nil {
    		panic(err)
    	}
    	// we can't close this now, because we need to pass it from the ztunnel server to the client
    	// it would leak, but this is a test, so we don't care
    	//	defer devNull.Close()
    
    	id := ztunnelTestCounter.Add(1)
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: fmt.Sprintf("name-%d", id),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  9. cmd/admin-heal-ops.go

    		h.currentStatus.Summary = healFinishedStatus
    		h.mutex.Unlock()
    
    		// drain traverse channel so the traversal
    		// go-routine does not leak.
    		go func() {
    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    func (h *healSequence) queueHealTask(source healSource, healType madmin.HealItemType) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

    /**
     * This stream class is unbuffered. Therefore this method will always
     * return 0 for streams connected to regular files. However, a 
     * stream created from a Named Pipe this method will query the server using a
     * "peek named pipe" operation and return the number of available bytes
     * on the server.
     */
        public int available() throws IOException {
            SmbNamedPipe pipe;
            TransPeekNamedPipe req;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.9K bytes
    - Viewed (0)
Back to top