- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 411 for range (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
cmd/data-usage-cache_gen.go
o = append(o, 0xa3, 0x73, 0x7a, 0x73) o = msgp.AppendArrayHeader(o, uint32(dataUsageBucketLen)) for za0001 := range z.ObjSizes { o = msgp.AppendUint64(o, z.ObjSizes[za0001]) } // string "vh" o = append(o, 0xa2, 0x76, 0x68) o = msgp.AppendArrayHeader(o, uint32(dataUsageVersionLen)) for za0002 := range z.ObjVersions { o = msgp.AppendUint64(o, z.ObjVersions[za0002]) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0)