- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 192 for blocked (0.18 sec)
-
src/runtime/tracestatus.go
// state but needs to present itself as preempted to the // garbage collector. In these cases, we're not going to // emit an event, and we want these goroutines to appear in // the final trace as if they're running, not blocked. tgs = traceGoWaiting if status == _Gwaiting && wr.isWaitingForGC() { tgs = traceGoRunning } case _Gdead: throw("tried to trace dead goroutine") default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0) -
internal/grid/muxserver.go
} default: m.disconnect("handler blocked", true) } } func (m *muxServer) unblockSend(seq uint32) { if !m.checkSeq(seq) { return } m.recvMu.Lock() defer m.recvMu.Unlock() if m.outBlock == nil { // Closed return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/crashmonitor/monitor.go
pcs = pcs[:min(len(pcs), 16)] if len(pcs) == 0 { // This can occur if all goroutines are idle, as when // caught in a deadlock, or killed by an async signal // while blocked. // // TODO(adonovan): consider how to report such // situations. Reporting a goroutine in [sleep] or // [select] state could be quite confusing without // further information about the nature of the crash,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:57:25 UTC 2024 - 7.6K bytes - Viewed (0) -
src/runtime/cpuprof.go
// //go:nosplit //go:nowritebarrierrec func (p *cpuProfile) addNonGo(stk []uintptr) { // Simple cas-lock to coordinate with SetCPUProfileRate. // (Other calls to add or addNonGo should be blocked out // by the fact that only one SIGPROF can be handled by the // process at a time. If not, this lock will serialize those too. // The use of timer_create(2) on Linux to request process-targeted
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
// sent to the Sink. Deep copy and send the copy to the queue. event := e.DeepCopy() select { case b.buffer <- event: default: sendErr = fmt.Errorf("audit buffer queue blocked") return true } } return true } func (b *bufferedBackend) String() string { return fmt.Sprintf("%s<%s>", PluginName, b.delegateBackend)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
src/sync/rwmutex_test.go
var wl RWMutex var rl Locker wlocked := make(chan bool, 1) rlocked := make(chan bool, 1) rl = wl.RLocker() n := 10 go func() { for i := 0; i < n; i++ { rl.Lock() rl.Lock() rlocked <- true wl.Lock() wlocked <- true } }() for i := 0; i < n; i++ { <-rlocked rl.Unlock() select { case <-wlocked: t.Fatal("RLocker() didn't read-lock it")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 29 17:13:13 UTC 2021 - 4.9K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
wl := NewLRWMutex() var rl sync.Locker wlocked := make(chan bool, 1) rlocked := make(chan bool, 1) rl = wl.DRLocker() n := 10 go func() { for i := 0; i < n; i++ { rl.Lock() rl.Lock() rlocked <- true wl.Lock() wlocked <- true } }() for i := 0; i < n; i++ { <-rlocked rl.Unlock() select { case <-wlocked: t.Fatal("RLocker() didn't read-lock it")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
expected := true if locked != expected { t.Errorf("TestSimpleWriteLockAcquired(): \nexpected %#v\ngot %#v", expected, locked) } } func TestSimpleWriteLockTimedOut(t *testing.T) { locked := testSimpleWriteLock(t, testDrwMutexAcquireTimeout) expected := false if locked != expected { t.Errorf("TestSimpleWriteLockTimedOut(): \nexpected %#v\ngot %#v", expected, locked) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
internal/lock/lock.go
// open file descriptor. package lock import ( "errors" "os" "sync" ) // ErrAlreadyLocked is returned if the underlying fd is already locked. var ErrAlreadyLocked = errors.New("file already locked") // RLockedFile represents a read locked file, implements a special // closer which only closes the associated *os.File when the ref count. // has reached zero, i.e when all the readers have given up their locks.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.5K bytes - Viewed (0) -
internal/dsync/locker.go
// In that case, the resource may or may not be unlocked. RUnlock(ctx context.Context, args LockArgs) (bool, error) // Do write unlock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of unlock request operation. // Canceling the context will abort the remote call. // In that case, the resource may or may not be unlocked.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 18 20:44:38 UTC 2022 - 2.7K bytes - Viewed (0)