- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 231 for race (0.85 sec)
-
pkg/kubelet/pleg/generic.go
} else { klog.V(4).InfoS("PLEG: Write status", "pod", klog.KRef(pod.Namespace, pod.Name)) } // Preserve the pod IP across cache updates if the new IP is empty. // When a pod is torn down, kubelet may race with PLEG and retrieve // a pod status after network teardown, but the kubernetes API expects // the completed pod's IP to be available after the pod is dead. status.IPs = g.getPodIPs(pid, status) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
src/runtime/stack.go
} osStackAlloc(s) s.elemsize = uintptr(n) } v = unsafe.Pointer(s.base()) } if traceAllocFreeEnabled() { trace := traceTryAcquire() if trace.ok() { trace.GoroutineStackAlloc(uintptr(v), uintptr(n)) traceRelease(trace) } } if raceenabled { racemalloc(v, uintptr(n)) } if msanenabled { msanmalloc(v, uintptr(n)) } if asanenabled {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 41.1K bytes - Viewed (0) -
src/cmd/cgo/internal/test/test.go
int i; for (i = 0; i < l; i++) { if (b[i] != i) { return 0; } } return 1; } // issue 17065 // Test that C symbols larger than a page play nicely with the race detector. int ii[65537]; // issue 17537 // The void* cast introduced by cgo to avoid problems // with const/volatile qualifiers breaks C preprocessor macros that // emulate functions. typedef struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:50:06 UTC 2024 - 48.5K bytes - Viewed (0) -
src/cmd/compile/internal/types2/typexpr.go
if check.conf.Trace { check.trace(e0.Pos(), "-- type %s", e0) check.indent++ defer func() { check.indent-- var under Type if T != nil { // Calling under() here may lead to endless instantiations. // Test case: type T[P any] *T[P] under = safeUnderlying(T) } if T == under { check.trace(e0.Pos(), "=> %s // %s", T, goTypeName(T)) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager.go
sort.Sort(sliceutils.ByImageSize(images)) i.images = images } // get gets image list from image cache. // NOTE: The caller of get() should not do mutating operations on the // returned list that could cause data race against other readers (e.g. // in-place sorting the returned list) func (i *imageCache) get() []container.Image { i.Lock() defer i.Unlock() return i.images } // Information about the images we track.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
return err } if !s.waitForCacheSync(stop) { return fmt.Errorf("failed to sync cache") } // Inform Discovery Server so that it can start accepting connections. s.XDSServer.CachesSynced() // Race condition - if waitForCache is too fast and we run this as a startup function, // the grpc server would be started before CA is registered. Listening should be last. if s.secureGrpcAddress != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
cmd/storage-rest-server.go
return } } }() return func(err error) { if doneCh == nil { return } // Indicate we are ready to write. doneCh <- err // Wait for channel to be closed so we don't race on writes. <-doneCh // Clear so we can be called multiple times without crashing. doneCh = nil }, &closeNotifier{rc: r.Body, done: bodyDoneCh} }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
src/syscall/exec_linux.go
// they might have been locked at the time of the fork. This means // no rescheduling, no malloc calls, and no new stack segments. // For the same reason compiler does not race instrument it. // The calls to RawSyscall are okay because they are assembly // functions that do not grow the stack. // //go:norace
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
peerAddr = peerInfo.Addr.String() } if err := s.WaitForRequestLimit(stream.Context()); err != nil { log.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: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// Knowing this, it is reasonable to wait until the service lister has synchronized at least once before attempting to build // a service env var map. This doesn't present the race below from happening entirely, but it does prevent the "obvious" // failure case of services simply not having completed a list operation that can reasonably be expected to succeed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)