Function handleProcessData

agent/utils/websocket/process_data.go:160–207

(proc *process.Process, processConfig *PsProcessConfig, pidConnections map[int32][]net.ConnectionStat)

}

func handleProcessData(proc *process.Process, processConfig *PsProcessConfig, pidConnections map[int32][]net.ConnectionStat) *PsProcessData {
	if processConfig.Pid > 0 && processConfig.Pid != proc.Pid {
		return nil
	}
	procData := PsProcessData{
		PID: proc.Pid,
	}
	if procName, err := proc.Name(); err == nil {
		procData.Name = procName
	} else {
		procData.Name = "<UNKNOWN>"
	}
	if processConfig.Name != "" && !strings.Contains(procData.Name, processConfig.Name) {
		return nil
	}
	if username, err := proc.Username(); err == nil {
		procData.Username = username
	}
	if processConfig.Username != "" && !strings.Contains(procData.Username, processConfig.Username) {
		return nil
	}
	procData.PPID, _ = proc.Ppid()
	statusArray, _ := proc.Status()
	if len(statusArray) > 0 {
		procData.Status = strings.Join(statusArray, ",")
	}
	createTime, procErr := proc.CreateTime()
	if procErr == nil {
		t := time.Unix(createTime/1000, 0)
		procData.StartTime = t.Format("2006-1-2 15:04:05")
	}
	procData.NumThreads, _ = proc.NumThreads()
	procData.CpuValue, _ = proc.CPUPercent()
	procData.CpuPercent = fmt.Sprintf("%.2f%%", procData.CpuValue)

	if memInfo, err := proc.MemoryInfo(); err == nil {
		procData.RssValue = memInfo.RSS
		procData.Rss = common.FormatBytes(memInfo.RSS)
	} else {
		procData.RssValue = 0
	}

	if connections, ok := pidConnections[proc.Pid]; ok {
		procData.NumConnections = len(connections)
	}

	return &procData
}

func getProcessData(processConfig PsProcessConfig) (res []byte, err error) {
	ctx, cancel := context.WithTimeout(context.Background(), defaultTimeout)