Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 501 for Lange (0.2 sec)

  1. cmd/erasure-server-pool.go

    func (z *erasureServerPools) GetDisksID(ids ...string) []StorageAPI {
    	idMap := make(map[string]struct{})
    	for _, id := range ids {
    		idMap[id] = struct{}{}
    	}
    	res := make([]StorageAPI, 0, len(idMap))
    	for _, s := range z.serverPools {
    		for _, set := range s.sets {
    			for _, disk := range set.getDisks() {
    				if disk == OfflineDisk {
    					continue
    				}
    				if id, _ := disk.GetDiskID(); id != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/erasure-common.go

    	resps := make([]chan ReadMultipleResp, len(disks))
    	for i := range resps {
    		resps[i] = make(chan ReadMultipleResp, len(req.Files))
    	}
    	g := errgroup.WithNErrs(len(disks))
    	// Read files in parallel across disks.
    	for index := range disks {
    		index := index
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  3. internal/logger/targets.go

    	cnt := make(map[string]int, len(sys)+len(audit))
    
    	// Add system and audit.
    	for _, t := range sys {
    		key := strings.ToLower(t.Type().String())
    		n := cnt[key]
    		cnt[key]++
    		key = fmt.Sprintf("sys_%s_%d", key, n)
    		res[key] = t.Stats()
    	}
    
    	for _, t := range audit {
    		key := strings.ToLower(t.Type().String())
    		n := cnt[key]
    		cnt[key]++
    		key = fmt.Sprintf("audit_%s_%d", key, n)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  4. internal/s3select/sql/parser_test.go

    		`"abc"`,
    		`"abc\a""ac"`,
    	}
    	for i, tc := range validCases {
    		err := p.ParseString(tc, &id)
    		if err != nil {
    			t.Fatalf("%d: %v", i, err)
    		}
    		// repr.Println(id, repr.Indent("  "), repr.OmitEmpty(true))
    	}
    
    	invalidCases := []string{
    		"+a",
    		"-a",
    		"1a",
    		`"ab`,
    		`abc"`,
    		`aa""a`,
    		`"a"a"`,
    	}
    	for i, tc := range invalidCases {
    		err := p.ParseString(tc, &id)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    			if disk == nil {
    				for i := range objects {
    					delObjErrs[index][i] = errDiskNotFound
    				}
    				return
    			}
    			errs := disk.DeleteVersions(ctx, bucket, dedupVersions, DeleteOptions{})
    			for i, err := range errs {
    				if err == nil {
    					continue
    				}
    				for _, v := range dedupVersions[i].Versions {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  6. internal/event/rules.go

    func (rules Rules) MatchSimple(objectName string) bool {
    	for pattern := range rules {
    		if wildcard.MatchSimple(pattern, objectName) {
    			return true
    		}
    	}
    	return false
    }
    
    // Match - returns TargetIDSet matching object name in rules.
    func (rules Rules) Match(objectName string) TargetIDSet {
    	targetIDs := NewTargetIDSet()
    
    	for pattern, targetIDSet := range rules {
    		if wildcard.MatchSimple(pattern, objectName) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  7. internal/grid/types.go

    		return msgp.NilSize
    	}
    	s := msgp.MapHeaderSize
    	for za0001, za0002 := range *m {
    		s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    	}
    	return s
    }
    
    // NewMSS returns a new MSS.
    func NewMSS() *MSS {
    	m := MSS(mssPool.Get().(map[string]string))
    	for k := range m {
    		delete(m, k)
    	}
    	return &m
    }
    
    // NewMSSWith returns a new MSS with the given map.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  8. internal/config/lambda/event/targetlist.go

    	keys := make([]ARN, 0, len(list.targets))
    	for k := range list.targets {
    		keys = append(keys, k.ToARN(region))
    	}
    
    	return keys
    }
    
    // TargetMap - returns available targets.
    func (list *TargetList) TargetMap() map[TargetID]Target {
    	list.RLock()
    	defer list.RUnlock()
    
    	ntargets := make(map[TargetID]Target, len(list.targets))
    	for k, v := range list.targets {
    		ntargets[k] = v
    	}
    	return ntargets
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2_gen.go

    	for za0004 := range z.PartNumbers {
    		o = msgp.AppendInt(o, z.PartNumbers[za0004])
    	}
    	// string "PartETags"
    	o = append(o, 0xa9, 0x50, 0x61, 0x72, 0x74, 0x45, 0x54, 0x61, 0x67, 0x73)
    	if z.PartETags == nil { // allownil: if nil
    		o = msgp.AppendNil(o)
    	} else {
    		o = msgp.AppendArrayHeader(o, uint32(len(z.PartETags)))
    		for za0005 := range z.PartETags {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  10. cmd/bucket-targets.go

    			for _, ep := range sys.hc {
    				eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme})
    			}
    			sys.hMutex.RUnlock()
    
    			if len(eps) > 0 {
    				cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
    				m := make(map[string]epHealth, len(eps))
    				start := time.Now()
    
    				for result := range sys.hcClient.Alive(cctx, madmin.AliveOpts{}, eps...) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
Back to top