Method appendResourceProcess

server/controller/cloud/cloud.go:658–715

(resource model.Resource)

}

func (c *Cloud) appendResourceProcess(resource model.Resource) model.Resource {

	if genesis.GenesisService == nil {
		log.Error("genesis service is nil", logger.NewORGPrefix(c.orgID))
		return resource
	}

	genesisSyncData, err := genesis.GenesisService.GetGenesisSyncResponse(c.orgID)
	if err != nil {
		log.Error(err.Error(), logger.NewORGPrefix(c.orgID))
		return resource
	}

	vtapIDToLcuuid, err := cloudcommon.GetVTapSubDomainMappingByDomain(c.basicInfo.Lcuuid, c.db.DB)
	if err != nil {
		log.Errorf("domain (%s) add process failed: %s", c.basicInfo.Name, err.Error(), logger.NewORGPrefix(c.orgID))
		return resource
	}

	for _, sProcess := range genesisSyncData.Processes {
		lcuuid, ok := vtapIDToLcuuid[int(sProcess.VtapID)]
		if !ok {
			continue
		}
		name, processName := sProcess.Name, sProcess.ProcessName
		if len(sProcess.Name) > c.cfg.ProcessNameLenMax {
			name = sProcess.Name[:c.cfg.ProcessNameLenMax]
		}
		if len(sProcess.ProcessName) > c.cfg.ProcessNameLenMax {
			processName = sProcess.ProcessName[:c.cfg.ProcessNameLenMax]
		}
		process := model.Process{
			Lcuuid:      sProcess.Lcuuid,
			Name:        name,
			VTapID:      sProcess.VtapID,
			PID:         sProcess.PID,
			NetnsID:     sProcess.NetnsID,
			ProcessName: processName,
			CommandLine: sProcess.CMDLine,
			UserName:    sProcess.UserName,
			ContainerID: sProcess.ContainerID,
			StartTime:   sProcess.StartTime,
			OSAPPTags:   sProcess.OSAPPTags,
		}
		if resource.Verified && lcuuid == "" {
			resource.Processes = append(resource.Processes, process)
			continue
		}
		subDomainResource, ok := resource.SubDomainResources[lcuuid]
		if !ok || !subDomainResource.Verified {
			continue
		}
		process.SubDomainLcuuid = lcuuid
		subDomainResource.Processes = append(subDomainResource.Processes, process)
		resource.SubDomainResources[lcuuid] = subDomainResource
	}
	return resource
}