ctripcorp/zeus
1
1
Fork 0
mirror of https://github.com/ctripcorp/zeus.git synced 2024-09-20 15:46:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

add not found online group data check

Browse source
This commit is contained in:
fanqq 2016-04-27 17:48:46 +08:00
parent 72894afdb2
commit 47c698339f
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/main/java/com/ctrip/zeus/executor/impl/TaskExecutorImpl.java
View file

@ -3,6 +3,7 @@ package com.ctrip.zeus.executor.impl;
import com.ctrip.framework.clogging.agent.log.ILog;
import com.ctrip.framework.clogging.agent.log.LogManager;
import com.ctrip.zeus.commit.entity.Commit;
import com.ctrip.zeus.exceptions.NginxProcessingException;
import com.ctrip.zeus.executor.TaskExecutor;
import com.ctrip.zeus.lock.DbLockFactory;
import com.ctrip.zeus.lock.DistLock;
@ -238,6 +239,10 @@ public class TaskExecutorImpl implements TaskExecutor {
need = true;
}
Group group = onlineGroups.get(gid);
if (group == null) {
logger.error("Not Found Online Group Data, GroupId: " + gid);
throw new NginxProcessingException("Not Found Online Group Data, GroupId: " + gid);
}
if (serverOps.size() > 0 && !need) {
for (GroupServer gs : group.getGroupServers()) {
if (serverOps.containsKey(gs.getIp())) {