Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 1,387 for Take (0.02 sec)

  1. guava-tests/benchmark/com/google/common/primitives/UnsignedLongsBenchmark.java

          int j = i & ARRAY_MASK;
          tmp += UnsignedLongs.remainder(longs[j], divisors[j]);
        }
        return tmp;
      }
    
      @Benchmark
      long parseUnsignedLong(int reps) {
        long tmp = 0;
        // Given that we make three calls per pass, we scale reps down in order
        // to do a comparable amount of work to other measurements.
        int scaledReps = reps / 3 + 1;
        for (int i = 0; i < scaledReps; i++) {
          int j = i & ARRAY_MASK;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 28 01:26:26 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. docs/en/docs/tutorial/path-operation-configuration.md

    ### Tags with Enums { #tags-with-enums }
    
    If you have a big application, you might end up accumulating **several tags**, and you would want to make sure you always use the **same tag** for related *path operations*.
    
    In these cases, it could make sense to store the tags in an `Enum`.
    
    **FastAPI** supports that the same way as with plain strings:
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        latch = new CountDownLatch(1);
        future = createListenableFuture(Boolean.TRUE, null, latch);
      }
    
      @Override
      protected void tearDown() throws Exception {
    
        // Make sure we have no waiting threads.
        latch.countDown();
      }
    
      /** Constructs a listenable future with a value available after the latch has counted down. */
      protected abstract <V> ListenableFuture<V> createListenableFuture(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users-race_test.go

       ]
      }
     ]
    }`, bucket)
    	err = s.adm.AddCannedPolicy(ctx, policy, policyBytes)
    	if err != nil {
    		c.Fatalf("policy add error: %v", err)
    	}
    
    	userCount := 50
    	accessKeys := make([]string, userCount)
    	secretKeys := make([]string, userCount)
    	for i := range userCount {
    		accessKey, secretKey := mustGenerateCredentials(c)
    		err = s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    		if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4K bytes
    - Viewed (0)
  5. docs/tuning/README.md

    # How to enable 'minio' performance profile with tuned?
    
    ## Prerequisites
    
    Please make sure the following packages are already installed via `dnf` or `apt`: 
    
    - `tuned`
    - `curl`
    
    ### Install `tuned.conf` performance profile
    
    #### Step 1 - download `tuned.conf` from the referenced link
    ```
    wget https://raw.githubusercontent.com/minio/minio/master/docs/tuning/tuned.conf
    ```
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jul 19 01:15:02 UTC 2024
    - 644 bytes
    - Viewed (0)
  6. internal/event/target/amqp.go

    	target.connMutex.Lock()
    	defer target.connMutex.Unlock()
    
    	if target.conn != nil {
    		ch, err = target.conn.Channel()
    		if err == nil {
    			if target.args.PublisherConfirms {
    				confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
    				if err := ch.Confirm(false); err != nil {
    					ch.Close()
    					return nil, nil, err
    				}
    				return ch, confirms, nil
    			}
    			return ch, nil, nil
    		}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 21 04:25:07 UTC 2025
    - 10K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance_gen_test.go

    	v := rebalanceInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgrebalanceInfo(b *testing.B) {
    	v := rebalanceInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/CacheBuilder.java

     * API</h2>
     *
     * <p>The successor to Guava's caching API is <a
     * href="https://github.com/ben-manes/caffeine/wiki">Caffeine</a>. Its API is designed to make it a
     * nearly drop-in replacement. Note that it is not available for Android or GWT/J2CL and that it may
     * have <a href="https://github.com/ben-manes/caffeine/wiki/Guava">different (usually better)
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.9K bytes
    - Viewed (0)
  9. compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/SimplexTransferListenerTest.java

            // for technical reasons we cannot throw here, even if delegate does cancel transfer
            listener.transferInitiated(event(session, resource, TransferEvent.EventType.INITIATED));
    
            Thread.sleep(500); // to make sure queue is processed, cancellation applied
    
            // subsequent call will cancel
            assertThrows(
                    TransferCancelledException.class,
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sun Dec 01 19:41:22 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. internal/config/crypto_test.go

    }{
    	{
    		Data:    nil,
    		Context: nil,
    	},
    	{
    		Data:    []byte{1},
    		Context: nil,
    	},
    	{
    		Data:    []byte{1},
    		Context: kms.Context{"key": "value"},
    	},
    	{
    		Data:    make([]byte, 1<<20),
    		Context: kms.Context{"key": "value", "a": "b"},
    	},
    }
    
    func TestEncryptDecrypt(t *testing.T) {
    	key, err := hex.DecodeString("ddedadb867afa3f73bd33c25499a723ed7f9f51172ee7b1b679e08dc795debcc")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.2K bytes
    - Viewed (0)
Back to top