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 ba586b002b01a207d60027e7b30070293ee6e829..68f478ca60cde2bb4d359ee350b73c89cbb4bec9 100644 --- a/workspace-gateway/src/main/java/com/aliware/tianchi/CallbackListenerImpl.java +++ b/workspace-gateway/src/main/java/com/aliware/tianchi/CallbackListenerImpl.java @@ -17,7 +17,7 @@ public class CallbackListenerImpl implements CallbackListener { @Override public void receiveServerMsg(String msg) { - System.out.println("receive msg from server :" + msg); + //System.out.println("receive msg from server :" + msg); String[] rcvmsglist = msg.split(","); if (rcvmsglist[0].equals("small")) memory_small = Long.parseLong(rcvmsglist[1]); else if (rcvmsglist[0].equals("medium")) memory_medium = Long.parseLong(rcvmsglist[1]); @@ -25,7 +25,7 @@ public class CallbackListenerImpl implements CallbackListener { long memory_sum = memory_large + memory_medium + memory_small; - System.out.println(msg + " : " + memory_large + ',' + memory_medium + ',' + memory_small + " | " + memory_sum); + //System.out.println(msg + " : " + memory_large + ',' + memory_medium + ',' + memory_small + " | " + memory_sum); UserLoadBalance.weight_large = 6.0 * memory_large / memory_sum; UserLoadBalance.weight_medium = 6.0 * memory_medium / memory_sum; diff --git a/workspace-gateway/src/main/java/com/aliware/tianchi/UserLoadBalance.java b/workspace-gateway/src/main/java/com/aliware/tianchi/UserLoadBalance.java index 0cc84ad8f0f66f12fc4428adb7f7d63f944bac11..f783b5d051fe82efb58d2c4bfac650c71377a3ca 100644 --- a/workspace-gateway/src/main/java/com/aliware/tianchi/UserLoadBalance.java +++ b/workspace-gateway/src/main/java/com/aliware/tianchi/UserLoadBalance.java @@ -29,7 +29,7 @@ public class UserLoadBalance implements LoadBalance { int id = 2; if (thread < weight_small) id = 0; else if (thread < weight_small + weight_medium) id = 1; - System.out.println(id + " | " + weight_large + ',' + weight_medium + ',' + weight_small); + //System.out.println(id + " | " + weight_large + ',' + weight_medium + ',' + weight_small); return invokers.get(id); } } diff --git a/workspace-provider/src/main/java/com/aliware/tianchi/TestRequestLimiter.java b/workspace-provider/src/main/java/com/aliware/tianchi/TestRequestLimiter.java index 5d60f743e59ce6fb9f351392d9c13ae6b9237287..90475a52b26519a8772a5f24dfc7c111c4b89c3d 100644 --- a/workspace-provider/src/main/java/com/aliware/tianchi/TestRequestLimiter.java +++ b/workspace-provider/src/main/java/com/aliware/tianchi/TestRequestLimiter.java @@ -20,7 +20,7 @@ public class TestRequestLimiter implements RequestLimiter { */ @Override public boolean tryAcquire(Request request, int activeTaskCount) { - if (activeTaskCount > 2000) return false; + //if (activeTaskCount > 2000) return false; return true; }