Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 236 for lockedm (0.18 sec)

  1. src/runtime/coro.go

    		casgstatus(gnext, _Gwaiting, _Grunnable)
    		casgstatus(gnext, _Grunnable, _Grunning)
    	}
    
    	// Donate locked state.
    	if locked {
    		mp.lockedg.set(gnext)
    		gnext.lockedm.set(mp)
    	}
    
    	// Release the trace locker. We've completed all the necessary transitions..
    	if trace.ok() {
    		traceRelease(trace)
    	}
    
    	// Switch to gnext. Does not return.
    	gogo(&gnext.sched)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:18 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. src/runtime/export_debug_test.go

    // will send SIGTRAP to thread ID tid. gp must be locked to its OS thread and
    // running.
    //
    // On success, InjectDebugCall returns the panic value of fn or nil.
    // If fn did not panic, its results will be available in args.
    func InjectDebugCall(gp *g, fn any, regArgs *abi.RegArgs, stackArgs any, tkill func(tid int) error, returnOnUnsafePoint bool) (any, error) {
    	if gp.lockedm == 0 {
    		return nil, plainError("goroutine not locked to thread")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. 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)
  4. src/runtime/proc.go

    		}
    		print(" mallocing=", mp.mallocing, " throwing=", mp.throwing, " preemptoff=", mp.preemptoff, " locks=", mp.locks, " dying=", mp.dying, " spinning=", mp.spinning, " blocked=", mp.blocked, " lockedg=")
    		if lockedg := mp.lockedg.ptr(); lockedg != nil {
    			print(lockedg.goid)
    		} else {
    			print("nil")
    		}
    		print("\n")
    	}
    
    	forEachG(func(gp *g) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. src/runtime/traceback.go

    		} else {
    			print(" m=nil")
    		}
    	}
    	print(" [", status)
    	if isScan {
    		print(" (scan)")
    	}
    	if waitfor >= 1 {
    		print(", ", waitfor, " minutes")
    	}
    	if gp.lockedm != 0 {
    		print(", locked to thread")
    	}
    	print("]:\n")
    }
    
    func tracebackothers(me *g) {
    	level, _, _ := gotraceback()
    
    	// Show the current goroutine first, if we haven't already.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  8. src/runtime/lock_sema.go

    					break
    				}
    				v = atomic.Loaduintptr(&l.key)
    				if v&locked == 0 {
    					continue Loop
    				}
    			}
    			if v&locked != 0 {
    				// Queued. Wait.
    				semasleep(-1)
    				i = 0
    			}
    		}
    	}
    }
    
    func unlock(l *mutex) {
    	unlockWithRank(l)
    }
    
    // We might not be holding a p in this code.
    //
    //go:nowritebarrier
    func unlock2(l *mutex) {
    	gp := getg()
    	var mp *m
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. 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)
  10. src/sync/mutex.go

    // relation at all.
    //
    // [the Go memory model]: https://go.dev/ref/mem
    type Mutex struct {
    	state int32
    	sema  uint32
    }
    
    // A Locker represents an object that can be locked and unlocked.
    type Locker interface {
    	Lock()
    	Unlock()
    }
    
    const (
    	mutexLocked = 1 << iota // mutex is locked
    	mutexWoken
    	mutexStarving
    	mutexWaiterShift = iota
    
    	// Mutex fairness.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top