- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 587 for blocked (0.17 sec)
-
src/sync/mutex.go
// relation at all. // // [the Go memory model]: https://go.dev/ref/mem type Mutex struct { state int32 sema uint32 } // A Locker represents an object that can be locked and unlocked. type Locker interface { Lock() Unlock() } const ( mutexLocked = 1 << iota // mutex is locked mutexWoken mutexStarving mutexWaiterShift = iota // Mutex fairness. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
Client: reconciliation.ClusterRoleModifier{Client: client.RbacV1().ClusterRoles()}, Confirm: true, } // ServiceUnavailble error is returned when the API server is blocked by storage version updates err := retryOnConflictOrServiceUnavailable(retry.DefaultBackoff, func() error { result, err := opts.Run() if err != nil { return err } switch {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
src/internal/trace/oldtrace.go
// blocked. blocked := false it.events.All()(func(nev *oldtrace.Event) bool { if nev.G != ev.G { return true } // After an EvGoSysCall, the next event on the same G will either be // EvGoSysBlock to denote a blocking syscall, or some other event // (or the end of the trace) if the syscall didn't block. if nev.Type == oldtrace.EvGoSysBlock {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 27.1K bytes - Viewed (0) -
src/sync/rwmutex.go
return r < 0 && r+rwmutexMaxReaders > 0 } // RLocker returns a [Locker] interface that implements // the [RWMutex.Lock] and [RWMutex.Unlock] methods by calling rw.RLock and rw.RUnlock. func (rw *RWMutex) RLocker() Locker { return (*rlocker)(rw) } type rlocker RWMutex func (r *rlocker) Lock() { (*RWMutex)(r).RLock() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/sync/runtime.go
func runtime_SemacquireRWMutexR(s *uint32, lifo bool, skipframes int) func runtime_SemacquireRWMutex(s *uint32, lifo bool, skipframes int) // Semrelease atomically increments *s and notifies a waiting goroutine // if one is blocked in Semacquire. // It is intended as a simple wakeup primitive for use by the synchronization // library and should not be used directly. // If handoff is true, pass count directly to the first waiter.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 16:32:27 UTC 2022 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/stats.go
fetchCount, activeFetchCount, ) } const ( hitTag = "hit" missTag = "miss" fetchFailedTag = "error" fetchOkTag = "ok" fetchInFlightTag = "in_flight" fetchBlockedTag = "blocked" ) type statsCollector struct{} var stats = statsCollector{} func (statsCollector) authenticating(ctx context.Context) func(hit bool) { start := time.Now() return func(hit bool) { var tag string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 01 18:49:09 UTC 2021 - 2.9K bytes - Viewed (0) -
internal/lock/lock_test.go
return } locked <- struct{}{} if blerr = bl.Close(); blerr != nil { t.Error(blerr) return } }() select { case <-locked: t.Error("unexpected unblocking") case <-time.After(100 * time.Millisecond): } // unlock if err = dupl.Close(); err != nil { t.Fatal(err) } // the previously blocked routine should be unblocked select { case <-locked:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.6K bytes - Viewed (0) -
tests/integration/helm/install_test.go
framework. NewTest(t). Run(setupInstallation(ambientProfileOverride, true, tt.nsConfig, "")) }) } } // TestReleaseChannels tests that non-stable CRDs and fields get blocked // by the default ValidatingAdmissionPolicy func TestReleaseChannels(t *testing.T) { overrideValuesStr := ` global: hub: %s tag: %s variant: %q profile: stable ` framework.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 7.7K bytes - Viewed (0) -
src/runtime/internal/wasitest/nonblock_test.go
// the FIFOs in their original order and spawns a goroutine for each that reads // from the FIFO and writes the result to stderr. If I/O was blocking, all // goroutines would be blocked waiting for one read call to return, and the // output order wouldn't match. type fifo struct { file *os.File path string } func TestNonblock(t *testing.T) { if target != "wasip1/wasm" { t.Skip()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 29 15:35:27 UTC 2023 - 2.4K bytes - Viewed (0)