- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 96 for lockedm (0.14 sec)
-
src/runtime/tracestack.go
} } } if gp != nil && mp == nil { // We're getting the backtrace for a G that's not currently executing. // It may still have an M, if it's locked to some M. mp = gp.lockedm.ptr() } nstk := 1 if tracefpunwindoff() || (mp != nil && mp.hasCgoOnStack()) { // Slow path: Unwind using default unwinder. Used when frame pointer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 14:38:56 UTC 2024 - 11K bytes - Viewed (0) -
src/runtime/export_test.go
} func LockOSCounts() (external, internal uint32) { gp := getg() if gp.m.lockedExt+gp.m.lockedInt == 0 { if gp.lockedm != 0 { panic("lockedm on non-locked goroutine") } } else { if gp.lockedm == 0 { panic("nil lockedm on locked goroutine") } } return gp.m.lockedExt, gp.m.lockedInt } //go:noinline func TracebackSystemstack(stk []uintptr, i int) int {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
src/runtime/runtime2.go
preemptoff string // if != "", keep curg running on this m locks int32 dying int32 profilehz int32 spinning bool // m is out of work and is actively looking for work blocked bool // m is blocked on a note newSigstack bool // minit on C thread called sigaltstack printlock int8 incgo bool // m is executing a cgo call isextra bool // m is an extra m
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// releaseAll releases all locks that are marked as locked func releaseAll(ctx context.Context, ds *Dsync, tolerance int, owner string, locks *[]string, isReadLock bool, restClnts []NetLocker, names ...string) bool { var wg sync.WaitGroup for lockID := range restClnts { wg.Add(1) go func(lockID int) { defer wg.Done() if sendRelease(ctx, ds, restClnts[lockID], owner, (*locks)[lockID], isReadLock, names...) { (*locks)[lockID] = ""
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/crypto/tls/quic.go
defer c.handshakeMutex.Lock() // Send on blockedc to notify the QUICConn that the handshake is blocked. // Exported methods of QUICConn wait for the handshake to become blocked // before returning to the user. select { case c.quic.blockedc <- struct{}{}: case <-c.quic.cancelc: return c.sendAlertLocked(alertCloseNotify) } // The QUICConn reads from signalc to notify us that the handshake may
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/dep-man/02-declaring-dependency-versions/dependency_locking.adoc
You can also disable locking on a specific configuration. This can be useful if a plugin configured locking on all configurations but you happen to add one that should not be locked. .Unlocking a specific configuration ==== include::sample[dir="snippets/dependencyManagement/dependencyLocking-unlockingSingleConfiguration/kotlin",files="build.gradle.kts[tags=locking-one]"]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 16:55:22 UTC 2024 - 15.5K bytes - Viewed (0) -
src/syscall/exec_linux.go
// Set up and fork. This returns immediately in the parent or // if there's an error. upid, pidfd, err, mapPipe, locked := forkAndExecInChild1(argv0, argv, envv, chroot, dir, attr, sys, pipe) if locked { runtime_AfterFork() } if err != 0 { return 0, err } // parent; return PID pid = int(upid) if sys.PidFD != nil { *sys.PidFD = int(pidfd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
cmd/erasure-sets.go
} } } func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) { return func() ([]dsync.NetLocker, string) { lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex])) copy(lockers, s.erasureLockers[setIndex]) return lockers, s.erasureLockOwner } } func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string { return func() []string {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationFactory.java
role ); instance.addMutationValidator(rootComponentMetadataBuilder.getValidator()); return instance; } /** * Creates a new locked resolvable configuration instance. */ DefaultResolvableConfiguration createResolvable( String name, ConfigurationsProvider configurationsProvider,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:29:40 UTC 2024 - 12.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/counter.go
sum := c.add(uint64(n)) debugPrintf("Add %q += %d: count=%d\n", c.name, n, sum) } c.releaseReader(state) return case state.locked(): if !c.state.update(&state, state.addExtra(uint64(n))) { continue } debugPrintf("Add %q += %d: locked extra=%d\n", c.name, n, state.extra()) return case !state.havePtr(): if !c.state.update(&state, state.addExtra(uint64(n)).setLocked()) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 10.3K bytes - Viewed (0)