Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 390 for ctx (0.03 sec)

  1. src/test/java/jcifs/smb/SSPContextTest.java

            private void useContext(SSPContext ctx) throws Exception {
                ctx.getSigningKey();
                ctx.isEstablished();
                ctx.initSecContext(new byte[] { 1, 2, 3 }, 1, 1);
                ctx.getNetbiosName();
                ctx.isSupported(new ASN1ObjectIdentifier("1.2.3"));
                ctx.isPreferredMech(new ASN1ObjectIdentifier("1.2.3"));
                ctx.getFlags();
                ctx.getSupportedMechs();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.2K bytes
    - Viewed (0)
  2. logger/slog.go

    }
    
    func (l *slogLogger) Info(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Info {
    		l.log(ctx, slog.LevelInfo, msg, slog.Any("data", data))
    	}
    }
    
    func (l *slogLogger) Warn(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Warn {
    		l.log(ctx, slog.LevelWarn, msg, slog.Any("data", data))
    	}
    }
    
    func (l *slogLogger) Error(ctx context.Context, msg string, data ...interface{}) {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Oct 30 10:56:26 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    		default:
    			writeErrorResponseJSON(ctx, w, toAPIError(ctx, errors.New("job ID format unrecognized")), r.URL)
    			return
    		}
    	}
    
    	ri := &batchJobInfo{}
    	if err := ri.load(ctx, objectAPI, req); err != nil {
    		if !errors.Is(err, errNoSuchJob) {
    			batchLogIf(ctx, err)
    		}
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (1)
  4. cmd/iam-object-store.go

    }
    
    func (iamOS *IAMObjectStore) loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error {
    	p, err := iamOS.loadPolicy(ctx, policy)
    	if err != nil {
    		return err
    	}
    	m[policy] = p
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    	client.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (info DiskInfo, err error) {
    			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			defer cancel()
    
    			nopts := DiskInfoOptions{DiskID: *client.diskID.Load(), Metrics: true}
    			infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &nopts)
    			if err != nil {
    				return info, toStorageErr(err)
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/SpnegoContextTest.java

            ctx.setMechs(updated);
            assertArrayEquals(updated, ctx.getMechs());
        }
    
        @Test
        @DisplayName("toString includes wrapped mechanism context")
        void testToString() {
            SpnegoContext ctx = newContext();
            when(this.mechContext.toString()).thenReturn("MECHCTX");
            assertEquals("SPNEGO[MECHCTX]", ctx.toString());
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  7. tests/generics_test.go

    	if err != nil {
    		t.Fatalf("Count failed: %v", err)
    	}
    }
    
    func TestGenericsUpdate(t *testing.T) {
    	ctx := context.Background()
    
    	// Just test that the API can be called
    	_, err := gorm.G[User](DB).Where("id = ?", 1).Update(ctx, "name", "test")
    	if err != nil {
    		t.Fatalf("Update failed: %v", err)
    	}
    }
    
    func TestGenericsUpdates(t *testing.T) {
    	ctx := context.Background()
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun Nov 02 14:09:18 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  8. tests/tracer_test.go

    }
    
    func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) {
    	S.Logger.Error(ctx, s, i...)
    }
    
    func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
    	S.Logger.Trace(ctx, begin, fc, err)
    	S.Test(ctx, begin, fc, err)
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Tue Oct 18 09:28:06 UTC 2022
    - 830 bytes
    - Viewed (0)
  9. internal/grid/muxserver.go

    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if msg.DeadlineMS > 0 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    	m := muxServer{
    		ID:        msg.MuxID,
    		RecvSeq:   msg.Seq + 1,
    		SendSeq:   msg.Seq,
    		ctx:       ctx,
    		cancel:    cancel,
    		parent:    c,
    		LastPing:  time.Now().Unix(),
    		BaseFlags: c.baseFlags,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  10. cmd/object-api-input-checks.go

    )
    
    // Checks on CopyObject arguments, bucket and object.
    func checkCopyObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on GetObject arguments, bucket and object.
    func checkGetObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on DeleteObject arguments, bucket and object.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top