Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 676 for cdone (0.01 seconds)

  1. cmd/bucket-replication_test.go

    					ResetID:         "xyz",
    					ResetBeforeDate: UTCNow(),
    				}}},
    			},
    		},
    		{ // 10. existing object replication enabled, versioning enabled, replication status Complete & reset done
    			name: "reset done on object in Completed Status - ineligbile for re-replication",
    			info: ObjectInfo{
    				Size:                      100,
    				ReplicationStatusInternal: "arn1:COMPLETED;",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  2. impl/maven-core/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    getArguments(); public String toString(); public static String quoteArgument(String) throws CommandLineException; public static String toString(String[]); public static String[] translateCommandline(String) throws Exception; public int size(); public Object clone(); public void clear(); public void clearArgs(); public Commandline$Marker createMarker(); public void setWorkingDirectory(String); public java.io.File getWorkingDirectory(); public Process execute() throws CommandLineException; public java.util.Properties...
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 164.6K bytes
    - Click Count (0)
  3. android/guava-tests/benchmark/com/google/common/collect/SortedCopyBenchmark.java

        List<Integer> list = new ArrayList<>(set);
        inputOrder.arrange(list);
        input = ImmutableList.copyOf(list);
      }
    
      @Benchmark
      int collections(int reps) {
        int dummy = 0;
        // Yes, this could be done more elegantly
        if (mutable) {
          for (int i = 0; i < reps; i++) {
            List<Integer> copy = new ArrayList<>(input);
            sort(copy);
            dummy += copy.get(0);
          }
        } else {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 3.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/hash/HashCode.java

       *
       * @since 15.0 (since 12.0 in HashCodes)
       */
      public static HashCode fromBytes(byte[] bytes) {
        checkArgument(bytes.length >= 1, "A HashCode must contain at least 1 byte.");
        return fromBytesNoCopy(bytes.clone());
      }
    
      /**
       * Creates a {@code HashCode} from a byte array. The array is <i>not</i> copied defensively, so it
       * must be handed-off so as to preserve the immutability contract of {@code HashCode}.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/reflect/TypeVisitor.java

    import java.util.HashSet;
    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Based on what a {@link Type} is, dispatch it to the corresponding {@code visit*} method. By
     * default, no recursion is done for type arguments or type bounds. But subclasses can opt to do
     * recursion by calling {@link #visit} for any {@code Type} while visitation is in progress. For
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  6. docs/sts/etcd.md

    ```
    go run client-grants.go -cid PoEgXP6uVO45IsENRngDXj5Au5Ya -csec eKsw6z8CtOJVBtrOWvhRWL4TUCga
    
    ##### Credentials
    {
     "accessKey": "IRBLVDGN5QGMDCMO1X8V",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  7. internal/cachevalue/cache_test.go

    import (
    	"context"
    	"errors"
    	"testing"
    	"time"
    )
    
    func slowCaller(ctx context.Context) error {
    	sl := time.NewTimer(time.Second)
    	defer sl.Stop()
    
    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    	cache.InitOnce(2*time.Second, Opts{},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

       * mutated by the call thread only. If is accessed by background connect threads.
       */
      private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>()
    
      /**
       * Results are posted here as they occur. The find job is done when either one plan completes
       * successfully or all plans fail.
       */
      private val connectResults = taskRunner.backend.decorate(LinkedBlockingDeque<ConnectResult>())
    
      override fun find(): RealConnection {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 5.8K bytes
    - Click Count (0)
  9. guava/src/com/google/common/hash/HashCode.java

       *
       * @since 15.0 (since 12.0 in HashCodes)
       */
      public static HashCode fromBytes(byte[] bytes) {
        checkArgument(bytes.length >= 1, "A HashCode must contain at least 1 byte.");
        return fromBytesNoCopy(bytes.clone());
      }
    
      /**
       * Creates a {@code HashCode} from a byte array. The array is <i>not</i> copied defensively, so it
       * must be handed-off so as to preserve the immutability contract of {@code HashCode}.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  10. cmd/metacache-server-pool.go

    	listCtx, cancelList := context.WithCancel(ctx)
    	filteredResults := o.gatherResults(listCtx, filterCh)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	var listErr error
    
    	go func(o listPathOptions) {
    		defer wg.Done()
    		if o.Lifecycle == nil {
    			// No filtering ahead, ask drives to stop
    			// listing exactly at a specific limit.
    			o.StopDiskAtLimit = true
    		}
    		listErr = z.listMerged(listCtx, o, filterCh)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
Back to Top