Revert "[ws-daemon] Change readiness behavior to wait for registry-facade (#1…" (#19668)

This reverts commit a2a81e0.

Author: iQQBot

components/ws-daemon/pkg/container/config.go

@@ -35,8 +35,6 @@ type Config struct {
 
 	// Containerd contains the containerd CRI config if runtime == RuntimeContainerd
 	Containerd *ContainerdConfig `json:"containerd,omitempty"`
-
-	RegistryFacadeHost string `json:"registryFacadeHost,omitempty"`
 }
 
 // RuntimeType lists the supported container runtimes
@@ -65,7 +63,7 @@ func FromConfig(cfg *Config) (rt Runtime, err error) {
 		if cfg.Containerd == nil {
 			return nil, xerrors.Errorf("runtime is set to containerd, but not containerd config is provided")
 		}
-		return NewContainerd(cfg.Containerd, cfg.Mapping, cfg.RegistryFacadeHost)
+		return NewContainerd(cfg.Containerd, cfg.Mapping)
 	default:
 		return nil, xerrors.Errorf("unknown runtime type: %s", cfg.Runtime)
 	}

components/ws-daemon/pkg/container/containerd.go

@@ -38,7 +38,7 @@ const (
 )
 
 // NewContainerd creates a new containerd adapter
-func NewContainerd(cfg *ContainerdConfig, pathMapping PathMapping, registryFacadeHost string) (*Containerd, error) {
+func NewContainerd(cfg *ContainerdConfig, pathMapping PathMapping) (*Containerd, error) {
 	cc, err := containerd.New(cfg.SocketPath, containerd.WithDefaultNamespace(kubernetesNamespace))
 	if err != nil {
 		return nil, xerrors.Errorf("cannot connect to containerd at %s: %w", cfg.SocketPath, err)
@@ -58,8 +58,6 @@ func NewContainerd(cfg *ContainerdConfig, pathMapping PathMapping, registryFacad
 		cntIdx: make(map[string]*containerInfo),
 		podIdx: make(map[string]*containerInfo),
 		wsiIdx: make(map[string]*containerInfo),
-
-		registryFacadeHost: registryFacadeHost,
 	}
 	go res.start()
 
@@ -75,8 +73,6 @@ type Containerd struct {
 	podIdx map[string]*containerInfo
 	wsiIdx map[string]*containerInfo
 	cntIdx map[string]*containerInfo
-
-	registryFacadeHost string
 }
 
 type containerInfo struct {
@@ -480,31 +476,9 @@ func (s *Containerd) ContainerPID(ctx context.Context, id ID) (pid uint64, err e
 	return uint64(info.PID), nil
 }
 
+// ContainerPID returns the PID of the container's namespace root process, e.g. the container shim.
 func (s *Containerd) IsContainerdReady(ctx context.Context) (bool, error) {
-	if len(s.registryFacadeHost) == 0 {
-		return s.Client.IsServing(ctx)
-	}
-
-	// check registry facade can reach containerd and returns image not found.
-	isServing, err := s.Client.IsServing(ctx)
-	if err != nil {
-		return false, err
-	}
-
-	if !isServing {
-		return false, nil
-	}
-
-	_, err = s.Client.GetImage(ctx, fmt.Sprintf("%v/not-a-valid-image:latest", s.registryFacadeHost))
-	if err != nil {
-		if errdefs.IsNotFound(err) {
-			return true, nil
-		}
-
-		return false, nil
-	}
-
-	return true, nil
+	return s.Client.IsServing(ctx)
 }
 
 var kubepodsQoSRegexp = regexp.MustCompile(`([^/]+)-([^/]+)-pod`)

components/ws-daemon/pkg/daemon/config.go

@@ -30,8 +30,6 @@ type Config struct {
 	OOMScores           cgroup.OOMScoreAdjConfig  `json:"oomScores"`
 	DiskSpaceGuard      diskguard.Config          `json:"disk"`
 	WorkspaceController WorkspaceControllerConfig `json:"workspaceController"`
-
-	RegistryFacadeHost string `json:"registryFacadeHost,omitempty"`
 }
 
 type WorkspaceControllerConfig struct {

install/installer/pkg/components/ws-daemon/configmap.go

@@ -113,7 +113,6 @@ func configmap(ctx *common.RenderContext) ([]runtime.Object, error) {
 
 	wsdcfg := wsdconfig.Config{
 		Daemon: daemon.Config{
-			RegistryFacadeHost: fmt.Sprintf("reg.%s:%d", ctx.Config.Domain, common.RegistryFacadeServicePort),
 			Runtime: daemon.RuntimeConfig{
 				KubernetesNamespace: ctx.Namespace,
 				SecretsNamespace:    common.WorkspaceSecretsNamespace,