fix(host): add startPodLock for pod instance

pkg/hostman/guestman/pod.go

@@ -26,6 +26,7 @@ import (
 	"path/filepath"
 	"strconv"
 	"strings"
+	"sync"
 	"time"
 
 	runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1"
@@ -216,12 +217,15 @@ type sPodGuestInstance struct {
 	containers     map[string]*sContainer
 	startStat      *startStatHelper
 	expectedStatus *PodExpectedStatus
+
+	startPodLock sync.Mutex
 }
 
 func newPodGuestInstance(id string, man *SGuestManager) PodInstance {
 	p := &sPodGuestInstance{
 		sBaseGuestInstance: newBaseGuestInstance(id, man, computeapi.HYPERVISOR_POD),
 		containers:         make(map[string]*sContainer),
+		startPodLock:       sync.Mutex{},
 	}
 	es, err := NewPodExpectedStatus(p.HomeDir(), computeapi.VM_UNKNOWN)
 	if err != nil {
@@ -737,6 +741,9 @@ func (s *sPodGuestInstance) ShouldRestartPodOnCrash() bool {
 }
 
 func (s *sPodGuestInstance) startPod(ctx context.Context, userCred mcclient.TokenCredential) (*computeapi.PodStartResponse, error) {
+	s.startPodLock.Lock()
+	defer s.startPodLock.Unlock()
+
 	retries := 3
 	sec := 5 * time.Second
 	var err error

pkg/hostman/guestman/pod_sync_loop.go

@@ -131,7 +131,12 @@ func (m *SGuestManager) syncContainerLoopIteration(plegCh chan *pleg.PodLifecycl
 			log.Infof("pod %s is dirty shutdown, waiting it to started", podMan.GetName())
 			return
 		}
+		podInstance := podMan.(*sPodGuestInstance)
 		if e.Type == pleg.ContainerStarted {
+			// 防止读取 podMan.GetCRIId 还没有刷新的问题
+			podInstance.startPodLock.Lock()
+			defer podInstance.startPodLock.Unlock()
+
 			log.Infof("pod container started: %s", jsonutils.Marshal(e))
 			ctrId := e.Data.(string)
 			if ctrId == podMan.GetCRIId() {