- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,038 for contexts (0.04 sec)
-
src/test/java/jcifs/CIFSContextTest.java
verify(mockContext).withDefaultCredentials(); } @Test @DisplayName("Should get context with anonymous credentials") void testWithAnonymousCredentials() { // Given CIFSContext newContext = mock(CIFSContext.class); when(mockContext.withAnonymousCredentials()).thenReturn(newContext); // When CIFSContext context = mockContext.withAnonymousCredentials();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 8.8K bytes - Viewed (0) -
logger/slog.go
} func (l *slogLogger) Info(ctx context.Context, msg string, data ...interface{}) { if l.LogLevel >= Info { l.Logger.InfoContext(ctx, msg, slog.Any("data", data)) } } func (l *slogLogger) Warn(ctx context.Context, msg string, data ...interface{}) { if l.LogLevel >= Warn { l.Logger.WarnContext(ctx, msg, slog.Any("data", data)) } } func (l *slogLogger) Error(ctx context.Context, msg string, data ...interface{}) {
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Mon Jul 28 09:34:58 UTC 2025 - 2.3K bytes - Viewed (0) -
cmd/bucket-quota.go
bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (DataUsageInfo, error) { if objAPI == nil { return DataUsageInfo{}, errServerNotInitialized } ctx, done := context.WithTimeout(ctx, 2*time.Second) defer done() return loadDataUsageFromBackend(ctx, objAPI) }, ) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Aug 06 23:48:58 UTC 2025 - 4.4K bytes - Viewed (0) -
association.go
relValuesMap, _ := schema.GetIdentityFieldValuesMapFromValues(association.DB.Statement.Context, values, rel.FieldSchema.PrimaryFields) cleanUpDeletedRelations := func(data reflect.Value) { if _, zero := rel.Field.ValueOf(association.DB.Statement.Context, data); !zero { fieldValue := reflect.Indirect(rel.Field.ReflectValueOf(association.DB.Statement.Context, data)) primaryValues := make([]interface{}, len(rel.FieldSchema.PrimaryFields))
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 21.5K bytes - Viewed (0) -
cmd/auth-handler.go
_, _, s3Err = checkRequestAuthTypeCredential(ctx, r, action) return s3Err } func authenticateRequest(ctx context.Context, r *http.Request, action policy.Action) (s3Err APIErrorCode) { if logger.GetReqInfo(ctx) == nil { bugLogIf(ctx, errors.New("unexpected context.Context does not have a logger.ReqInfo"), logger.ErrorKind) return ErrAccessDenied } var cred auth.Credentials var owner bool switch getRequestAuthType(r) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
cmd/generic-handlers.go
} } sr, err := globalDNSConfig.Get(bucket) if err != nil { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) if err == dns.ErrNoEntriesFound { writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNoSuchBucket), r.URL) } else { writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.7K bytes - Viewed (1) -
cmd/metacache-server-pool.go
c = &resp } else { rctx, cancel := context.WithTimeout(ctx, 5*time.Second) c, err = rpc.GetMetacacheListing(rctx, *o) cancel() } if err != nil { if errors.Is(err, context.Canceled) { // Context is canceled, return at once. // request canceled, no entries to return return entries, io.EOF } if !IsErr(err, context.DeadlineExceeded, grid.ErrDisconnected) {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.9K bytes - Viewed (0) -
tests/associations_has_many_test.go
} var contents []ItemContent if err := tx.Find(&contents).Error; err != nil { t.Errorf("failed to find contents, got error: %v", err) } if len(contents) != 3 { t.Errorf("expected %d contents, got %d", 3, len(contents)) } // test delete if err := tx.Model(&item).Association("Contents").Unscoped().Delete(&contents[0]); err != nil { t.Errorf("failed to delete Contents, got error: %v", err) }
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 16K bytes - Viewed (0) -
src/main/java/jcifs/context/SingletonContext.java
} INSTANCE = new SingletonContext(p); } /** * Get singleton context * * The singleton context will use system properties for configuration as well as values specified in a file * specified through this <code>jcifs.properties</code> system property. * * @return a global context, initialized on first call */ public static synchronized final SingletonContext getInstance() {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.3K bytes - Viewed (0) -
cmd/lock-rest-server.go
} // RefreshHandler - refresh the current lock func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { // Add a timeout similar to what we expect upstream. ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall) defer cancel() resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(ctx, *args) if err != nil { return l.makeResp(resp, err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0)