- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 453 for ctx_ (0.04 sec)
-
cmd/admin-handlers.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } err = verifyBinary(u, sha256Sum, releaseInfo, mode, bytes.NewReader(bin)) if err != nil { adminLogIf(ctx, fmt.Errorf("server update failed with %w", err)) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
} if !c.chainedCNIPlugin { // Standalone CNI plugin parent := context.Background() ctx1, cancel := context.WithTimeout(parent, 100*time.Millisecond) defer cancel() result, err := getCNIConfigFilepath(ctx1, c.specifiedConfName, tempDir, c.chainedCNIPlugin) if err != nil { assert.Equal(t, result, "") if err == context.DeadlineExceeded {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 18:38:14 UTC 2024 - 15.3K bytes - Viewed (0) -
src/cmd/asm/main.go
} ctxt := obj.Linknew(architecture.LinkArch) ctxt.Debugasm = flags.PrintOut ctxt.Debugvlog = flags.DebugV ctxt.Flag_dynlink = *flags.Dynlink ctxt.Flag_linkshared = *flags.Linkshared ctxt.Flag_shared = *flags.Shared || *flags.Dynlink ctxt.Flag_maymorestack = flags.DebugFlags.MayMoreStack ctxt.Debugpcln = flags.DebugFlags.PCTab ctxt.IsAsm = true ctxt.Pkgpath = *flags.Importpath
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Jun 21 19:58:04 UTC 2024 - 2.9K bytes - Viewed (0) -
src/cmd/asm/internal/asm/endtoend_test.go
architecture, ctxt := setArch(goarch) architecture.Init(ctxt) lexer := lex.NewLexer(input) parser := NewParser(ctxt, architecture, lexer) pList := new(obj.Plist) var ok bool testOut = new(strings.Builder) // The assembler writes test output to this buffer. ctxt.Bso = bufio.NewWriter(os.Stdout) ctxt.IsAsm = true defer ctxt.Bso.Flush() failed := false
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Dec 07 18:42:59 UTC 2023 - 11.6K bytes - Viewed (0) -
cmd/logging.go
logger.LogOnceIf(ctx, "iam", err, id, errKind...) } func iamLogIf(ctx context.Context, err error, errKind ...interface{}) { if !errors.Is(err, grid.ErrDisconnected) { logger.LogIf(ctx, "iam", err, errKind...) } } func iamLogEvent(ctx context.Context, msg string, args ...interface{}) { logger.Event(ctx, "iam", msg, args...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 18:49:48 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/admin-handlers-users.go
if globalIAMSys.LDAPConfig.Enabled() { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errIAMActionNotAllowed), r.URL) return } updatedAt, err := globalIAMSys.CreateUser(ctx, accessKey, ureq) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{ Type: madmin.SRIAMItemIAMUser,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 03 23:11:02 UTC 2024 - 85.1K bytes - Viewed (0) -
cmd/tier-handlers.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err := globalTierConfigMgr.Remove(ctx, tier, force); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err := globalTierConfigMgr.Save(ctx, objAPI); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } bucketLifecycle, err := lifecycle.ParseLifecycleConfigWithID(io.LimitReader(r.Body, r.ContentLength)) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Validate the received bucket policy document if err = bucketLifecycle.Validate(rcfg); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7K bytes - Viewed (0) -
cmd/dummy-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Validate if bucket exists, before proceeding further... _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 15:25:16 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/kms-handlers.go
ctx := newContext(r, w, "KMSMetrics") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) objectAPI, _ := validateAdminReq(ctx, w, r, policy.KMSMetricsAction) if objectAPI == nil { return } if GlobalKMS == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrKMSNotConfigured), r.URL) return } metrics, err := GlobalKMS.Metrics(ctx) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 10.1K bytes - Viewed (0)