- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 595 for lockedm (0.35 sec)
-
test/chan/nonblock.go
cs := make(chan string, buffer) select { case i32 = <-c32: panic("blocked i32sender") default: } select { case i64 = <-c64: panic("blocked i64sender") default: } select { case b = <-cb: panic("blocked bsender") default: } select { case s = <-cs: panic("blocked ssender") default: } go i32receiver(c32, sync) try := 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Feb 19 06:44:02 UTC 2012 - 3.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/artifacts/dsl/LockMode.java
/** * The supported lock modes: * <ul> * <li>{@code DEFAULT} will load the lock state and verify resolution matches it</li> * <li>{@code STRICT} in addition to the {@code DEFAULT} behaviour, will fail resolution if a locked configuration does not have lock state defined</li> * <li>{@code LENIENT} will load the lock state, to anchor dynamic versions, but otherwise be lenient about modifications of the dependency resolution,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 23 15:47:10 UTC 2020 - 1.2K bytes - Viewed (0) -
clause/locking_test.go
}, { []clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate, Options: clause.LockingOptionsSkipLocked}}, "SELECT * FROM `users` FOR UPDATE SKIP LOCKED", nil, }, } for idx, result := range results { t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) { checkBuildClauses(t, result.Clauses, result.Result, result.Vars) }) }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Fri Dec 15 08:32:56 UTC 2023 - 1.2K bytes - Viewed (0) -
src/internal/trace/traceviewer/format/format.go
} type Frame struct { Name string `json:"name"` Parent int `json:"parent,omitempty"` } type NameArg struct { Name string `json:"name"` } type BlockedArg struct { Blocked string `json:"blocked"` } type SortIndexArg struct { Index int `json:"sort_index"` } type HeapCountersArg struct { Allocated uint64 NextGC uint64 } const (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2K bytes - Viewed (0) -
src/cmd/trace/gstate.go
// and orthogonal to syscallEnd; both must be called if the syscall blocked. This sets up an instant // to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system. func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) { name := "exit blocked syscall" gs.setStartCause(ts, name, trace.SyscallP, stack)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
src/cmd/trace/jsontrace_test.go
return parts[1] } // filterBlocked returns an event filter that returns true if the event's // "blocked" argument is equal to blocked. func filterBlocked(blocked string) eventFilterFn { return func(e *format.Event, _ *format.Data) bool { m, ok := e.Arg.(map[string]any) if !ok { return false } return m["blocked"] == blocked } } // filterStackRootFunc returns an event filter that returns true if the function
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 7.8K bytes - Viewed (0) -
src/runtime/testdata/testprog/syscall_windows.go
wg.Done() select {} }() } wg.Wait() mem2, err := getPagefileUsage() if err != nil { panic(err) } // assumes that this process creates 1 thread for each // thread locked goroutine plus extra 10 threads // like sysmon and others print((mem2 - mem1) / (threadCount + 10))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 17:31:31 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockPacketPayloadTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 2K bytes - Viewed (0) -
src/runtime/tracecpu.go
// we need to acquire it and read the generation. locked := false if mp.trace.seqlock.Load()%2 == 0 { mp.trace.seqlock.Add(1) locked = true } gen := trace.gen.Load() if gen == 0 { // Tracing is disabled, as it turns out. Release the seqlock if necessary // and exit. if locked { mp.trace.seqlock.Add(1) } return } now := traceClockNow()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0)