mux_unsupported_test.go RawHistoryFolder

1//go:build !linux && !darwin
2
3package ipc
4
5import (
6	"context"
7	"errors"
8	"path/filepath"
9	"testing"
10	"time"
11)
12
13// TestMuxFailsClosedWithoutPeerCredentialCheck proves the private mux carriage
14// fails closed on a platform or build without the Linux SO_PEERCRED same-user
15// check: a bound listener refuses every peer instead of admitting an unverified
16// one, and dialing never returns an unverified transport.
17func TestMuxFailsClosedWithoutPeerCredentialCheck(t *testing.T) {
18	path := filepath.Join(shortSocketDir(t, "vev"), "mux.sock")
19	listener, err := ListenMux(path)
20	if err != nil {
21		t.Fatalf("ListenMux: %v", err)
22	}
23	defer func() { _ = listener.Close() }()
24
25	type dialOutcome struct {
26		transport interface{ Close() error }
27		err       error
28	}
29	dialed := make(chan dialOutcome, 1)
30	go func() {
31		transport, dialErr := DialMuxContext(context.Background(), path)
32		if transport == nil {
33			dialed <- dialOutcome{err: dialErr}
34			return
35		}
36		dialed <- dialOutcome{transport: transport, err: dialErr}
37	}()
38
39	transport, acceptErr := listener.Accept()
40	if transport != nil {
41		_ = transport.Close()
42		t.Fatal("Accept returned an unverified transport")
43	}
44	if !errors.Is(acceptErr, ErrMuxUnsupported) {
45		t.Fatalf("Accept error = %v, want ErrMuxUnsupported", acceptErr)
46	}
47
48	select {
49	case outcome := <-dialed:
50		if outcome.transport != nil {
51			_ = outcome.transport.Close()
52			t.Fatal("DialMuxContext returned an unverified transport")
53		}
54		if !errors.Is(outcome.err, ErrMuxUnsupported) {
55			t.Fatalf("DialMuxContext error = %v, want ErrMuxUnsupported", outcome.err)
56		}
57	case <-time.After(5 * time.Second):
58		t.Fatal("DialMuxContext did not return")
59	}
60}