Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 597 for index (0.14 sec)

  1. src/runtime/mspanset.go

    	spineLen  atomic.Uintptr            // Spine array length
    	spineCap  uintptr                   // Spine array cap, accessed under spineLock
    
    	// index is the head and tail of the spanSet in a single field.
    	// The head and the tail both represent an index into the logical
    	// concatenation of all blocks, with the head always behind or
    	// equal to the tail (indicating an empty set). This field is
    	// always accessed atomically.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. src/crypto/rsa/pkcs1v15.go

    	// bytes into em.
    	validPS := subtle.ConstantTimeLessOrEq(2+8, index)
    
    	valid = firstByteIsZero & secondByteIsTwo & (^lookingForIndex & 1) & validPS
    	index = subtle.ConstantTimeSelect(valid, index+1, 0)
    	return valid, em, index, nil
    }
    
    // nonZeroRandomBytes fills the given slice with non-zero random octets.
    func nonZeroRandomBytes(s []byte, random io.Reader) (err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:11:21 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    	g := errgroup.WithNErrs(len(storageDisks))
    
    	// Write `format.json` to all disks.
    	for index := range storageDisks {
    		index := index
    		g.Go(func() error {
    			if formats[index] == nil {
    				return errDiskNotFound
    			}
    			return saveFormatErasure(storageDisks[index], formats[index], "")
    		}, index)
    	}
    
    	// Wait for the routines to finish.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. plugin/pkg/auth/authorizer/node/graph.go

    	n := e.From()
    	index := g.destinationEdgeIndex[n.ID()]
    	if index == nil {
    		// There is no index, use the full index computation method
    		g.recomputeDestinationIndex_locked(n)
    		return
    	}
    	// fast-add the new edge to an existing index
    	if destinationEdge, ok := e.(*destinationEdge); ok {
    		index.increment(destinationEdge.DestinationID())
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  5. pkg/controller/job/indexed_job_utils.go

    	template.Labels[batch.JobCompletionIndexAnnotation] = strconv.Itoa(index)
    }
    
    func podGenerateNameWithIndex(jobName string, index int) string {
    	appendIndex := "-" + strconv.Itoa(index) + "-"
    	generateNamePrefix := jobName + appendIndex
    	if len(generateNamePrefix) > names.MaxGeneratedNameLength {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  6. pkg/controller/job/success_policy_test.go

    			successPolicy: &batch.SuccessPolicy{
    				Rules: []batch.SuccessPolicyRule{{
    					SucceededIndexes: ptr.To("0-2"),
    				}},
    			},
    			wantMessage:          "Matched rules at index 0",
    			wantMetSuccessPolicy: true,
    		},
    		"rules.succeededIndexes is specified; succeededIndexes didn't match rules": {
    			enableJobSuccessPolicy: true,
    			completions:            10,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  7. pkg/scheduler/apis/config/validation/validation.go

    		for i := range cc.Profiles {
    			profile := &cc.Profiles[i]
    			path := profilesPath.Index(i)
    			errs = append(errs, validateKubeSchedulerProfile(path, cc.APIVersion, profile)...)
    			if idx, ok := existingProfiles[profile.SchedulerName]; ok {
    				errs = append(errs, field.Duplicate(path.Child("schedulerName"), profilesPath.Index(idx).Child("schedulerName")))
    			}
    			existingProfiles[profile.SchedulerName] = i
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  8. src/slices/slices.go

    		}
    	}
    	if len(s1) < len(s2) {
    		return -1
    	}
    	return 0
    }
    
    // Index returns the index of the first occurrence of v in s,
    // or -1 if not present.
    func Index[S ~[]E, E comparable](s S, v E) int {
    	for i := range s {
    		if v == s[i] {
    			return i
    		}
    	}
    	return -1
    }
    
    // IndexFunc returns the first index i satisfying f(s[i]),
    // or -1 if none do.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 29 14:01:59 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common_test.go

    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	// Iterate through all the modTimes and count the FileInfo(s) with latest time.
    	for index, t := range modTimes {
    		if partsMetadata[index].IsValid() && t.Equal(modTime) {
    			latestFileInfo = partsMetadata[index]
    			count++
    		}
    	}
    
    	if !latestFileInfo.IsValid() {
    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	if count < latestFileInfo.Erasure.DataBlocks {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 23K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode_test.go

    			assertOnError: assertIdenticalError(&cbor.DupMapKeyError{Key: int64(-1), Index: 1}),
    		},
    		{
    			name:          "reject duplicate negative int keys into map",
    			in:            hex("a220012002"), // {-1: 1, -1: 2}
    			into:          map[int64]interface{}{},
    			assertOnError: assertIdenticalError(&cbor.DupMapKeyError{Key: int64(-1), Index: 1}),
    		},
    		{
    			name:          "reject duplicate positive int keys into struct",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 18:43:10 UTC 2024
    - 25.6K bytes
    - Viewed (0)
Back to top