Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 970 for mange (0.02 sec)

  1. cmd/bucket-replication-stats.go

    		tq                                  InQueueMetric
    	)
    	for _, bucketStat := range bucketStats {
    		totReplicaSize += bucketStat.ReplicationStats.ReplicaSize
    		totReplicaCount += bucketStat.ReplicationStats.ReplicaCount
    		for _, q := range bucketStat.QueueStats.Nodes {
    			tq = tq.merge(q.QStats)
    		}
    
    		for arn, stat := range bucketStat.ReplicationStats.Stats {
    			oldst := stats[arn]
    			if oldst == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/services/VersionRangeResolver.java

        /**
         * Expands a version range to a list of matching versions, in ascending order.
         * For example, resolves "[3.8,4.0)" to "3.8", "3.8.1", "3.8.2".
         * The returned list of versions is only dependent on the configured repositories and their contents.
         * The supplied request may also refer to a single concrete version rather than a version range.
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Sep 12 06:19:14 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/arch/arch.go

    	}
    
    	instructions := make(map[string]obj.As)
    	for i, s := range obj.Anames {
    		instructions[s] = obj.As(i)
    	}
    	for i, s := range ppc64.Anames {
    		if obj.As(i) >= obj.A_ARCHSPECIFIC {
    			instructions[s] = obj.As(i) + obj.ABasePPC64
    		}
    	}
    	// The opcodes generated by x/arch's ppc64map are listed in
    	// a separate slice, add them too.
    	for i, s := range ppc64.GenAnames {
    		instructions[s] = obj.As(i) + ppc64.AFIRSTGEN
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Nov 07 02:20:14 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  7. utils/utils_test.go

    package utils
    
    import (
    	"database/sql"
    	"database/sql/driver"
    	"errors"
    	"math"
    	"strings"
    	"testing"
    	"time"
    )
    
    func TestIsValidDBNameChar(t *testing.T) {
    	for _, db := range []string{"db", "dbName", "db_name", "db1", "1dbname", "db$name"} {
    		if fields := strings.FieldsFunc(db, IsValidDBNameChar); len(fields) != 1 {
    			t.Fatalf("failed to parse db name %v", db)
    		}
    	}
    }
    
    func TestCheckTruth(t *testing.T) {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. 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)
  9. cmd/xl-storage-meta-inline.go

    		return
    	}
    	if plSize <= 0 {
    		plSize = 1 + msgp.MapHeaderSize
    		for i := range keys {
    			plSize += len(keys[i]) + len(vals[i]) + msgp.StringPrefixSize + msgp.ArrayHeaderSize
    		}
    	}
    	payload := make([]byte, 1, plSize)
    	payload[0] = xlMetaInlineDataVer
    	payload = msgp.AppendMapHeader(payload, uint32(len(keys)))
    	for i := range keys {
    		payload = msgp.AppendStringFromBytes(payload, keys[i])
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  10. 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)
Back to top