Skip to content
Snippets Groups Projects
Commit 0e3b51af authored by Sara Bertocco's avatar Sara Bertocco
Browse files

New working version after Victoria trip - new version

parent a809df92
No related branches found
No related tags found
No related merge requests found
...@@ -5,6 +5,7 @@ ...@@ -5,6 +5,7 @@
*/ */
package it.inaf.oats.vospacebackend.implementation; package it.inaf.oats.vospacebackend.implementation;
import ca.nrc.cadc.uws.server.JobDAO.JobSchema;
import ca.nrc.cadc.uws.server.JobExecutor; import ca.nrc.cadc.uws.server.JobExecutor;
import ca.nrc.cadc.uws.server.SimpleJobManager; import ca.nrc.cadc.uws.server.SimpleJobManager;
import ca.nrc.cadc.uws.server.ThreadPoolExecutor; import ca.nrc.cadc.uws.server.ThreadPoolExecutor;
...@@ -16,15 +17,17 @@ import ca.nrc.cadc.vos.server.transfers.TransferRunner; ...@@ -16,15 +17,17 @@ import ca.nrc.cadc.vos.server.transfers.TransferRunner;
*/ */
public class TransferJobManager extends SimpleJobManager { public class TransferJobManager extends SimpleJobManager {
private static final Long MAX_EXEC_DURATION = new Long(12*3600L); // 12 hours
private static final Long MAX_DESTRUCTION = new Long(7*24*3600L); // 1 week
private static final Long MAX_QUOTE = new Long(12*3600L); // same as exec
private JobSchema config;
public TransferJobManager() { public TransferJobManager() {
super(); super();
Long MAX_EXEC_DURATION = new Long(600L);;
Long MAX_DESTRUCTION = new Long(1L+MAX_EXEC_DURATION);
Long MAX_QUOTE = new Long(600L);
DatabaseJobPersistenceImpl jobPersist = new DatabaseJobPersistenceImpl(); DatabaseJobPersistenceImpl jobPersist = new DatabaseJobPersistenceImpl();
//this.config = jobPersist.getJobSchema(); this.config = jobPersist.getJobSchema();
// exec jobs in in new thread using our custom TransferRunner // exec jobs in in new thread using our custom TransferRunner
JobExecutor jobExec = new ThreadPoolExecutor(jobPersist, TransferRunner.class, 6); JobExecutor jobExec = new ThreadPoolExecutor(jobPersist, TransferRunner.class, 6);
...@@ -35,4 +38,12 @@ public class TransferJobManager extends SimpleJobManager { ...@@ -35,4 +38,12 @@ public class TransferJobManager extends SimpleJobManager {
super.setMaxDestruction(MAX_DESTRUCTION); super.setMaxDestruction(MAX_DESTRUCTION);
super.setMaxQuote(MAX_QUOTE); super.setMaxQuote(MAX_QUOTE);
} }
public JobSchema getConfig() {
return config;
} }
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment