git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/trunk/vre-management/VREModeler@8603 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
parent
7491ee3434
commit
77a14668ae
|
@ -94,11 +94,9 @@ public class DeployVRE extends Thread{
|
||||||
try {
|
try {
|
||||||
DBInterface.ExecuteUpdate("UPDATE VRE SET STATUS='"+ModelerService.FAILED+"' WHERE VRE.id='"+this.resourceId+"';");
|
DBInterface.ExecuteUpdate("UPDATE VRE SET STATUS='"+ModelerService.FAILED+"' WHERE VRE.id='"+this.resourceId+"';");
|
||||||
} catch (Exception e1) {
|
} catch (Exception e1) {
|
||||||
logger.error("impossible to update the VRE Status");
|
logger.error("impossible to update the VRE Status"+e1);
|
||||||
e1.printStackTrace();
|
|
||||||
}
|
}
|
||||||
logger.error("Error deploying the VRE with id "+this.resourceId+" "+e);
|
logger.error("Error deploying the VRE with id "+this.resourceId+" "+e);
|
||||||
e.printStackTrace();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -147,12 +145,10 @@ public class DeployVRE extends Thread{
|
||||||
report=mbportType.getReport(reportId);
|
report=mbportType.getReport(reportId);
|
||||||
attempt++;
|
attempt++;
|
||||||
getResource().setReportFirstStep(report);
|
getResource().setReportFirstStep(report);
|
||||||
System.out.println("---step 1------");
|
|
||||||
System.out.println(report);
|
|
||||||
System.out.println("---------");
|
|
||||||
}while (!isDeploymentStatusFinished(report) && attempt<10);
|
}while (!isDeploymentStatusFinished(report) && attempt<10);
|
||||||
}catch(Exception e){e.printStackTrace(); throw e;}
|
}catch(Exception e){e.printStackTrace(); throw e;}
|
||||||
System.out.println( "is something failed in the first step?"+isSomethingFailed(report));
|
logger.trace("report step 1: "+report);
|
||||||
|
logger.info("is something failed in the first step?"+isSomethingFailed(report));
|
||||||
return isSomethingFailed(report);
|
return isSomethingFailed(report);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
@ -189,9 +185,6 @@ public class DeployVRE extends Thread{
|
||||||
List<EndpointReferenceType> eprs = new ArrayList<EndpointReferenceType>();
|
List<EndpointReferenceType> eprs = new ArrayList<EndpointReferenceType>();
|
||||||
for (GCUBERunningInstance instance : client.execute(query, scope))
|
for (GCUBERunningInstance instance : client.execute(query, scope))
|
||||||
eprs.add(instance.getAccessPoint().getEndpoint("gcube/vremanagement/VREManager"));
|
eprs.add(instance.getAccessPoint().getEndpoint("gcube/vremanagement/VREManager"));
|
||||||
System.out.println("EPRs: ");
|
|
||||||
for (EndpointReferenceType epr: eprs)
|
|
||||||
System.out.println(epr);
|
|
||||||
return eprs;
|
return eprs;
|
||||||
}catch(Exception e){e.printStackTrace(); throw e;}
|
}catch(Exception e){e.printStackTrace(); throw e;}
|
||||||
}
|
}
|
||||||
|
@ -304,14 +297,12 @@ public class DeployVRE extends Thread{
|
||||||
do{
|
do{
|
||||||
Thread.currentThread().sleep(20000);
|
Thread.currentThread().sleep(20000);
|
||||||
report=vreManPortType.getReport(reportId);
|
report=vreManPortType.getReport(reportId);
|
||||||
System.out.println("---step 2------");
|
|
||||||
System.out.println(report);
|
|
||||||
System.out.println("---------");
|
|
||||||
attempt++;
|
attempt++;
|
||||||
getResource().setReportSecondStep(report);
|
getResource().setReportSecondStep(report);
|
||||||
|
|
||||||
}while (!isDeploymentStatusFinished(report) && attempt<20);
|
}while (!isDeploymentStatusFinished(report) && attempt<20);
|
||||||
System.out.println( "is something failed in the second step?"+isSomethingFailed(report));
|
logger.info("is something failed in the second step?"+isSomethingFailed(report));
|
||||||
|
logger.trace("report step 2: "+report);
|
||||||
return isSomethingFailed(report);
|
return isSomethingFailed(report);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
|
@ -52,9 +52,6 @@ public abstract class VREManagerServiceHandler<T, P> extends GCUBEServiceHandler
|
||||||
List<EndpointReferenceType> eprs = new ArrayList<EndpointReferenceType>();
|
List<EndpointReferenceType> eprs = new ArrayList<EndpointReferenceType>();
|
||||||
for (GCUBERunningInstance instance : client.execute(query, scope))
|
for (GCUBERunningInstance instance : client.execute(query, scope))
|
||||||
eprs.add(instance.getAccessPoint().getEndpoint("gcube/vremanagement/VREManager"));
|
eprs.add(instance.getAccessPoint().getEndpoint("gcube/vremanagement/VREManager"));
|
||||||
System.out.println("EPRs: ");
|
|
||||||
for (EndpointReferenceType epr: eprs)
|
|
||||||
System.out.println(epr);
|
|
||||||
return eprs;
|
return eprs;
|
||||||
}catch(Exception e){e.printStackTrace(); throw e;}
|
}catch(Exception e){e.printStackTrace(); throw e;}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue