Search Options

Results per page
Sort
Preferred Languages
Advance

Results 881 - 890 of 1,107 for Len (0.02 sec)

  1. guava/src/com/google/common/primitives/Shorts.java

        if (collection instanceof ShortArrayAsList) {
          return ((ShortArrayAsList) collection).toShortArray();
        }
    
        Object[] boxedArray = collection.toArray();
        int len = boxedArray.length;
        short[] array = new short[len];
        for (int i = 0; i < len; i++) {
          // checkNotNull for GWT (do not optimize)
          array[i] = ((Number) checkNotNull(boxedArray[i])).shortValue();
        }
        return array;
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 27 16:47:48 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. cmd/metrics-resource.go

    func getResourceKey(name MetricName, labels map[string]string) string {
    	// labels are used to uniquely identify a metric
    	// e.g. reads_per_sec_{drive} inside the map
    	sfx := ""
    	for _, v := range labels {
    		if len(sfx) > 0 {
    			sfx += "_"
    		}
    		sfx += v
    	}
    
    	return string(name) + "_" + sfx
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  3. internal/crypto/header.go

    		return key, ErrMissingCustomerKeyMD5
    	}
    
    	clientKey, err := base64.StdEncoding.DecodeString(h.Get(xhttp.AmzServerSideEncryptionCopyCustomerKey))
    	if err != nil || len(clientKey) != 32 { // The client key must be 256 bits long
    		return key, ErrInvalidCustomerKey
    	}
    	keyMD5, err := base64.StdEncoding.DecodeString(h.Get(xhttp.AmzServerSideEncryptionCopyCustomerKeyMD5))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. cmd/background-newdisks-heal-ops.go

    // Order is preserved.
    func (h *healingTracker) setQueuedBuckets(buckets []BucketInfo) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	s := set.CreateStringSet(h.HealedBuckets...)
    	h.QueuedBuckets = make([]string, 0, len(buckets))
    	for _, b := range buckets {
    		if !s.Contains(b.Name) {
    			h.QueuedBuckets = append(h.QueuedBuckets, b.Name)
    		}
    	}
    }
    
    func (h *healingTracker) printTo(writer io.Writer) {
    	h.mu.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. cmd/config.go

    }
    
    // data is optional. If nil it will be loaded from backend.
    func readServerConfig(ctx context.Context, objAPI ObjectLayer, data []byte) (config.Config, error) {
    	srvCfg := config.New()
    	var err error
    	if len(data) == 0 {
    		configFile := path.Join(minioConfigPrefix, minioConfigFile)
    		data, err = readConfig(ctx, objAPI, configFile)
    		if err != nil {
    			if errors.Is(err, errConfigNotFound) {
    				lookupConfigs(srvCfg, objAPI)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  6. istioctl/pkg/install/k8sversion/version_test.go

    			if !c.isValid && strings.Compare(errMsgTrim, outBufTrim) != 0 {
    				t.Fatalf("\nwanted: %v \nbut found: %v", errMsgTrim, outBufTrim)
    			}
    
    			if c.isValid && outBuf.Len() > 0 {
    				t.Fatalf("\nwanted: %v \nbut found: %v", errMsgTrim, outBufTrim)
    			}
    			outBuf.Reset()
    		})
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 30 21:50:50 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. docs/debugging/hash-set/main.go

    			set := sipHashMod(prefix+object, setCount, id)
    			distrib[set] = append(distrib[set], prefix+object)
    		}
    		for set, files := range distrib {
    			fmt.Println("Set:", set+1, "Objects:", len(files))
    			if !verbose {
    				continue
    			}
    			for _, s := range files {
    				fmt.Printf("\t%s\n", s)
    			}
    		}
    		os.Exit(0)
    	}
    
    	if object == "" {
    		log.Fatalln("object name is mandatory")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  8. istioctl/pkg/precheck/precheck.go

    					outputMsgs = append(outputMsgs, m)
    				}
    			}
    			output, err := formatting.Print(outputMsgs, msgOutputFormat, true)
    			if err != nil {
    				return err
    			}
    
    			if len(outputMsgs) == 0 {
    				message := " No issues found when checking the cluster. Istio is safe to install or upgrade!"
    				message += "\n  To get started, check out https://istio.io/latest/docs/setup/getting-started/."
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 02:31:32 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  9. cmd/object-handlers-common.go

    }
    
    func deleteObjectVersions(ctx context.Context, o ObjectLayer, bucket string, toDel []ObjectToDelete, lcEvent lifecycle.Event) {
    	for remaining := toDel; len(remaining) > 0; toDel = remaining {
    		if len(toDel) > maxDeleteList {
    			remaining = toDel[maxDeleteList:]
    			toDel = toDel[:maxDeleteList]
    		} else {
    			remaining = nil
    		}
    		vc, _ := globalBucketVersioningSys.Get(bucket)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  10. tensorflow/c/c_api.cc

        status->status =
            InvalidArgument("Value for '", attr_name, "' is not a list");
        return;
      }
      const auto len = std::min(max_values, attr->list().s_size());
      char* p = static_cast<char*>(storage);
      for (int i = 0; i < len; ++i) {
        const string& s = attr->list().s(i);
        values[i] = p;
        lengths[i] = s.size();
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
Back to top