loop_lock.go RawHistoryFolder

1package capi
2
3import (
4	"unsafe"
5
6	"github.com/bnema/purego"
7)
8
9// pw_loop_lock/pw_loop_unlock are kept as handwritten internal bindings
10// because they are only used inside capi to satisfy PipeWire's thread/locking
11// requirements for stream lifecycle calls. Exposing them through generated
12// ports would leak a low-level implementation detail upward.
13type pwLoopControlFunc func(loop unsafe.Pointer) int32
14
15var (
16	pw_loop_lock   pwLoopControlFunc
17	pw_loop_unlock pwLoopControlFunc
18)
19
20func registerLoopLock(handle uintptr) {
21	purego.RegisterLibFunc(&pw_loop_lock, handle, "pw_loop_lock")
22	purego.RegisterLibFunc(&pw_loop_unlock, handle, "pw_loop_unlock")
23}
24
25var withLoopLock = defaultWithLoopLock
26
27func defaultWithLoopLock(loop unsafe.Pointer, fn func() int32) int32 {
28	if loop == nil || pw_loop_lock == nil || pw_loop_unlock == nil {
29		return -1
30	}
31	if ret := pw_loop_lock(loop); ret < 0 {
32		return ret
33	}
34	ret := fn()
35	unlockRet := pw_loop_unlock(loop)
36	if ret >= 0 && unlockRet < 0 {
37		return unlockRet
38	}
39	return ret
40}