hostagent: avoid requiring fuser and ss in the guest

No need to check the guestagent socket with `fuser` or `ss`,
if the guestagent is actually functional

Fix issue 2010

Signed-off-by: Akihiro Suda <[email protected]>

Author: AkihiroSuda

pkg/hostagent/hostagent.go

@@ -57,6 +57,9 @@ type HostAgent struct {
 
 	clientMu sync.RWMutex
 	client   guestagentclient.GuestAgentClient
+
+	guestAgentAlive   *time.Time
+	guestAgentAliveMu sync.RWMutex
 }
 
 type options struct {
@@ -495,6 +498,20 @@ sudo chown -R "${USER}" /run/host-services`
 	if err := a.waitForRequirements("final", a.finalRequirements()); err != nil {
 		errs = append(errs, err)
 	}
+	if !*a.y.Plain {
+		a.guestAgentAliveMu.RLock()
+		guestAgentAlive := a.guestAgentAlive
+		a.guestAgentAliveMu.RUnlock()
+		if guestAgentAlive == nil {
+			err := errors.New("lima-guestagent does not seem to be running; port forwards will not work")
+			if *a.y.VMType == limayaml.WSL2 {
+				// geustagent is currently not available for WSL2: https://github.com/lima-vm/lima/issues/2025
+				logrus.Warn(err)
+			} else {
+				errs = append(errs, err)
+			}
+		}
+	}
 	// Copy all config files _after_ the requirements are done
 	for _, rule := range a.y.CopyToHost {
 		if err := copyToHost(ctx, a.sshConfig, a.sshLocalPort, rule.HostFile, rule.GuestFile); err != nil {
@@ -605,6 +622,11 @@ func (a *HostAgent) processGuestAgentEvents(ctx context.Context, client guestage
 	if err != nil {
 		return err
 	}
+	logrus.Info("Guest agent is running")
+	infoTime := time.Now()
+	a.guestAgentAliveMu.Lock()
+	a.guestAgentAlive = &infoTime
+	a.guestAgentAliveMu.Unlock()
 
 	logrus.Debugf("guest agent info: %+v", info)
 

pkg/hostagent/requirements.go

@@ -6,7 +6,6 @@ import (
 	"time"
 
 	"github.com/lima-vm/lima/pkg/limayaml"
-	"github.com/lima-vm/lima/pkg/store/filenames"
 	"github.com/lima-vm/sshocker/pkg/ssh"
 	"github.com/sirupsen/logrus"
 )
@@ -120,40 +119,6 @@ fi
 			debugHint: `Append "user_allow_other" to /etc/fuse.conf (/etc/fuse3.conf) in the guest`,
 		})
 	}
-	if a.vSockPort != 0 {
-		req = append(req, requirement{
-			description: "the guest agent to be running",
-			script: fmt.Sprintf(`#!/bin/bash
-set -eux -o pipefail
-if ! timeout 30s bash -c "until ss -a -n --vsock --listen | grep -q ':%d'; do sleep 3; done"; then
-	echo >&2 "lima-guestagent is not installed yet"
-	exit 1
-fi
-`, a.vSockPort),
-			debugHint: fmt.Sprintf(`The guest agent with vsockPort %d does not seem running.
-Make sure that you are using an officially supported image.
-Also see "/var/log/cloud-init-output.log" in the guest.
-A possible workaround is to run "lima-guestagent install-systemd" in the guest.
-`, a.vSockPort),
-		})
-	} else {
-		req = append(req, requirement{
-			description: "the guest agent to be running",
-			script: fmt.Sprintf(`#!/bin/bash
-set -eux -o pipefail
-sock="/dev/virtio-ports/%s"
-if ! timeout 30s bash -c "until sudo fuser \"${sock}\" || sudo lsof \"${sock}\"; do sleep 3; done"; then
-	echo >&2 "lima-guestagent is not installed yet"
-	exit 1
-fi
-`, filenames.VirtioPort),
-			debugHint: fmt.Sprintf(`The guest agent with serialport /dev/virtio-ports/%s does not seem running.
-Make sure that you are using an officially supported image.
-Also see "/var/log/cloud-init-output.log" in the guest.
-A possible workaround is to run "lima-guestagent install-systemd" in the guest.
-`, filenames.VirtioPort),
-		})
-	}
 	return req
 }