ソースを参照

agent 更新 ProcScanTask 任务

reghao 3 ヶ月 前
コミット
974d648765

+ 4 - 2
agent/src/main/java/cn/reghao/bnt/agent/task/ProcScanTask.java

@@ -57,7 +57,9 @@ public class ProcScanTask implements Runnable {
                     String state = osProcess.getState().name();
                     List<OSThread> osThreadList = osProcess.getThreadDetails();
                     String cmdLine = osProcess.getCommandLine();
-                    return new SysProcess(pid, name, ppid, cmdLine);
+                    long startTime = osProcess.getStartTime();
+                    String user = osProcess.getUser();
+                    return new SysProcess(pid, name, ppid, cmdLine, startTime, user);
                 })
                 .collect(Collectors.toMap(SysProcess::getPid, sp -> sp));
 
@@ -116,7 +118,7 @@ public class ProcScanTask implements Runnable {
     }
 
     private String byte2Str(byte[] buffer) {
-        String address = "-1:-1:-1:-1";
+        String address = "-1.-1.-1.-1";
         try {
             InetAddress inetAddress = InetAddress.getByAddress(buffer);
             address = inetAddress.getHostAddress();

+ 5 - 1
common/src/main/java/cn/reghao/bnt/common/machine/model/SysProcess.java

@@ -25,14 +25,18 @@ public class SysProcess implements Serializable {
     private int ppid;
     private String cmdLine;
     private Set<String> hostPorts;
+    private long startTime;
+    private String user;
     private String containerId;
     private String appId;
 
-    public SysProcess(int pid, String name, int ppid, String cmdLine) {
+    public SysProcess(int pid, String name, int ppid, String cmdLine, long startTime, String user) {
         this.pid = pid;
         this.name = name;
         this.ppid = ppid;
         this.cmdLine = cmdLine.length() > 255 ? cmdLine.substring(0, 255) : cmdLine;
         this.hostPorts = new HashSet<>();
+        this.startTime = startTime;
+        this.user = user;
     }
 }