loop.go RawHistoryFolder

1package core
2
3import (
4	"errors"
5	"unsafe"
6
7	portout "github.com/bnema/purego-pipewire/internal/ports/out"
8)
9
10var ErrMainLoopCreate = errors.New("failed to create main loop")
11
12type MainLoop struct {
13	ptr  unsafe.Pointer
14	capi portout.CAPI
15}
16
17func (r *Runtime) NewMainLoop() (*MainLoop, error) {
18	ptr := r.capi.PWMainLoopNew(nil)
19	if ptr == nil {
20		return nil, ErrMainLoopCreate
21	}
22	return &MainLoop{ptr: ptr, capi: r.capi}, nil
23}
24
25func (ml *MainLoop) Run() int32 {
26	return ml.capi.PWMainLoopRun(ml.ptr)
27}
28
29func (ml *MainLoop) Destroy() {
30	ml.capi.PWMainLoopDestroy(ml.ptr)
31}
32
33func (ml *MainLoop) Ptr() unsafe.Pointer {
34	return ml.ptr
35}
36
37var ErrLoopCreate = errors.New("failed to create loop")
38
39// Loop wraps a pw_loop that the caller iterates itself, typically from a
40// poll loop that waits on Fd. A Loop and everything created on it (Context,
41// Core, streams) must only be used from one goroutine locked to one OS
42// thread (runtime.LockOSThread); PipeWire loops are not thread safe.
43type Loop struct {
44	ptr  unsafe.Pointer
45	capi portout.VideoStreamAPI
46}
47
48// NewLoop creates a pw_loop. The Runtime must be initialized.
49func (r *Runtime) NewLoop() (*Loop, error) {
50	ptr := r.capi.PWLoopNew(nil)
51	if ptr == nil {
52		return nil, ErrLoopCreate
53	}
54	return &Loop{ptr: ptr, capi: r.capi}, nil
55}
56
57// Fd returns the pollable file descriptor of the loop. It becomes readable
58// when Iterate has work to do.
59func (l *Loop) Fd() int {
60	return int(l.capi.PWLoopGetFd(l.ptr))
61}
62
63// Iterate dispatches the pending events without blocking (pw_loop_enter,
64// pw_loop_iterate with a zero timeout, pw_loop_leave). Stream callbacks run
65// inside it. A negative result such as -EINTR is not fatal and is ignored:
66// the next Iterate simply retries.
67func (l *Loop) Iterate() {
68	l.capi.PWLoopEnter(l.ptr)
69	_ = l.capi.PWLoopIterate(l.ptr, 0)
70	l.capi.PWLoopLeave(l.ptr)
71}
72
73// Destroy destroys the loop. Contexts created on it must be destroyed first.
74// Destroy is idempotent.
75func (l *Loop) Destroy() {
76	if l.ptr == nil {
77		return
78	}
79	l.capi.PWLoopDestroy(l.ptr)
80	l.ptr = nil
81}
82
83func (l *Loop) Ptr() unsafe.Pointer {
84	return l.ptr
85}