- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 60 for if (0.12 sec)
-
cmd/object-handlers.go
} } if reader != nil && proxy.Proxy && perr == nil { gr = reader } } } if reader == nil || !proxy.Proxy { // validate if the request indeed was authorized, if it wasn't we need to return "ErrAccessDenied" // instead of any namespace related error. if s3Error := authorizeRequest(ctx, r, policy.GetObjectAction); s3Error != ErrNone {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/erasure-object.go
} rw.Unlock() if err == nil && fi.InlineData() { break } } if err != nil { // We can only look for dangling if we received all the responses, if we did // not we simply ignore it, since we can't tell for sure if its dangling object. if totalResp == er.setDriveCount && shouldCheckForDangling(err, errs, bucket) {
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/erasure-server-pool.go
for _, pinfo := range poolObjInfos { // skip all objects from suspended pools if asked by the // caller. if opts.SkipDecommissioned && z.IsSuspended(pinfo.Index) { continue } // Skip object if it's from pools participating in a rebalance operation. if opts.SkipRebalancing && z.IsPoolRebalancing(pinfo.Index) { continue } if pinfo.Err == nil { // found a pool
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/bucket-targets.go
found := false for idx, t := range tgts { if t.Type == tgt.Type { if t.Arn == tgt.Arn { if !update { return BucketRemoteAlreadyExists{Bucket: t.TargetBucket} } newtgts[idx] = *tgt found = true continue } // fail if endpoint is already present in list of targets and not a matching ARN if t.Endpoint == tgt.Endpoint { return BucketRemoteAlreadyExists{Bucket: t.TargetBucket}
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/bucket/lifecycle/rule.go
func (r Rule) Validate() error { if err := r.validateID(); err != nil { return err } if err := r.validateStatus(); err != nil { return err } if err := r.validateExpiration(); err != nil { return err } if err := r.validateNoncurrentExpiration(); err != nil { return err } if err := r.validatePrefixAndFilter(); err != nil { return err } if err := r.validateTransition(); err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/object-api-errors.go
apiErr := ObjectExistsAsDirectory{} if len(params) >= 1 { apiErr.Bucket = params[0] } if len(params) >= 2 { apiErr.Object = decodeDirObject(params[1]) } return apiErr case errFileVersionNotFound.Error(): apiErr := VersionNotFound{} if len(params) >= 1 { apiErr.Bucket = params[0] } if len(params) >= 2 { apiErr.Object = decodeDirObject(params[1]) } if len(params) >= 3 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
internal/logger/console.go
// Strip escape control characters from json message msg = ansiRE.ReplaceAllLiteralString(msg, "") console.json(msg, args...) case quietFlag: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" } console.quiet(msg+"\n", args...) default: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" } console.pretty(msg+"\n", args...) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/signals.go
// If global profiler is set stop before we exit. globalProfilerMu.Lock() defer globalProfilerMu.Unlock() for _, p := range globalProfiler { p.Stop() } if success { os.Exit(0) } os.Exit(1) } stopProcess := func() bool { // send signal to various go-routines that they need to quit. cancelGlobalContext() if httpServer := newHTTPServerFn(); httpServer != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/httprange_test.go
rs, err := parseRequestRangeSpec(testCase.spec) if err != nil { if !testCase.errExpected || err == nil && testCase.errExpected { t.Errorf("unexpected err: %v", err) } continue } h, err := rs.ToHeader() if err != nil && !testCase.errExpected || err == nil && testCase.errExpected { t.Errorf("expected error with invalid range: %v", err) } if h != testCase.spec {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 3.7K bytes - Viewed (0) -
cmd/data-scanner_test.go
NewerNoncurrentVersions: 1, }, }, }, } lcXML, err := xml.Marshal(lc) if err != nil { t.Fatalf("Failed to marshal lifecycle config: %v", err) } vcfg := versioning.Versioning{ Status: "Enabled", } vcfgXML, err := xml.Marshal(vcfg) if err != nil { t.Fatalf("Failed to marshal versioning config: %v", err) } bucket := "bucket" obj := "obj-1"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0)