Function getProcessData

agent/utils/websocket/process_data.go:209–242

(processConfig PsProcessConfig)

}

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

	processes, err := process.ProcessesWithContext(ctx)
	if err != nil {
		return
	}

	connections, err := net.ConnectionsMaxWithContext(ctx, "all", 32768)
	if err != nil {
		return
	}

	pidConnections := make(map[int32][]net.ConnectionStat, len(processes))
	for _, conn := range connections {
		if conn.Pid == 0 {
			continue
		}
		pidConnections[conn.Pid] = append(pidConnections[conn.Pid], conn)
	}

	result := make([]PsProcessData, 0, len(processes))

	for _, proc := range processes {
		procData := handleProcessData(proc, &processConfig, pidConnections)
		if procData != nil {
			result = append(result, *procData)
		}
	}

	res, err = json.Marshal(result)
	return
}

func getSSHSessions(config SSHSessionConfig) (res []byte, err error) {
	var (