- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 498 for Franke (0.2 sec)
-
cmd/copy-part-range.go
func parseCopyPartRangeSpec(rangeString string) (hrange *HTTPRangeSpec, err error) { hrange, err = parseRequestRangeSpec(rangeString) if err != nil { return nil, err } if hrange.IsSuffixLength || hrange.Start < 0 || hrange.End < 0 { return nil, errInvalidRange } return hrange, nil } // checkCopyPartRangeWithSize adds more check to the range string in case of
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 2.5K bytes - Viewed (0) -
cmd/httprange.go
if start < 0 { start = 0 } } return start, length, nil } // Parse a HTTP range header value into a HTTPRangeSpec func parseRequestRangeSpec(rangeString string) (hrange *HTTPRangeSpec, err error) { // Return error if given range string doesn't start with byte range prefix. if !strings.HasPrefix(rangeString, byteRangePrefix) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 24 14:56:28 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/endpoint.go
// Add add pool endpoints func (l *EndpointServerPools) Add(zeps PoolEndpoints) error { existSet := set.NewStringSet() for _, zep := range *l { for _, ep := range zep.Endpoints { existSet.Add(ep.String()) } } // Validate if there are duplicate endpoints across serverPools for _, ep := range zeps.Endpoints { if existSet.Contains(ep.String()) { return fmt.Errorf("duplicate endpoints found") } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/config-migrate.go
compress.SetCompressionConfig(newCfg, cfg.Compression) for k, args := range cfg.Notify.AMQP { notify.SetNotifyAMQP(newCfg, k, args) } for k, args := range cfg.Notify.Elasticsearch { notify.SetNotifyES(newCfg, k, args) } for k, args := range cfg.Notify.Kafka { notify.SetNotifyKafka(newCfg, k, args) } for k, args := range cfg.Notify.MQTT { notify.SetNotifyMQTT(newCfg, k, args) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/batch-job-common-types_test.go
}, { // 11MiB > 10 MiB -> out of range from right objSize: 11 << 20, sizeFilter: BatchJobSizeFilter{ UpperBound: 10 << 20, LowerBound: 1 << 20, }, want: false, }, { // 2MiB < 10MiB -> in range objSize: 2 << 20, sizeFilter: BatchJobSizeFilter{ UpperBound: 10 << 20, }, want: true, }, { // 2MiB > 1MiB -> in range objSize: 2 << 20,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 08 23:22:28 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/local-locker_test.go
// Expire 50% toUnLock := make([]dsync.LockArgs, 0, locks*readers) for k, v := range l.lockMap { for _, lock := range v { if rng.Intn(2) == 0 { toUnLock = append(toUnLock, dsync.LockArgs{Resources: []string{k}, UID: lock.UID}) } } } start := time.Now() for _, lock := range toUnLock { ok, err := l.ForceUnlock(context.Background(), lock)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0) -
cmd/peer-s3-server.go
return nil, err } } for _, v := range healBuckets { bi := BucketInfo{ Name: v.Name, Created: v.Created, } if vi, ok := deletedBuckets[v.Name]; ok { bi.Deleted = vi.Created } buckets = append(buckets, bi) } for _, v := range deletedBuckets { if _, ok := healBuckets[v.Name]; !ok { buckets = append(buckets, BucketInfo{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
for _, versions := range diskVersions { if len(versions) > 0 { diskVersionsCount[binary.BigEndian.Uint64(versions)]++ } } var commonVersions uint64 max := 0 for versions, count := range diskVersionsCount { if max < count { max = count commonVersions = versions } } if max >= writeQuorum { for _, versions := range diskVersions {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
// parse size from content-range header func parseSizeFromContentRange(h http.Header) (sz int64, err error) { cr := h.Get(xhttp.ContentRange) if cr == "" { return sz, fmt.Errorf("Content-Range not set") } parts := contentRangeRegexp.FindStringSubmatch(cr) if len(parts) != 4 { return sz, fmt.Errorf("invalid Content-Range header %s", cr) } if parts[3] == "*" { return -1, nil
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
cmd/metrics-v3-api.go
for name, value := range httpStats.CurrentS3Requests.APIStats { m.Set(apiRequestsInFlightTotal, float64(value), "name", name, "type", "s3") } for name, value := range httpStats.TotalS3Requests.APIStats { m.Set(apiRequestsTotal, float64(value), "name", name, "type", "s3") } for name, value := range httpStats.TotalS3Errors.APIStats {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 9.2K bytes - Viewed (0)