Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for withValues (0.25 sec)

  1. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		return
    	}
    
    	tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    	ctx = context.WithValue(ctx, config.ContextKeyForTargetFromConfig, tgts)
    	if verr := validateConfig(ctx, result.Cfg, result.SubSys); verr != nil {
    		err = badConfigErr{Err: verr}
    		return
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. src/crypto/tls/quic_test.go

    		t.Fatalf("error during connection handshake: %v", err)
    	}
    }
    
    func TestQUICStartContextPropagation(t *testing.T) {
    	const key = "key"
    	const value = "value"
    	ctx := context.WithValue(context.Background(), key, value)
    	config := testConfig.Clone()
    	config.MinVersion = VersionTLS13
    	calls := 0
    	config.GetConfigForClient = func(info *ClientHelloInfo) (*Config, error) {
    		calls++
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 17:23:54 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  3. src/cmd/go/internal/cfg/cfg.go

    	return ""
    }
    
    // WithBuildXWriter returns a Context in which BuildX output is written
    // to given io.Writer.
    func WithBuildXWriter(ctx context.Context, xLog io.Writer) context.Context {
    	return context.WithValue(ctx, buildXContextKey{}, xLog)
    }
    
    type buildXContextKey struct{}
    
    // BuildXWriter returns nil if BuildX is false, or
    // the writer to which BuildX output should be written otherwise.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 17:13:51 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  4. src/net/lookup_test.go

    	keyValues := []struct {
    		key, value any
    	}{
    		{"key-1", 12},
    		{384, "value2"},
    		{new(float64), 137},
    	}
    	ctx := context.Background()
    	for _, kv := range keyValues {
    		ctx = context.WithValue(ctx, kv.key, kv.value)
    	}
    
    	wantIPs := []IPAddr{
    		{IP: IPv4(127, 0, 0, 1)},
    		{IP: IPv6loopback},
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  5. src/log/slog/logger_test.go

    		{l.ErrorContext, LevelError},
    		{DebugContext, LevelDebug},
    		{InfoContext, LevelInfo},
    		{WarnContext, LevelWarn},
    		{ErrorContext, LevelError},
    	} {
    		h.clear()
    		ctx := context.WithValue(context.Background(), "L", test.wantLevel)
    
    		test.f(ctx, "msg")
    		if gv := h.ctx.Value("L"); gv != test.wantLevel || h.r.Level != test.wantLevel {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 10 21:25:30 UTC 2023
    - 19.5K bytes
    - Viewed (0)
  6. src/net/dial.go

    	resolveCtx := ctx
    	if trace, _ := ctx.Value(nettrace.TraceKey{}).(*nettrace.Trace); trace != nil {
    		shadow := *trace
    		shadow.ConnectStart = nil
    		shadow.ConnectDone = nil
    		resolveCtx = context.WithValue(resolveCtx, nettrace.TraceKey{}, &shadow)
    	}
    
    	addrs, err := d.resolver().resolveAddrList(resolveCtx, "dial", network, address, d.LocalAddr)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  7. src/net/dial_test.go

    					id = ctx.Value("id").(int)
    					return controlOnConnSetup(network, address, c)
    				}}
    				c, err := d.DialContext(context.WithValue(context.Background(), "id", i+1), network, ln.Addr().String())
    				if err != nil {
    					t.Fatal(err)
    				}
    				if id != i+1 {
    					t.Errorf("got id %d, want %d", id, i+1)
    				}
    				c.Close()
    			})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
  8. cmd/xl-storage-disk-id-check.go

    		return ctx, done, nil
    	}
    
    	if contextCanceled(ctx) {
    		return ctx, done, ctx.Err()
    	}
    
    	atomic.StoreInt64(&p.health.lastStarted, time.Now().UnixNano())
    	p.health.waiting.Add(1)
    
    	ctx = context.WithValue(ctx, healthDiskCtxKey{}, &healthDiskCtxValue{lastSuccess: &p.health.lastSuccess})
    	si := p.updateStorageMetrics(s, paths...)
    	var once sync.Once
    	return ctx, func(sz int64, errp *error) {
    		p.health.waiting.Add(-1)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
Back to top