- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 320 for race (0.04 sec)
-
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/autoregistration/controller.go
// queue contains workloadEntry that need to be unregistered queue controllers.Queue // cleanupLimit rate limit's auto registered WorkloadEntry cleanup calls to k8s cleanupLimit *rate.Limiter // cleanupQueue delays the cleanup of auto registered WorkloadEntries to allow for grace period cleanupQueue queue.Delayed adsConnections *adsConnections lateRegistrationQueue controllers.Queue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
source.skip(remainingByteCount) closeLater(ErrorCode.FLOW_CONTROL_ERROR) return } // Discard data received after the stream is finished. It's probably a benign race. if (finished) { source.skip(remainingByteCount) return } // Fill the receive buffer without holding any locks.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
continue } // This is a device plugin resource yet we don't have cached // resource state. This is likely due to a race during node // restart. We re-issue allocate request to cover this race. if m.podDevices.containerDevices(podUID, contName, resource) == nil { needsReAllocate = true } } if needsReAllocate {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K 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) -
src/runtime/signal_unix.go
// that programs that use profiling don't want to crash on a // stray SIGPROF. See issue 19320. // We do the change here instead of when turning off profiling, // because there we may race with a signal handler running // concurrently, in particular, sigfwdgo may observe _SIG_DFL and // die. See issue 43828. if h == _SIG_DFL { h = _SIG_IGN } atomic.Storeuintptr(&fwdSig[_SIGPROF], h)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0)