- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 244 for blocked (0.34 sec)
-
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) -
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/internal/trace/testdata/testprog/stress-start-stop.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines, // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS). //go:build ignore package main import ( "bytes" "io" "log" "net" "os" "runtime" "runtime/trace" "sync" "time" )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
src/internal/trace/trace_test.go
// of entered -> blocked -> runnable -> running. If in the running state // we block, then we have a futile wakeup. Because of the runtime.Gosched // on these specially marked goroutines, we should end up back in runnable // first. If at any point we go to a different state, switch back to entered // and wait for the next time the goroutine blocks. if ev.Kind() != trace.EventStateTransition {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stacks.go
// Now we will do a bunch of things for which we verify stacks later. // It is impossible to ensure that a goroutine has actually blocked // on a channel, in a select or otherwise. So we kick off goroutines // that need to block first in the hope that while we are executing // the rest of the test, they will block. go func() { // func1 select {} }() go func() { // func2 var c chan int c <- 0 }() go func() { // func3
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
src/runtime/preempt.go
// Goroutine preemption // // A goroutine can be preempted at any safe-point. Currently, there // are a few categories of safe-points: // // 1. A blocked safe-point occurs for the duration that a goroutine is // descheduled, blocked on synchronization, or in a system call. // // 2. Synchronous safe-points occur when a running goroutine checks // for a preemption request. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
src/runtime/traceevent.go
traceEvGoBlock // goroutine blocks [timestamp, reason, stack ID] traceEvGoUnblock // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID] traceEvGoSyscallBegin // syscall enter [timestamp, P seq, stack ID] traceEvGoSyscallEnd // syscall exit [timestamp] traceEvGoSyscallEndBlocked // syscall exit and it blocked at some point [timestamp]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.2K bytes - Viewed (0) -
src/runtime/sema.go
// The operations on the inner lists of sudogs with the same address // are all O(1). The scanning of the top-level semaRoot list is O(log n), // where n is the number of distinct addresses with goroutines blocked // on them that hash to the given semaRoot. // See golang.org/issue/17953 for a program that worked badly // before we introduced the second level of list, and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
func (ping) Name() string { return "ping" } // PingHealthz is a health check that returns true. func (ping) Check(_ *http.Request) error { return nil } // LogHealthz returns true if logging is not blocked var LogHealthz HealthChecker = &log{} type log struct { startOnce sync.Once lastVerified atomic.Value } func (l *log) Name() string { return "log" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0)