maemachinebroke/hakurei
1
0
Fork 0
forked from security/hakurei
Code Pull Requests Activity

internal/pipewire: treat unknown opcode as fatal

Browse Source 
Skipping events can cause local state to diverge from the server.

Signed-off-by: Ophestra <cat@gensokyo.uk>
This commit is contained in:
Ophestra
2025-12-11 04:22:03 +09:00
parent 47db461546
commit e60ff660f6
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/pipewire/client.go
View File

@@ -113,7 +113,7 @@ func (client *Client) consume(opcode byte, files []int, unmarshal func(v any)) e
return nil return nil
default: default:
return &UnsupportedOpcodeError{opcode, client.String()} panic(&UnsupportedOpcodeError{opcode, client.String()})
} }
} }

4
internal/pipewire/core.go
View File

@@ -764,7 +764,7 @@ func (core *Core) consume(opcode byte, files []int, unmarshal func(v any)) error
return proxy.setBoundProps(&boundProps) return proxy.setBoundProps(&boundProps)
default: default:
return &UnsupportedOpcodeError{opcode, core.String()} panic(&UnsupportedOpcodeError{opcode, core.String()})
} }
} }
@@ -831,7 +831,7 @@ func (registry *Registry) consume(opcode byte, files []int, unmarshal func(v any
return nil return nil
default: default:
return &UnsupportedOpcodeError{opcode, registry.String()} panic(&UnsupportedOpcodeError{opcode, registry.String()})
} }
} }

2
internal/pipewire/securitycontext.go
View File

@@ -190,7 +190,7 @@ func (securityContext *SecurityContext) consume(opcode byte, files []int, _ func
// SecurityContext does not receive any events // SecurityContext does not receive any events
default: default:
return &UnsupportedOpcodeError{opcode, securityContext.String()} panic(&UnsupportedOpcodeError{opcode, securityContext.String()})
} }
} }