p05617423
/
bench4q
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

refactor 

refactor
This commit is contained in:
coderfengyun 2014-07-19 10:02:11 +08:00
parent 41190529b1
commit da70ff117b
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Bench4Q-Master/src/main/java/org/bench4q/master/domain/factory/PluginDomainFactory.java
View File

@ -62,7 +62,6 @@ public class PluginDomainFactory {
private PluginInfoModel createPluginInfoModel(PluginInfo pluginInfo) {
PluginInfoModel pluginInfoModel = new PluginInfoModel();
pluginInfoModel.setName(pluginInfo.getName());
pluginInfoModel.setNameCN(pluginInfo.getNameCN());
pluginInfoModel.setParamInfoModels(createParamInfoModels(pluginInfo
.getParams()));
pluginInfoModel
@ -82,7 +81,6 @@ public class PluginDomainFactory {
private BehaviorInfoModel createBehaviorInfoModel(BehaviorInfo behaviorInfo) {
BehaviorInfoModel behaviorInfoModel = new BehaviorInfoModel();
behaviorInfoModel.setName(behaviorInfo.getName());
behaviorInfoModel.setNameCN(behaviorInfo.getNameCN());
behaviorInfoModel.setParamInfoModels(createParamInfoModels(behaviorInfo
.getParams()));
behaviorInfoModel.setGroupModels(createGroupModels(behaviorInfo
@ -143,7 +141,6 @@ public class PluginDomainFactory {
}
GroupModel groupModel = new GroupModel();
groupModel.setName(group.getName());
groupModel.setNameCN(group.getNameCN());
groupModel.setParamInfoModels(createParamInfoModels(group.getParams()));
return groupModel;

7
Bench4Q-Master/src/main/java/org/bench4q/master/infrastructure/highavailable/impl/HighAvailablePoolImpl.java
View File

@ -152,8 +152,7 @@ public class HighAvailablePoolImpl extends CurrentLoadSubject implements
private void heartBeatsAndUpdateHAPool() {
Map<Agent, Future<ServerStatusModel>> map = new HashMap<Agent, Future<ServerStatusModel>>();
for (Agent agent : this.getPool().values()) {
CheckHearBeat checkHearBeat = new CheckHearBeat(agent,
agentMessenger);
HearBeat checkHearBeat = new HearBeat(agent, agentMessenger);
map.put(agent, this.excuExecutorService.submit(checkHearBeat));
}
this.updateAgentPoolByHeart(map);
@ -351,7 +350,7 @@ public class HighAvailablePoolImpl extends CurrentLoadSubject implements
}
class CheckHearBeat implements Callable<ServerStatusModel> {
class HearBeat implements Callable<ServerStatusModel> {
private Agent agent;
private AgentMessenger agentMessenger;
@ -359,7 +358,7 @@ class CheckHearBeat implements Callable<ServerStatusModel> {
return agentMessenger;
}
public CheckHearBeat(Agent agent, AgentMessenger agentMessenger) {
public HearBeat(Agent agent, AgentMessenger agentMessenger) {
this.agent = agent;
this.agentMessenger = agentMessenger;
}