Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,038 for contexts (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top