all: move procPin and procUnpin to internal/runtime

For #65355

Change-Id: I42c04ade295d2900f55596ad2f223c9c93dd740f

Author: qiulaidongfeng

src/go/build/deps_test.go

@@ -50,6 +50,8 @@ var depsRules = `
 	  unicode/utf8, unicode/utf16, unicode,
 	  unsafe;
 
+	unsafe < internal/runtime;
+
 	# These packages depend only on internal/goarch and unsafe.
 	internal/goarch, unsafe
 	< internal/abi, internal/chacha8rand;
@@ -64,7 +66,8 @@ var depsRules = `
 	internal/goarch,
 	internal/godebugs,
 	internal/goexperiment,
-	internal/goos
+	internal/goos,
+	internal/runtime
 	< internal/bytealg
 	< internal/itoa
 	< internal/unsafeheader

src/runtime/proc.go

@@ -6921,42 +6921,6 @@ func procUnpin() {
 	gp.m.locks--
 }
 
-//go:linkname sync_runtime_procPin sync.runtime_procPin
-//go:nosplit
-func sync_runtime_procPin() int {
-	return procPin()
-}
-
-//go:linkname sync_runtime_procUnpin sync.runtime_procUnpin
-//go:nosplit
-func sync_runtime_procUnpin() {
-	procUnpin()
-}
-
-//go:linkname sync_atomic_runtime_procPin sync/atomic.runtime_procPin
-//go:nosplit
-func sync_atomic_runtime_procPin() int {
-	return procPin()
-}
-
-//go:linkname sync_atomic_runtime_procUnpin sync/atomic.runtime_procUnpin
-//go:nosplit
-func sync_atomic_runtime_procUnpin() {
-	procUnpin()
-}
-
-//go:linkname internal_weak_runtime_procPin internal/weak.runtime_procPin
-//go:nosplit
-func internal_weak_runtime_procPin() int {
-	return procPin()
-}
-
-//go:linkname internal_weak_runtime_procUnpin internal/weak.runtime_procUnpin
-//go:nosplit
-func internal_weak_runtime_procUnpin() {
-	procUnpin()
-}
-
 // Active spinning for sync.Mutex.
 //
 //go:linkname sync_runtime_canSpin sync.runtime_canSpin

src/sync/atomic/value.go

@@ -5,6 +5,7 @@
 package atomic
 
 import (
+	rt "internal/runtime"
 	"unsafe"
 )
 
@@ -56,15 +57,15 @@ func (v *Value) Store(val any) {
 			// Attempt to start first store.
 			// Disable preemption so that other goroutines can use
 			// active spin wait to wait for completion.
-			runtime_procPin()
+			rt.ProcPin()
 			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
-				runtime_procUnpin()
+				rt.ProcUnpin()
 				continue
 			}
 			// Complete first store.
 			StorePointer(&vp.data, vlp.data)
 			StorePointer(&vp.typ, vlp.typ)
-			runtime_procUnpin()
+			rt.ProcUnpin()
 			return
 		}
 		if typ == unsafe.Pointer(&firstStoreInProgress) {
@@ -100,15 +101,15 @@ func (v *Value) Swap(new any) (old any) {
 			// Disable preemption so that other goroutines can use
 			// active spin wait to wait for completion; and so that
 			// GC does not see the fake type accidentally.
-			runtime_procPin()
+			rt.ProcPin()
 			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
-				runtime_procUnpin()
+				rt.ProcUnpin()
 				continue
 			}
 			// Complete first store.
 			StorePointer(&vp.data, np.data)
 			StorePointer(&vp.typ, np.typ)
-			runtime_procUnpin()
+			rt.ProcUnpin()
 			return nil
 		}
 		if typ == unsafe.Pointer(&firstStoreInProgress) {
@@ -152,15 +153,15 @@ func (v *Value) CompareAndSwap(old, new any) (swapped bool) {
 			// Disable preemption so that other goroutines can use
 			// active spin wait to wait for completion; and so that
 			// GC does not see the fake type accidentally.
-			runtime_procPin()
+			rt.ProcPin()
 			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
-				runtime_procUnpin()
+				rt.ProcUnpin()
 				continue
 			}
 			// Complete first store.
 			StorePointer(&vp.data, np.data)
 			StorePointer(&vp.typ, np.typ)
-			runtime_procUnpin()
+			rt.ProcUnpin()
 			return true
 		}
 		if typ == unsafe.Pointer(&firstStoreInProgress) {
@@ -188,7 +189,3 @@ func (v *Value) CompareAndSwap(old, new any) (swapped bool) {
 		return CompareAndSwapPointer(&vp.data, data, np.data)
 	}
 }
-
-// Disable/enable preemption, implemented in runtime.
-func runtime_procPin() int
-func runtime_procUnpin()

src/sync/export_test.go

@@ -4,11 +4,13 @@
 
 package sync
 
+import "internal/runtime"
+
 // Export for testing.
 var Runtime_Semacquire = runtime_Semacquire
 var Runtime_Semrelease = runtime_Semrelease
-var Runtime_procPin = runtime_procPin
-var Runtime_procUnpin = runtime_procUnpin
+var Runtime_procPin = runtime.ProcPin
+var Runtime_procUnpin = runtime.ProcUnpin
 
 // poolDequeue testing.
 type PoolDequeue interface {

src/sync/pool.go

@@ -6,6 +6,7 @@ package sync
 
 import (
 	"internal/race"
+	rt "internal/runtime"
 	"runtime"
 	"sync/atomic"
 	"unsafe"
@@ -112,7 +113,7 @@ func (p *Pool) Put(x any) {
 	} else {
 		l.shared.pushHead(x)
 	}
-	runtime_procUnpin()
+	rt.ProcUnpin()
 	if race.Enabled {
 		race.Enable()
 	}
@@ -142,7 +143,7 @@ func (p *Pool) Get() any {
 			x = p.getSlow(pid)
 		}
 	}
-	runtime_procUnpin()
+	rt.ProcUnpin()
 	if race.Enabled {
 		race.Enable()
 		if x != nil {
@@ -205,7 +206,7 @@ func (p *Pool) pin() (*poolLocal, int) {
 		panic("nil Pool")
 	}
 
-	pid := runtime_procPin()
+	pid := rt.ProcPin()
 	// In pinSlow we store to local and then to localSize, here we load in opposite order.
 	// Since we've disabled preemption, GC cannot happen in between.
 	// Thus here we must observe local at least as large localSize.
@@ -221,10 +222,10 @@ func (p *Pool) pin() (*poolLocal, int) {
 func (p *Pool) pinSlow() (*poolLocal, int) {
 	// Retry under the mutex.
 	// Can not lock the mutex while pinned.
-	runtime_procUnpin()
+	rt.ProcUnpin()
 	allPoolsMu.Lock()
 	defer allPoolsMu.Unlock()
-	pid := runtime_procPin()
+	pid := rt.ProcPin()
 	// poolCleanup won't be called while we are pinned.
 	s := p.localSize
 	l := p.local
@@ -292,8 +293,6 @@ func indexLocal(l unsafe.Pointer, i int) *poolLocal {
 
 // Implemented in runtime.
 func runtime_registerPoolCleanup(cleanup func())
-func runtime_procPin() int
-func runtime_procUnpin()
 
 // The below are implemented in internal/runtime/atomic and the
 // compiler also knows to intrinsify the symbol we linkname into this