소스 검색

限制在客户端没有发送基本信息前不派发任务

jxing 6 년 전
부모
커밋
b8259a38bb
1개의 변경된 파일2개의 추가작업 그리고 0개의 파일을 삭제
  1. 2 0
      scheduler/src/main/java/cn/sagacloud/server/DispatchTask.java

+ 2 - 0
scheduler/src/main/java/cn/sagacloud/server/DispatchTask.java

@@ -174,6 +174,8 @@ public class DispatchTask implements Runnable {
             if(!wrapper.isLastRefuseTimeOutPassed()){
                 wrapper = null;
             }
+            if(wrapper.getClientInfo() == null || wrapper.getClientInfo().length() == 0)
+                wrapper = null;
             if(clientCount == 0)
                 return null;
             clientIndex = (clientIndex + 1) % clientCount;