From b60854e8bce493c45d724648cc6e69f91189c797 Mon Sep 17 00:00:00 2001
From: "Jason T. Greene" <jason.greene@redhat.com>
Date: Thu, 24 Mar 2022 22:57:01 -0500
Subject: Prefer registering both machine and global pipe

Signed-off-by: Jason T. Greene <jason.greene@redhat.com>
---
 pkg/machine/wsl/machine.go | 30 +++++++++++++++++++-----------
 1 file changed, 19 insertions(+), 11 deletions(-)

diff --git a/pkg/machine/wsl/machine.go b/pkg/machine/wsl/machine.go
index 5128fa313..fdda45ca6 100644
--- a/pkg/machine/wsl/machine.go
+++ b/pkg/machine/wsl/machine.go
@@ -145,6 +145,8 @@ http://docs.microsoft.com/en-us/windows/wsl/install\
 const (
 	winSShProxy    = "win-sshproxy.exe"
 	winSshProxyTid = "win-sshproxy.tid"
+	pipePrefix     = "npipe:////./pipe/"
+	globalPipe     = "docker_engine"
 )
 
 type Provider struct{}
@@ -801,16 +803,15 @@ func (v *MachineVM) Start(name string, _ machine.StartOptions) error {
 }
 
 func launchWinProxy(v *MachineVM) (bool, string, error) {
-	globalName := true
-	pipeName := "docker_engine"
-	if !pipeAvailable(pipeName) {
-		pipeName = toDist(v.Name)
-		globalName = false
-		if !pipeAvailable(pipeName) {
-			return globalName, "", errors.Errorf("could not start api proxy since expected pipe is not available: %s", pipeName)
-		}
+	machinePipe := toDist(v.Name)
+	if !pipeAvailable(machinePipe) {
+		return false, "", errors.Errorf("could not start api proxy since expected pipe is not available: %s", machinePipe)
+	}
+
+	globalName := false
+	if pipeAvailable(globalPipe) {
+		globalName = true
 	}
-	fullPipeName := "npipe:////./pipe/" + pipeName
 
 	exe, err := os.Executable()
 	if err != nil {
@@ -829,12 +830,19 @@ func launchWinProxy(v *MachineVM) (bool, string, error) {
 	}
 
 	dest := fmt.Sprintf("ssh://root@localhost:%d/run/podman/podman.sock", v.Port)
-	cmd := exec.Command(command, v.Name, stateDir, fullPipeName, dest, v.IdentityPath)
+	args := []string{v.Name, stateDir, pipePrefix + machinePipe, dest, v.IdentityPath}
+	waitPipe := machinePipe
+	if globalName {
+		args = append(args, pipePrefix+globalPipe, dest, v.IdentityPath)
+		waitPipe = globalPipe
+	}
+
+	cmd := exec.Command(command, args...)
 	if err := cmd.Start(); err != nil {
 		return globalName, "", err
 	}
 
-	return globalName, fullPipeName, waitPipeExists(pipeName, 30, func() error {
+	return globalName, pipePrefix + waitPipe, waitPipeExists(waitPipe, 30, func() error {
 		active, exitCode := getProcessState(cmd.Process.Pid)
 		if !active {
 			return errors.Errorf("win-sshproxy.exe failed to start, exit code: %d (see windows event logs)", exitCode)
-- 
cgit v1.2.3-54-g00ecf