diff options
Diffstat (limited to 'internal/pipewire/securitycontext.go')
| -rw-r--r-- | internal/pipewire/securitycontext.go | 32 |
1 files changed, 27 insertions, 5 deletions
diff --git a/internal/pipewire/securitycontext.go b/internal/pipewire/securitycontext.go index 21123f19..ec19a64a 100644 --- a/internal/pipewire/securitycontext.go +++ b/internal/pipewire/securitycontext.go @@ -111,17 +111,39 @@ func (registry *Registry) GetSecurityContext() (securityContext *SecurityContext } // Create queues a [SecurityContextCreate] message for the PipeWire server. -func (securityContext *SecurityContext) Create(listenFd, closeFd int, props SPADict) error { - if err := securityContext.checkDestroy(); err != nil { - return err +func (securityContext *SecurityContext) Create(listenFd, closeFd int, props SPADict) (err error) { + if err = securityContext.checkDestroy(); err != nil { + return + } + + asCoreError := securityContext.ctx.expectsCoreError(securityContext.ID, &err) + if err != nil { + return } // queued in reverse based on upstream behaviour, unsure why offset := securityContext.ctx.queueFiles(closeFd, listenFd) - return securityContext.ctx.writeMessage( + if err = securityContext.ctx.writeMessage( securityContext.ID, &SecurityContextCreate{ListenFd: offset + 1, CloseFd: offset + 0, Properties: &props}, - ) + ); err != nil { + return + } + if err = securityContext.ctx.GetCore().Sync(); err == nil { + return nil + } + + if coreError := asCoreError(); coreError == nil { + return + } else { + switch syscall.Errno(-coreError.Result) { + case syscall.EPERM: + return &PermissionError{securityContext.ID, coreError.Message} + + default: + return coreError + } + } } // securityContextCloser holds onto resources associated to the security context. |