- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 182 for lockedm (0.17 sec)
-
src/internal/trace/oldtrace.go
mappedArgs = timedEventArgs{uint64(it.builtinToStringID[sMarkAssistWait]), uint64(ev.StkID)} case oldtrace.EvGoSysCall: // Look for the next event for the same G to determine if the syscall // 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
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) -
android/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 - 25.8K 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) -
cmd/bucket-object-lock.go
// enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false } lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined) if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn { return true }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
src/internal/trace/trace_test.go
state, ok := gs[id] if !ok { continue } _, new := st.Goroutine() switch state { case entered: if new == trace.GoWaiting { state = blocked } else { state = entered } case blocked: if new == trace.GoRunnable { state = runnable } else { state = entered } case runnable: if new == trace.GoRunning { state = running
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
tests/binary/binaries_test.go
"indicating the binary size has decreased. The test will fail to ensure you update the test thresholds to ensure "+ "the improvements are 'locked in'.", got, tt.minMb) } }) } // If this flag is present, it means "testing" was imported by code that is built by the binary var denylistedFlags = []string{ "--test.memprofilerate", }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 4.8K bytes - Viewed (0) -
src/sync/cond.go
type Cond struct { noCopy noCopy // L is held while observing or changing the condition L Locker notify notifyList checker copyChecker } // NewCond returns a new Cond with Locker l. func NewCond(l Locker) *Cond { return &Cond{L: l} } // Wait atomically unlocks c.L and suspends execution // of the calling goroutine. After later resuming execution,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stacks.go
} defer trace.Stop() // in case of early return // 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 {} }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
startTime := time.Now() timeout := c.dispatchTimeoutBudget.takeAvailable() c.timer.Reset(timeout) // Send event to all blocked watchers. As long as timer is running, // `add` will wait for the watcher to unblock. After timeout, // `add` will not wait, but immediately close a still blocked watcher. // Hence, every watcher gets the chance to unblock itself while timer // is running, not only the first ones in the list.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0)