Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 657 for arrange (0.04 sec)

  1. cmd/erasure-metadata.go

    func objectPartIndex(parts []ObjectPartInfo, partNumber int) int {
    	for i, part := range parts {
    		if partNumber == part.Number {
    			return i
    		}
    	}
    	return -1
    }
    
    // objectPartIndexNums returns the index of the specified part number.
    // Returns -1 if the part cannot be found.
    func objectPartIndexNums(parts []int, partNumber int) int {
    	for i, part := range parts {
    		if part != 0 && partNumber == part {
    			return i
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  2. cmd/iam-object-store.go

    	}
    	m[policy] = p
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    	for item := range listIAMConfigItems(ctx, iamOS.objAPI, iamConfigPoliciesPrefix) {
    		if item.Err != nil {
    			return item.Err
    		}
    
    		policyName := path.Dir(item.Item)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  3. cmd/erasure-decode_test.go

    		}
    		if n != test.data {
    			t.Fatalf("Test %d: failed to create erasure test file", i)
    		}
    		for i, w := range writers {
    			if w == nil {
    				disks[i] = nil
    			}
    		}
    
    		// Get the checksums of the current part.
    		bitrotReaders := make([]io.ReaderAt, len(disks))
    		for index, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  4. cmd/metacache-bucket.go

    			})
    			// Keep first metacacheMaxEntries...
    			for _, cache := range remainCaches[metacacheMaxEntries:] {
    				if time.Since(cache.lastHandout) > metacacheMaxClientWait {
    					remove[cache.id] = struct{}{}
    				}
    			}
    		}
    	}
    
    	for id := range remove {
    		b.deleteCache(id)
    	}
    }
    
    // updateCacheEntry will update a cache.
    // Returns the updated status.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    		return errInvalidArgument
    	}
    
    	nv := make(textproto.MIMEHeader, len(v))
    	for k, kv := range v {
    		// Canonicalize all headers, to remove any duplicates.
    		nv[http.CanonicalHeaderKey(k)] = kv
    	}
    
    	// Save all supported headers.
    	for _, supportedHeader := range supportedHeaders {
    		value, ok := nv[http.CanonicalHeaderKey(supportedHeader)]
    		if ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  6. cmd/local-locker_gen.go

    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0006, zb0007 := range z {
    		err = en.WriteString(zb0006)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		err = en.WriteArrayHeader(uint32(len(zb0007)))
    		if err != nil {
    			err = msgp.WrapError(err, zb0006)
    			return
    		}
    		for zb0008 := range zb0007 {
    			err = zb0007[zb0008].EncodeMsg(en)
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 31 19:54:34 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  7. cmd/global-heal.go

    	indexed := make(map[string][]madmin.Disk)
    	for _, disk := range si.Disks {
    		setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex)
    		indexed[setIdx] = append(indexed[setIdx], disk)
    	}
    
    	for id, disks := range indexed {
    		ss := madmin.SetStatus{
    			ID:        id,
    			SetIndex:  disks[0].SetIndex,
    			PoolIndex: disks[0].PoolIndex,
    		}
    		for _, disk := range disks {
    			ss.Disks = append(ss.Disks, disk)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  8. cmd/storage-rest_test.go

    func testStorageAPIDiskInfo(t *testing.T, storage StorageAPI) {
    	testCases := []struct {
    		expectErr bool
    	}{
    		{true},
    	}
    
    	for i, testCase := range testCases {
    		_, err := storage.DiskInfo(t.Context(), DiskInfoOptions{Metrics: true})
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/BoundType.java

     * the License.
     */
    
    package com.google.common.collect;
    
    import com.google.common.annotations.GwtCompatible;
    
    /**
     * Indicates whether an endpoint of some range is contained in the range itself ("closed") or not
     * ("open"). If a range is unbounded on a side, it is neither open nor closed on that side; the
     * bound simply does not exist.
     *
     * @since 10.0
     */
    @GwtCompatible
    public enum BoundType {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/toolchain/RequirementMatcherFactory.java

            @Override
            public boolean matches(String requirement) {
                try {
                    VersionRange range = VersionRange.createFromVersionSpec(requirement);
                    if (range.hasRestrictions()) {
                        return range.containsVersion(version);
                    } else {
                        return range.getRecommendedVersion().compareTo(version) == 0;
                    }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Feb 12 13:13:28 UTC 2025
    - 2.7K bytes
    - Viewed (0)
Back to top