- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for someone (0.21 sec)
-
doc/next/9-todo.md
<!-- These items need to be reviewed, and mentioned in the Go 1.23 release notes if applicable. None right now; more may come up later on. --> <!-- Maybe should be documented? Maybe shouldn't? Someone familiar with the change needs to determine.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:18:52 UTC 2024 - 6K bytes - Viewed (0) -
src/internal/runtime/exithook/hooks.go
package exithook import ( "internal/runtime/atomic" _ "unsafe" // for linkname ) // A Hook is a function to be run at program termination // (when someone invokes os.Exit, or when main.main returns). // Hooks are run in reverse order of registration: // the first hook added is the last one run. type Hook struct { F func() // func to run
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 16:41:13 UTC 2024 - 2.2K bytes - Viewed (0) -
src/runtime/traceregion.go
if r <= uintptr(len(block.data)) { return (*notInHeap)(unsafe.Pointer(&block.data[r-n])) } } // Try to install a new block. lock(&a.lock) // Check block again under the lock. Someone may // have gotten here first. block = (*traceRegionAllocBlock)(a.current.Load()) if block != nil { r := block.off.Add(n) if r <= uintptr(len(block.data)) { unlock(&a.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 3.2K bytes - Viewed (0) -
src/unique/handle.go
*concurrent.HashTrieMap[T, weak.Pointer[T]] cloneSeq } func addUniqueMap[T comparable](typ *abi.Type) *uniqueMap[T] { // Create a map for T and try to register it. We could // race with someone else, but that's fine; it's one // small, stray allocation. The number of allocations // this can create is bounded by a small constant. m := &uniqueMap[T]{ HashTrieMap: concurrent.NewHashTrieMap[T, weak.Pointer[T]](),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 16:01:55 UTC 2024 - 5.3K bytes - Viewed (0) -
src/runtime/lock_sema.go
timer.end() return } i = 0 } if i < spin { procyield(active_spin_cnt) } else if i < spin+passive_spin { osyield() } else { // Someone else has it. // l->waitm points to a linked list of M's waiting // for this lock, chained through m->nextwaitm. // Queue this M. for { gp.m.nextwaitm = muintptr(v &^ locked)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
src/runtime/preempt.go
stopped := false var asyncM *m var asyncGen uint32 var nextPreemptM int64 for i := 0; ; i++ { switch s := readgstatus(gp); s { default: if s&_Gscan != 0 { // Someone else is suspending it. Wait // for them to finish. // // TODO: It would be nicer if we could // coalesce suspends. break } dumpgstatus(gp) throw("invalid g status")
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/net/unixsock_posix.go
func (ln *UnixListener) close() error { // The operating system doesn't clean up // the file that announcing created, so // we have to clean it up ourselves. // There's a race here--we can't know for // sure whether someone else has come along // and replaced our socket name already-- // but this sequence (remove then close) // is at least compatible with the auto-remove // sequence in ListenUnix. It's only non-Go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
src/sync/mutex.go
// So get off the way. if old>>mutexWaiterShift == 0 || old&(mutexLocked|mutexWoken|mutexStarving) != 0 { return } // Grab the right to wake someone. new = (old - 1<<mutexWaiterShift) | mutexWoken if atomic.CompareAndSwapInt32(&m.state, old, new) { runtime_Semrelease(&m.sema, false, 1) return } old = m.state } } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
istioctl/cmd/root.go
// TODO(hanxiaop): I think experimental version still has issues, so we keep the old version for now. version.XdsVersionCommand(ctx), // TODO(hanxiaop): this is kept for some releases in case someone is using it. proxystatus.XdsStatusCommand(ctx), } troubleshootingCommands := []*cobra.Command{ version.NewVersionCommand(ctx), proxystatus.StableXdsStatusCommand(ctx), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 10K bytes - Viewed (0)