Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 62 for Swarm (0.02 seconds)

  1. src/test/java/org/codelibs/fess/query/QueryFieldConfigSetBasedLookupTest.java

            }
            queryFieldConfig.setSortFields(fields);
    
            // Test field that appears at the end (worst case for array lookup)
            String testField = "field999";
    
            // Warm up
            for (int i = 0; i < 100; i++) {
                queryFieldConfig.isSortField(testField);
            }
    
            // Measure Set-based lookup (current implementation)
            long setStartTime = System.nanoTime();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 19.4K bytes
    - Click Count (0)
  2. cmd/erasure-metadata_test.go

    	}
    }
    
    func TestListObjectParities(t *testing.T) {
    	mkMetaArr := func(N, parity, agree int) []FileInfo {
    		fi := newFileInfo("obj-1", N-parity, parity)
    		fi.TransitionTier = "WARM-TIER"
    		fi.TransitionedObjName = mustGetUUID()
    		fi.TransitionStatus = "complete"
    		fi.Size = 1 << 20
    
    		metaArr := make([]FileInfo, N)
    		for i := range N {
    			fi.Erasure.Index = i + 1
    			metaArr[i] = fi
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  3. docs/bigdata/README.md

    MinIO also supports multi-cluster, multi-site federation similar to AWS regions and tiers. Using MinIO Information Lifecycle Management (ILM), you can configure data to be tiered between NVMe based hot storage, and HDD based warm storage. All data is encrypted with per-object key. Access Control and Identity Management between the tenants are managed by MinIO using OpenID Connect or Kerberos/LDAP/AD.
    
    ## **2. Prerequisites**
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  4. android/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)
  5. 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)
  6. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       *          |              /   .     thresholdPermits and maxPermits
       *          |             /    .
       *          |            /     .
       *          |           /      .
       *   stable +----------/  WARM .
       * interval |          .   UP  .
       *          |          . PERIOD.
       *          |          .       .
       *        0 +----------+-------+--------------→ storedPermits
       *          0 thresholdPermits maxPermits
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  7. 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)
  8. cmd/bucket-lifecycle.go

    			// TODO consider including expiry of restored object to events we
    			// notify.
    			auditLogLifecycle(ctx, *oi, ILMExpiry, tags, traceFn)
    		}
    		return err
    	}
    
    	// Delete remote object from warm-tier
    	err := deleteObjectFromRemoteTier(ctx, oi.TransitionedObject.Name, oi.TransitionedObject.VersionID, oi.TransitionedObject.Tier)
    	if err == nil {
    		// Skip adding free version since we successfully deleted the
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top