context.go RawHistoryFolder

1package core
2
3import (
4	"errors"
5	"unsafe"
6
7	portout "github.com/bnema/purego-pipewire/internal/ports/out"
8)
9
10var ErrContextCreate = errors.New("failed to create context")
11
12// Context wraps a pw_context. Create it with Runtime.NewContext and destroy
13// it before the Loop it was created on.
14type Context struct {
15	ptr  unsafe.Pointer
16	capi portout.VideoStreamAPI
17	shm  portout.SharedMemAPI
18}
19
20// NewContext creates a pw_context that runs on loop. The loop must outlive
21// the context.
22func (r *Runtime) NewContext(loop *Loop) (*Context, error) {
23	if loop == nil || loop.ptr == nil {
24		return nil, ErrContextCreate
25	}
26	ptr := r.capi.PWContextNew(loop.ptr, nil, 0)
27	if ptr == nil {
28		return nil, ErrContextCreate
29	}
30	return &Context{ptr: ptr, capi: r.capi, shm: memfdShm{}}, nil
31}
32
33// Destroy destroys the context. All cores connected from it must have been
34// disconnected first. Destroy is idempotent.
35func (c *Context) Destroy() {
36	if c.ptr == nil {
37		return
38	}
39	c.capi.PWContextDestroy(c.ptr)
40	c.ptr = nil
41}
42
43// Connect connects to the PipeWire daemon.
44func (c *Context) Connect() (*Core, error) {
45	if c.ptr == nil {
46		return nil, ErrCoreConnect
47	}
48	ptr := c.capi.PWContextConnect(c.ptr, nil, 0)
49	if ptr == nil {
50		return nil, ErrCoreConnect
51	}
52	return &Core{ptr: ptr, capi: c.capi, shm: c.shm}, nil
53}
54
55func (c *Context) Ptr() unsafe.Pointer {
56	return c.ptr
57}