Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 46 of 46 for Swarm (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        for (int i = 0; i < 8; i++) {
          limiter.acquire(); // // #4
        }
        stopwatch.sleepMillis(200); // #5: to repay for the last acquire
        stopwatch.sleepMillis(1000); // #6: still warm! It would take another 3 seconds to go cold
        for (int i = 0; i < 8; i++) {
          limiter.acquire(); // #7
        }
        assertEvents(
            "R0.00, R1.75, R1.26, R0.76, R0.30, R0.20, R0.20, R0.20", // #1
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
  2. cmd/erasure-metadata.go

    		} else if metadata.TransitionStatus == lifecycle.TransitionComplete {
    			// For tiered objects, read quorum is N/2+1 to ensure simple majority on xl.meta.
    			// It is not equal to EcM because the data integrity is entrusted with the warm tier.
    			// However, we never go below EcM, in case of a EcM=EcN setup.
    			parities[index] = max(totalShards-(totalShards/2+1), metadata.Erasure.ParityBlocks)
    		} else {
    			parities[index] = metadata.Erasure.ParityBlocks
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        val networkInterceptorDelay = 250L
        val requestBodyDelay = 250L
        val responseHeadersStartDelay = 250L
        val responseBodyStartDelay = 250L
        val responseBodyEndDelay = 250L
    
        // Warm up the client so the timing part of the test gets a pooled connection.
        server.enqueue(MockResponse())
        val warmUpCall =
          client.newCallWithListener(
            Request
              .Builder()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  4. cmd/erasure-object.go

    	res, err := er.NewMultipartUpload(ctx, bucket, object, ropts)
    	if err != nil {
    		return setRestoreHeaderFn(oi, err)
    	}
    
    	var uploadedParts []CompletePart
    	var rs *HTTPRangeSpec
    	// get reader from the warm backend - note that even in the case of encrypted objects, this stream is still encrypted.
    	gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, http.Header{}, oi, opts)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  5. RELEASE.md

    ### Major Features and Improvements
    
    * `tf.data`
        * Adds `autotune.min_parallelism` to `tf.data.Options` to enable faster input pipeline warm up.
    * `tf.lite`
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Mon Mar 30 18:31:38 GMT 2026
    - 746.5K bytes
    - Click Count (3)
  6. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

                defaultMap.put(FessConfig.LOG_NOTIFICATION_BUFFER_SIZE, "1000");
                defaultMap.put(FessConfig.LOG_NOTIFICATION_INTERVAL, "300");
                defaultMap.put(FessConfig.lasta_di_SMART_DEPLOY_MODE, "warm");
                defaultMap.put(FessConfig.DEVELOPMENT_HERE, "true");
                defaultMap.put(FessConfig.ENVIRONMENT_TITLE, "Local Development");
                defaultMap.put(FessConfig.FRAMEWORK_DEBUG, "false");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 576.9K bytes
    - Click Count (2)
Back to Top