Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 605 for Lange (0.18 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 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 Apr 21 19:28:08 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  5. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  6. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  7. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  8. cmd/bootstrap-peer-server.go

    	}
    
    	for i, cmdLine := range s1.CmdLines {
    		if cmdLine != s2.CmdLines[i] {
    			return fmt.Errorf("Expected command line argument %s, seen %s", cmdLine,
    				s2.CmdLines[i])
    		}
    	}
    
    	if reflect.DeepEqual(s1.MinioEnv, s2.MinioEnv) {
    		return nil
    	}
    
    	// Report differences in environment variables.
    	var missing []string
    	var mismatching []string
    	for k, v := range s1.MinioEnv {
    		ev, ok := s2.MinioEnv[k]
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  9. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  10. cmd/httprange_test.go

    		"bytes=+3-+5",
    		"bytes=10-11,12-10", // Unsupported by S3/MinIO (valid in RFC)
    	}
    	for i, urs := range unparsableRangeSpecs {
    		rs, err := parseRequestRangeSpec(urs)
    		if err == nil {
    			t.Errorf("Case %d: Did not get an expected error - got %v", i, rs)
    		}
    		if err == errInvalidRange {
    			t.Errorf("Case %d: Got invalid range error instead of a parse error", i)
    		}
    		if rs != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 08 21:58:55 GMT 2022
    - 3.7K bytes
    - Viewed (0)
Back to top