Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 111 for race (0.04 sec)

  1. src/go/types/resolver.go

    						// do not import them!
    						if token.IsExported(name) {
    							// declare dot-imported object
    							// (Do not use check.declare because it modifies the object
    							// via Object.setScopePos, which leads to a race condition;
    							// the object may be imported into more than one file scope
    							// concurrently. See go.dev/issue/32154.)
    							if alt := fileScope.Lookup(name); alt != nil {
    								err := check.newError(DuplicateDecl)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 16:22:59 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. src/go/types/issues_test.go

    // underlying type of b.T (which is the underlying type of a.T, which is int)
    // we must not set the underlying type of a.T again since that would lead to
    // a race condition if package b is imported elsewhere, in a package that is
    // concurrently type-checked.
    func TestIssue34921(t *testing.T) {
    	defer func() {
    		if r := recover(); r != nil {
    			t.Error(r)
    		}
    	}()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_node_status.go

    	unschedulableTaint := v1.Taint{
    		Key:    v1.TaintNodeUnschedulable,
    		Effect: v1.TaintEffectNoSchedule,
    	}
    
    	// Taint node with TaintNodeUnschedulable when initializing
    	// node to avoid race condition; refer to #63897 for more detail.
    	if node.Spec.Unschedulable &&
    		!taintutil.TaintExists(nodeTaints, &unschedulableTaint) {
    		nodeTaints = append(nodeTaints, unschedulableTaint)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  4. src/net/smtp/smtp_test.go

    	bcmdbuf := bufio.NewWriter(&cmdbuf)
    	l, err := net.Listen("tcp", "127.0.0.1:0")
    	if err != nil {
    		t.Fatalf("Unable to create listener: %v", err)
    	}
    	defer l.Close()
    
    	// prevent data race on bcmdbuf
    	var done = make(chan struct{})
    	go func(data []string) {
    
    		defer close(done)
    
    		conn, err := l.Accept()
    		if err != nil {
    			t.Errorf("Accept error: %v", err)
    			return
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  5. tools/istio-iptables/pkg/capture/run.go

    }
    
    // addConntrackZoneDNSUDP is a helper function to add iptables rules to split DNS traffic
    // in two separate conntrack zones to avoid issues with UDP conntrack race conditions.
    // Traffic that goes from istio to DNS servers and vice versa are zone 1 and traffic from
    // DNS client to istio and vice versa goes to zone 2
    func addConntrackZoneDNSUDP(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 03:53:23 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  6. pkg/kube/inject/inject_test.go

    			continue
    		}
    		cases = append(cases, testCase{in: f.Name(), want: want})
    	}
    
    	// Precompute injection settings. This may seem like a premature optimization, but due to the size of
    	// YAMLs, with -race this was taking >10min in some cases to generate!
    	if util.Refresh() {
    		cleanupOldFiles(t)
    		writeInjectionSettings(t, "default", nil, "")
    		for i, c := range cases {
    			if c.setFlags != nil || c.inFilePath != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/types2/call.go

    	assert(check != nil)
    	assert(len(targs) == typ.TypeParams().Len())
    
    	if check.conf.Trace {
    		check.trace(pos, "-- instantiating signature %s with %s", typ, targs)
    		check.indent++
    		defer func() {
    			check.indent--
    			check.trace(pos, "=> %s (under = %s)", res, res.Underlying())
    		}()
    	}
    
    	inst := check.instance(pos, typ, targs, nil, check.context()).(*Signature)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 31.5K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/serviceentry/controller.go

    	}
    	s.mutex.Unlock()
    	for _, svc := range allServices {
    		// shallow copy, copy `AutoAllocatedIPv4Address` and `AutoAllocatedIPv6Address`
    		// if return the pointer directly, there will be a race with `BuildNameTable`
    		// nolint: govet
    		shallowSvc := *svc
    		out = append(out, &shallowSvc)
    	}
    	return out
    }
    
    // GetService retrieves a service by host name if it exists.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/types2/issues_test.go

    // underlying type of b.T (which is the underlying type of a.T, which is int)
    // we must not set the underlying type of a.T again since that would lead to
    // a race condition if package b is imported elsewhere, in a package that is
    // concurrently type-checked.
    func TestIssue34921(t *testing.T) {
    	defer func() {
    		if r := recover(); r != nil {
    			t.Error(r)
    		}
    	}()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. src/go/types/call.go

    	assert(check != nil)
    	assert(len(targs) == typ.TypeParams().Len())
    
    	if check.conf._Trace {
    		check.trace(pos, "-- instantiating signature %s with %s", typ, targs)
    		check.indent++
    		defer func() {
    			check.indent--
    			check.trace(pos, "=> %s (under = %s)", res, res.Underlying())
    		}()
    	}
    
    	inst := check.instance(pos, typ, targs, nil, check.context()).(*Signature)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 33.5K bytes
    - Viewed (0)
Back to top