Function startMockMaintNotificationsDowngradeServer

internal_maint_notif_test.go:547–568

(t *testing.T)

}

func startMockMaintNotificationsDowngradeServer(t *testing.T) *mockMaintNotificationsDowngradeServer {
	t.Helper()
	ln, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		t.Fatalf("failed to listen: %v", err)
	}
	s := &mockMaintNotificationsDowngradeServer{
		ln:               ln,
		firstPingBlocked: make(chan struct{}),
		releaseFirstPing: make(chan struct{}),
	}
	go func() {
		for {
			conn, err := ln.Accept()
			if err != nil {
				return
			}
			go s.handle(conn)
		}
	}()
	return s
}

func TestClient_ModeAutoDowngradeRetiresEnabledInUseConnOnPut(t *testing.T) {
	srv := startMockMaintNotificationsDowngradeServer(t)