aboutsummaryrefslogtreecommitdiffhomepage
path: root/internal/pipewire/core.go
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-12-06 21:09:55 +0900
committerOphestra <cat@gensokyo.uk>2025-12-06 21:09:55 +0900
commitbb1fc4c7bcd9730b774f2afb079b814c928c0b5a (patch)
tree0400e5461a27233608d97a2b45ff2662b88cc17e /internal/pipewire/core.go
parentf44923da296720360e359016ac83c6a56deeb0f1 (diff)
internal/pipewire: check pending ids after done
This is not guaranteed to have completed after a roundtrip. This is leftover from when Roundtrip also sent and waited for sync. Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/pipewire/core.go')
-rw-r--r--internal/pipewire/core.go6
1 files changed, 6 insertions, 0 deletions
diff --git a/internal/pipewire/core.go b/internal/pipewire/core.go
index 4642bdba..6a8af0ba 100644
--- a/internal/pipewire/core.go
+++ b/internal/pipewire/core.go
@@ -3,6 +3,8 @@ package pipewire
import (
"errors"
"fmt"
+ "maps"
+ "slices"
"strconv"
"time"
)
@@ -373,6 +375,10 @@ func (core *Core) Sync() error {
}
}
+ if len(core.ctx.pendingIds) != 0 {
+ core.ctx.closeReceivedFiles()
+ return &ProxyFatalError{Err: UnacknowledgedProxyError(slices.Collect(maps.Keys(core.ctx.pendingIds))), ProxyErrs: core.ctx.cloneAsProxyErrors()}
+ }
return core.ctx.doSyncComplete()
}