- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 2,671 for errorf (1.23 sec)
-
cmd/xl-storage-free-version.go
return false } // AddFreeVersion adds a free-version if needed for fi.VersionID version. // Free-version will be added if fi.VersionID has transitioned. func (x *xlMetaV2) AddFreeVersion(fi FileInfo) error { var uv uuid.UUID var err error switch fi.VersionID { case "", nullVersionID: default: uv, err = uuid.Parse(fi.VersionID) if err != nil { return err } } for i, version := range x.versions {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Mar 02 05:11:03 UTC 2024 - 3.4K bytes - Viewed (0) -
internal/bucket/lifecycle/filter_test.go
"testing" "github.com/dustin/go-humanize" ) // TestUnsupportedFilters checks if parsing Filter xml with // unsupported elements returns appropriate errors func TestUnsupportedFilters(t *testing.T) { testCases := []struct { inputXML string expectedErr error }{ { // Filter with And tags inputXML: ` <Filter> <And> <Prefix>key-prefix</Prefix> </And> </Filter>`,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 27 00:01:20 UTC 2024 - 7.2K bytes - Viewed (0) -
clause/joins_test.go
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Thu Nov 03 13:03:13 UTC 2022 - 2.6K bytes - Viewed (0) -
internal/bucket/lifecycle/evaluator.go
} return events } // Eval will return a lifecycle event for each object in objs func (e *Evaluator) Eval(objs []ObjectOpts) ([]Event, error) { if len(objs) == 0 { return nil, nil } if len(objs) != objs[0].NumVersions { return nil, fmt.Errorf("number of versions mismatch, expected %d, got %d", objs[0].NumVersions, len(objs)) } return e.eval(objs, time.Now().UTC()), nil
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Apr 08 15:41:24 UTC 2025 - 4.6K bytes - Viewed (0) -
cmd/peer-s3-client.go
HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error GetHost() string SetPools([]int) GetPools() []int }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/metacache-server-pool.go
return entries, nil } } else { err = fmt.Errorf("invalid pool/set") o.pool, o.set = 0, 0 } } if IsErr(err, []error{ nil, context.Canceled, context.DeadlineExceeded, // io.EOF is expected and should be returned but no need to log it. io.EOF, }...) { // Expected good errors we don't need to return error. return entries, err } entries.truncate(0)Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 12.9K bytes - Viewed (0) -
internal/config/etcd/etcd.go
} func parseEndpoints(endpoints string) ([]string, bool, error) { etcdEndpoints := strings.Split(endpoints, config.ValueSeparator) var etcdSecure bool for _, endpoint := range etcdEndpoints { u, err := xnet.ParseHTTPURL(endpoint) if err != nil { return nil, false, err } if etcdSecure && u.Scheme == "http" { return nil, false, config.Errorf("all endpoints should be https or http: %s", endpoint) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 16 14:27:42 UTC 2025 - 5.2K bytes - Viewed (0) -
internal/store/batch_test.go
CommitTimeout: 5 * time.Minute, Log: func(ctx context.Context, err error, id string, errKind ...any) { t.Log(err) }, }) defer batch.Close() var wg sync.WaitGroup for i := 0; i < int(limit); i++ { wg.Add(1) go func(key int) { defer wg.Done() if err := batch.Add(testItem); err != nil { t.Errorf("failed to add item %v; %v", key, err) return } }(i) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.6K bytes - Viewed (0) -
cmd/http-tracer_test.go
_ = stats.Load(false) } }(i) } wg.Wait() finalStats := stats.Load(false) expected := numGoroutines * opsPerGoroutine actual := finalStats["TestAPI"] if actual != expected { t.Errorf("Race condition detected: expected %d, got %d (lost %d increments)", expected, actual, expected-actual) } } // TestBucketHTTPStatsRaceCondition tests concurrent access to bucket-level HTTP stats.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.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 } var usz uint64
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 26.1K bytes - Viewed (0)