- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 320 for race (1.32 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)