jxing преди 6 години
родител
ревизия
2269c77dd6

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

@@ -172,10 +172,10 @@ public class DispatchTask implements Runnable {
                 wrapper = null;
                 clientCount = clientList.size();
             }
-            if(!wrapper.isLastRefuseTimeOutPassed()){
+            if(wrapper == null || !wrapper.isLastRefuseTimeOutPassed()){
                 wrapper = null;
             }
-            if(wrapper.getClientInfo() == null || wrapper.getClientInfo().length() == 0)
+            if(wrapper == null || wrapper.getClientInfo() == null || wrapper.getClientInfo().length() == 0)
                 wrapper = null;
             if(clientCount == 0)
                 return null;

+ 1 - 1
scheduler/src/main/java/cn/sagacloud/server/SchedulerHandler.java

@@ -65,7 +65,7 @@ public class SchedulerHandler extends ChannelInboundHandlerAdapter {
      */
     @Override
     public void handlerAdded(ChannelHandlerContext ctx) {
-        SocketAddress addr = ctx.channel().remoteAddress();
+        //SocketAddress addr = ctx.channel().remoteAddress();
         System.out.println("client incoming");
     }