Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 661 - 670 of 676 for known (0.04 seconds)

  1. cmd/erasure-server-pool.go

    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    
    	opts.MetadataChg = true
    	opts.NoLock = true
    	// We don't know the size here set 1GiB at least.
    	idx, err := z.getPoolIdxExistingWithOpts(ctx, bucket, object, opts)
    	if err != nil {
    		return ObjectInfo{}, err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/io/MoreFiles.java

        @Override
        public Optional<Long> sizeIfKnown() {
          BasicFileAttributes attrs;
          try {
            attrs = readAttributes();
          } catch (IOException e) {
            // Failed to get attributes; we don't know the size.
            return Optional.absent();
          }
    
          // Don't return a size for directories or symbolic links; their sizes are implementation
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Apr 14 16:07:06 GMT 2025
    - 34.6K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        // Backing futures complete
        Boolean booleanPartial = true;
        futureBoolean.set(booleanPartial);
        // Once the backing futures are done there's a (brief) moment where we know nothing
        assertThat(futureResult.toString()).matches("CombinedFuture@\\w+\\[status=PENDING]");
        callableBlocking.countDown();
        // Need to wait for resultFuture to be returned.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        // Backing futures complete
        Boolean booleanPartial = true;
        futureBoolean.set(booleanPartial);
        // Once the backing futures are done there's a (brief) moment where we know nothing
        assertThat(futureResult.toString()).matches("CombinedFuture@\\w+\\[status=PENDING]");
        callableBlocking.countDown();
        // Need to wait for resultFuture to be returned.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  5. cmd/erasure-server-pool-decom.go

    		StartSize:   pi.Free,
    		CurrentSize: pi.Free,
    		TotalSize:   pi.Total,
    	}
    	return nil
    }
    
    func (p poolMeta) IsSuspended(idx int) bool {
    	if idx >= len(p.Pools) {
    		// We don't really know if the pool is suspended or not, since it doesn't exist.
    		return false
    	}
    	return p.Pools[idx].Decommission != nil
    }
    
    func (p *poolMeta) validate(pools []*erasureSets) (bool, error) {
    	type poolInfo struct {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  6. android/guava/src/com/google/common/net/InetAddresses.java

       *
       * <p>{@link InetAddress#getByAddress} is documented as throwing a checked exception "if IP
       * address is of illegal length." We replace it with an unchecked exception, for use by callers
       * who already know that addr is an array of length 4 or 16.
       *
       * @param addr the raw 4-byte or 16-byte IP address in big-endian order
       * @return an InetAddress object created from the raw IP address
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 47.7K bytes
    - Click Count (0)
  7. cmd/bucket-handlers.go

    			// This is not for our server, so we can continue
    			continue
    		}
    
    		wg.Add(1)
    		go func(bucket string) {
    			defer wg.Done()
    			// We go to here, so we know the bucket no longer exists,
    			// but is registered in DNS to this server
    			if err := globalDNSConfig.Delete(bucket); err != nil {
    				dnsLogIf(GlobalContext, fmt.Errorf("Failed to remove DNS entry for %s due to %w",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  8. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                    }
                }
            } else if (userSuppliedConfigurationProcessorCount > 1) {
                //
                // There are too many ConfigurationProcessors so we don't know which one to run so report the error.
                //
                StringBuilder sb = new StringBuilder(String.format(
                        "%nThere can only be one user supplied ConfigurationProcessor, there are %s:%n%n",
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 78.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/collect/Maps.java

       * must be well-behaved with respect to {@link Object#equals} and {@link Object#hashCode}.
       *
       * <p><b>Note:</b>If you only need to know whether two maps have the same mappings, call {@code
       * left.equals(right)} instead of this method.
       *
       * @param left the map to treat as the "left" map for purposes of comparison
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 157.6K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/Maps.java

       * must be well-behaved with respect to {@link Object#equals} and {@link Object#hashCode}.
       *
       * <p><b>Note:</b>If you only need to know whether two maps have the same mappings, call {@code
       * left.equals(right)} instead of this method.
       *
       * @param left the map to treat as the "left" map for purposes of comparison
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 163.4K bytes
    - Click Count (0)
Back to Top