Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 327 for flow (0.02 sec)

  1. guava-tests/test/com/google/common/collect/ImmutableRangeMapTest.java

        }
        ImmutableRangeMap<Integer, Integer> map = builder.build();
        for (int i = 0; i < 100; i++) {
          assertEquals(Integer.valueOf(i), map.get(i));
        }
      }
    
      @AndroidIncompatible // slow
      public void testAsMapOfRanges() {
        for (Range<Integer> range1 : RANGES) {
          for (Range<Integer> range2 : RANGES) {
            if (!range1.isConnected(range2) || range1.intersection(range2).isEmpty()) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/ActiveProjectArtifact.java

    /**
     * Wraps an active project instance to be able to receive updates from its artifact without affecting the original
     * attributes of this artifact.
     *
     * TODO I think this exposes a design flaw in that the immutable and mutable parts of an artifact are in one class and
     * should be split. ie scope, file, etc depend on the context of use, whereas everything else is immutable.
     */
    @Deprecated
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

       * this address.
       *
       * If [planToReplace] is non-null, this will swap it for a pooled connection if that pooled
       * connection uses HTTP/2. That results in fewer sockets overall and thus fewer TCP slow starts.
       */
      internal fun planReusePooledConnection(
        planToReplace: ConnectPlan? = null,
        routes: List<Route>? = null,
      ): ReusePlan? {
        val result =
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 12K bytes
    - Viewed (0)
  4. internal/event/targetlist.go

    		list.eventsSkipped.Add(int64(len(list.queue)))
    		return
    	default:
    		list.eventsSkipped.Add(1)
    		err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend)
    		for id := range targetIDset {
    			reqInfo := &logger.ReqInfo{}
    			reqInfo.AppendTags("targetID", id.String())
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  5. internal/config/api/api.go

    	}
    	cfg.ListQuorum = listQuorum
    
    	replicationPriority := env.Get(EnvAPIReplicationPriority, kvs.GetWithDefault(apiReplicationPriority, DefaultKVS))
    	switch replicationPriority {
    	case "slow", "fast", "auto":
    	default:
    		return cfg, fmt.Errorf("invalid value %v for replication_priority", replicationPriority)
    	}
    	cfg.ReplicationPriority = replicationPriority
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.5K bytes
    - Viewed (1)
  6. CHANGELOG/CHANGELOG-1.20.md

    Initially introduced in 1.18, Kubernetes 1.20 now enables API Priority and Fairness (APF) by default. This allows `kube-apiserver` to [categorize incoming requests by priority levels](https://docs.k8s.io/concepts/cluster-administration/flow-control/).
    
    ### IPv4/IPv6 run
    
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Jan 19 21:05:45 UTC 2022
    - 409K bytes
    - Viewed (0)
  7. architecture/standards/0008-use-nullaway.md

    Prefer either:
      * Provide only non-nullable version and move the `null` check to the call site (if the number of nullable callsites is low).
      * Provide two overloads with a different names (as Java doesn't support overloading on nullability). See 
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Thu Dec 11 10:24:40 UTC 2025
    - 4K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/AndXServerMessageBlockTest.java

            };
            byte[] buffer = new byte[1024];
    
            // Setup buffer after header
            buffer[33] = 4; // wordCount
            buffer[34] = (byte) 0xFF; // andxCommand
            buffer[36] = 0; // andxOffset low
            buffer[37] = 0; // andxOffset high
            SMBUtil.writeInt2(20, buffer, 42); // byteCount
    
            int length = testBlock.decode(buffer, 0);
    
            assertTrue(length > 0);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  9. doc/asm.html

    specific to each architecture.
    The sections below list these.
    </p>
    
    <p>
    One detail evident in the examples from the previous sections is that data in the instructions flows from left to right:
    <code>MOVQ</code> <code>$0,</code> <code>CX</code> clears <code>CX</code>.
    This rule applies even on architectures where the conventional notation uses the opposite direction.
    </p>
    
    <p>
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Nov 14 19:09:46 UTC 2025
    - 36.5K bytes
    - Viewed (0)
  10. internal/etag/reader.go

    // nil as ETag.
    //
    // Wrap provides an adapter for io.Reader implementations
    // that don't implement the Tagger interface.
    // It is mainly used to provide a high-level io.Reader
    // access to the ETag computed by a low-level io.Reader:
    //
    //	content := etag.NewReader(r.Body, nil)
    //
    //	compressedContent := Compress(content)
    //	encryptedContent := Encrypt(compressedContent)
    //
    //	// Now, we need an io.Reader that can access
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 4.8K bytes
    - Viewed (0)
Back to top