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

add try catch 

add try catch
This commit is contained in:
coderfengyun 2014-03-31 14:50:51 +08:00
parent efb6e56141
commit 5475ef7112
1 changed files with 25 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
Bench4Q-Master/src/main/java/org/bench4q/master/domain/service/TestPlanEngine.java
View File

@ -165,25 +165,30 @@ public class TestPlanEngine implements TaskCompleteCallback,
public TestPlan pickATestPlan() {
logger.info("enter pick");
List<Criterion> criterions = new ArrayList<Criterion>();
Criterion notComplete = Restrictions.not(Restrictions.eq(
"currentStatus", TestPlanStatus.Complete.name()));
criterions.add(notComplete);
Criterion notInRunning = Restrictions.not(Restrictions.eq(
"currentStatus", TestPlanStatus.InRunning.name()));
criterions.add(notInRunning);
Criterion lessThanPoolAvailbleLoad = Restrictions.lt("requiredLoad",
this.getHaPool().getCurrentAvailableLoad());
criterions.add(lessThanPoolAvailbleLoad);
Criterion lessThanMaxFailTimes = Restrictions.lt("failTimes",
Main.MAX_FAIL_TIMES);
criterions.add(lessThanMaxFailTimes);
Criterion intervalGTMin_Interval = Restrictions.lt("lastRunningTime",
new Date(System.currentTimeMillis()
- Main.MIN_EXECUTE_INTERVAL_IN_SECONDS * 1000));
criterions.add(intervalGTMin_Interval);
List<TestPlan> testPlans = this.getTestPlanRepository()
.loadTestPlansBy(criterions, Order.desc("createDateTime"));
return testPlans.size() > 0 ? testPlans.get(0) : null;
try {
List<Criterion> criterions = new ArrayList<Criterion>();
Criterion notComplete = Restrictions.not(Restrictions.eq(
"currentStatus", TestPlanStatus.Complete.name()));
criterions.add(notComplete);
Criterion notInRunning = Restrictions.not(Restrictions.eq(
"currentStatus", TestPlanStatus.InRunning.name()));
criterions.add(notInRunning);
Criterion lessThanPoolAvailbleLoad = Restrictions.lt(
"requiredLoad", this.getHaPool().getCurrentAvailableLoad());
criterions.add(lessThanPoolAvailbleLoad);
Criterion lessThanMaxFailTimes = Restrictions.lt("failTimes",
Main.MAX_FAIL_TIMES);
criterions.add(lessThanMaxFailTimes);
Criterion intervalGTMin_Interval = Restrictions.lt(
"lastRunningTime", new Date(System.currentTimeMillis()
- Main.MIN_EXECUTE_INTERVAL_IN_SECONDS * 1000));
criterions.add(intervalGTMin_Interval);
List<TestPlan> testPlans = this.getTestPlanRepository()
.loadTestPlansBy(criterions, Order.desc("createDateTime"));
return testPlans.size() > 0 ? testPlans.get(0) : null;
} catch (Exception e) {
logger.error(e, e);
return null;
}
}
}