From 20fc76309a68860e8961af6d7a4f78a22b46d4fa Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=BD=87=E6=B4=92?= <jundi.mjd@antfin.com>
Date: Tue, 16 Jul 2019 15:57:20 +0800
Subject: [PATCH] use cpu

---
 .../java/com/aliware/tianchi/CallbackListenerImpl.java    | 2 +-
 .../java/com/aliware/tianchi/CallbackServiceImpl.java     | 8 +++++---
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/workspace-gateway/src/main/java/com/aliware/tianchi/CallbackListenerImpl.java b/workspace-gateway/src/main/java/com/aliware/tianchi/CallbackListenerImpl.java
index 0388893..12c91a7 100644
--- a/workspace-gateway/src/main/java/com/aliware/tianchi/CallbackListenerImpl.java
+++ b/workspace-gateway/src/main/java/com/aliware/tianchi/CallbackListenerImpl.java
@@ -42,7 +42,7 @@ public class CallbackListenerImpl implements CallbackListener {
             UserLoadBalance.weight_large =  cpu_large*6.5 / cpu_sum;
             UserLoadBalance.weight_medium =  cpu_medium*4.5 / cpu_sum;
             UserLoadBalance.weight_small =  cpu_small*2.0 / cpu_sum;
-            //System.out.println( UserLoadBalance.weight_large +"  "+ UserLoadBalance.weight_medium+"  "+ UserLoadBalance.weight_small);
+            System.out.println( UserLoadBalance.weight_large +"  "+ UserLoadBalance.weight_medium+"  "+ UserLoadBalance.weight_small);
             mask = 0x0;
         }
     }
diff --git a/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java b/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java
index e5c15d5..ab13f57 100644
--- a/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java
+++ b/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java
@@ -37,7 +37,7 @@ public class CallbackServiceImpl implements CallbackService {
                     }
                 }
             }
-        }, 0, 5000);
+        }, 0, 1000);
     }
 
     private Timer timer = new Timer();
@@ -45,8 +45,10 @@ public class CallbackServiceImpl implements CallbackService {
     private String generateStatusMessage() {
         try {
             List<String> cpuLoadList = getProcessCpuLoad().stream().map(Object::toString).collect(Collectors.toList());
-            String cpuLoadString = String.join(",", cpuLoadList);
-            return "cpu=" + cpuLoadString;
+            //String cpuLoadString = String.join(",", cpuLoadList);
+            System.out.println(cpuLoadList.get(0));
+            return cpuLoadList.get(0);
+
         }
         catch(Exception ex) {
             return "error";
-- 
GitLab