diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-12-09 06:21:41 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-12-09 06:21:41 +0900 |
| commit | 130add21e56360b008b8954c6284ad4149cfaf68 (patch) | |
| tree | 963ed96d83f26d4d669160a23ee618d248171dcf | |
| parent | 5ec4045e248c19cd02ec76d52c21015acc5e2831 (diff) | |
internal/pipewire: increment remote sequence after establishing bounds
This avoids incrementing it twice proceeding from a partial message.
Signed-off-by: Ophestra <cat@gensokyo.uk>
| -rw-r--r-- | internal/pipewire/pipewire.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/pipewire/pipewire.go b/internal/pipewire/pipewire.go index 3025016b..6270429e 100644 --- a/internal/pipewire/pipewire.go +++ b/internal/pipewire/pipewire.go @@ -681,11 +681,11 @@ func (ctx *Context) consume(receiveRemaining []byte) (remaining []byte, err erro if header.Sequence != ctx.remoteSequence { return remaining, UnexpectedSequenceError(header.Sequence) } - ctx.remoteSequence++ if len(remaining) < int(SizeHeader+header.Size) { return } + ctx.remoteSequence++ proxy, ok := ctx.proxy[header.ID] if !ok { |