Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 320 for race (1.32 sec)

  1. tensorflow/c/kernels_experimental.cc

                                                   std::move(shared_locks));
      if (sparse) {
        // Enable sparse variables' access.
        // NOTE: This can not be done before the variable input locks are held,
        // because a race condition can happen between this and another thread that
        // turns off some variable's `copy_on_read_mode` after this thread enables
        // sparse access; when a later function sees `copy_on_read_mode` is off, it
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 23 06:12:29 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  2. pkg/registry/core/service/ipallocator/controller/repairip.go

    // and then creates the accurate list of IPAddresses objects with all allocated ClusterIPs.
    //
    // Handles:
    // * Duplicate ClusterIP assignments caused by operator action or undetected race conditions
    // * Allocations to services that were not actually created due to a crash or powerloss
    // * Migrates old versions of Kubernetes services into the new ipallocator automatically
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  3. src/cmd/compile/internal/ssagen/ssa.go

    	types.NewPtrCacheEnabled = false
    	ssaConfig = ssa.NewConfig(base.Ctxt.Arch.Name, *types_, base.Ctxt, base.Flag.N == 0, Arch.SoftFloat)
    	ssaConfig.Race = base.Flag.Race
    	ssaCaches = make([]ssa.Cache, base.Flag.LowerC)
    
    	// Set up some runtime functions we'll need to call.
    	ir.Syms.AssertE2I = typecheck.LookupRuntimeFunc("assertE2I")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 284.9K bytes
    - Viewed (0)
  4. src/net/http/transport_test.go

    		},
    	}
    	if mode == http2Mode {
    		trace.TLSHandshakeStart = func() { logf("tls handshake start") }
    		trace.TLSHandshakeDone = func(s tls.ConnectionState, err error) {
    			logf("tls handshake done. ConnectionState = %v \n err = %v", s, err)
    		}
    	}
    	if noHooks {
    		// zero out all func pointers, trying to get some path to crash
    		*trace = httptrace.ClientTrace{}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/walk/assign.go

    			// Left in place for back end.
    			// Do not add a new write barrier.
    			// Set up address of type for back end.
    			r.Fun = reflectdata.AppendElemRType(base.Pos, r)
    			return as
    		}
    		// Otherwise, lowered for race detector.
    		// Treat as ordinary assignment.
    	}
    
    	if as.X != nil && as.Y != nil {
    		return convas(as, init)
    	}
    	return as
    }
    
    // walkAssignDotType walks an OAS2DOTTYPE node.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:09:06 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  6. src/go/token/position.go

    	if i := searchFiles(s.files, int(p)); i >= 0 {
    		f := s.files[i]
    		// f.base <= int(p) by definition of searchFiles
    		if int(p) <= f.base+f.size {
    			// Update cache of last file. A race is ok,
    			// but an exclusive lock causes heavy contention.
    			s.last.Store(f)
    			return f
    		}
    	}
    	return nil
    }
    
    // File returns the file that contains the position p.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  7. src/cmd/link/link_test.go

    }
    
    func main() {
    	callee(9)
    }
    `
    
    func TestIssue42396(t *testing.T) {
    	testenv.MustHaveGoBuild(t)
    
    	if !platform.RaceDetectorSupported(runtime.GOOS, runtime.GOARCH) {
    		t.Skip("no race detector support")
    	}
    
    	t.Parallel()
    
    	tmpdir := t.TempDir()
    
    	src := filepath.Join(tmpdir, "main.go")
    	err := os.WriteFile(src, []byte(testIssue42396src), 0666)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 20:26:02 UTC 2024
    - 43.5K bytes
    - Viewed (0)
  8. Makefile.core.mk

    # For now, keep a minimal subset. This can be expanded in the future.
    BENCH_TARGETS ?= ./pilot/...
    
    PKG ?= ./...
    .PHONY: racetest
    racetest: $(JUNIT_REPORT)
    	go test ${GOBUILDFLAGS} ${T} -race $(PKG) 2>&1 | tee >($(JUNIT_REPORT) > $(JUNIT_OUT))
    
    .PHONY: benchtest
    benchtest: $(JUNIT_REPORT) ## Runs all benchmarks
    	prow/benchtest.sh run $(BENCH_TARGETS)
    	prow/benchtest.sh compare
    
    report-benchtest:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Jun 02 19:53:04 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  9. src/syscall/fs_wasip1.go

    		// determine ahead of time if the path we are about to open is a
    		// directory, so instead we fallback to a second call to path_open with
    		// a more limited set of rights.
    		//
    		// This approach is subject to a race if the file system is modified
    		// concurrently, so we also inject OFLAG_DIRECTORY to ensure that we do
    		// not accidentally open a file which is not a directory.
    		errno = path_open(
    			dirFd,
    			LOOKUP_SYMLINK_FOLLOW,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  10. pilot/pkg/xds/delta.go

    		peerAddr = peerInfo.Addr.String()
    	}
    
    	if err := s.WaitForRequestLimit(stream.Context()); err != nil {
    		deltaLog.Warnf("ADS: %q exceeded rate limit: %v", peerAddr, err)
    		return status.Errorf(codes.ResourceExhausted, "request rate limit exceeded: %v", err)
    	}
    
    	ids, err := s.authenticate(ctx)
    	if err != nil {
    		return status.Error(codes.Unauthenticated, err.Error())
    	}
    	if ids != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
Back to top