diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-12-03 03:52:17 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-12-03 03:52:17 +0900 |
| commit | 2c0b92771a95693af7f14a70ddeddc5371e73996 (patch) | |
| tree | 38c5e3cf06ecdee79db7d373c68dfbd4fe3b7e6b /internal/pipewire/pipewire_test.go | |
| parent | 054c91879fccc22466da942462497e048c057a54 (diff) | |
internal/pipewire: relocate constants
This should make things easier to navigate, and possible to fully automatically generate the constants in the future.
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/pipewire/pipewire_test.go')
| -rw-r--r-- | internal/pipewire/pipewire_test.go | 53 |
1 files changed, 0 insertions, 53 deletions
diff --git a/internal/pipewire/pipewire_test.go b/internal/pipewire/pipewire_test.go index f7df3ab1..f819dff8 100644 --- a/internal/pipewire/pipewire_test.go +++ b/internal/pipewire/pipewire_test.go @@ -1,8 +1,6 @@ package pipewire_test import ( - _ "embed" - "encoding/binary" "fmt" "net" "reflect" @@ -813,57 +811,6 @@ func (conn *stubUnixConn) Close() error { return nil } -var ( - //go:embed testdata/pw-container-00-sendmsg - samplePWContainer00 string - //go:embed testdata/pw-container-01-recvmsg - samplePWContainer01 string - //go:embed testdata/pw-container-03-sendmsg - samplePWContainer03 string - //go:embed testdata/pw-container-04-recvmsg - samplePWContainer04 string - //go:embed testdata/pw-container-06-sendmsg - samplePWContainer06 string - //go:embed testdata/pw-container-07-recvmsg - samplePWContainer07 string - - // samplePWContainer is a collection of messages from the pw-container sample. - samplePWContainer = [...][][3][]byte{ - splitMessages(samplePWContainer00), - splitMessages(samplePWContainer01), - nil, - splitMessages(samplePWContainer03), - splitMessages(samplePWContainer04), - nil, - splitMessages(samplePWContainer06), - splitMessages(samplePWContainer07), - nil, - } -) - -// splitMessages splits concatenated messages into groups of -// header, payload, footer of each individual message. -// splitMessages panics on any decoding error. -func splitMessages(iovec string) (messages [][3][]byte) { - data := []byte(iovec) - messages = make([][3][]byte, 0, 1<<7) - - var header pipewire.Header - for len(data) != 0 { - if err := header.UnmarshalBinary(data[:pipewire.SizeHeader]); err != nil { - panic(err) - } - size := pipewire.SizePrefix + binary.NativeEndian.Uint32(data[pipewire.SizeHeader:]) - messages = append(messages, [3][]byte{ - data[:pipewire.SizeHeader], - data[pipewire.SizeHeader : pipewire.SizeHeader+size], - data[pipewire.SizeHeader+size : pipewire.SizeHeader+header.Size], - }) - data = data[pipewire.SizeHeader+header.Size:] - } - return -} - func TestContextErrors(t *testing.T) { t.Parallel() |
