From 0e3b51affcd0f515a2fbdd3e543a33052079ba3f Mon Sep 17 00:00:00 2001 From: Sara Bertocco <bertocco@oats.inaf.it> Date: Thu, 21 Jul 2016 14:47:51 +0200 Subject: [PATCH] New working version after Victoria trip - new version --- .../implementation/TransferJobManager.java | 21 ++++++++++++++----- 1 file changed, 16 insertions(+), 5 deletions(-) diff --git a/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java b/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java index beb07dc..eef00a5 100644 --- a/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java +++ b/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java @@ -5,6 +5,7 @@ */ 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.SimpleJobManager; import ca.nrc.cadc.uws.server.ThreadPoolExecutor; @@ -16,15 +17,17 @@ import ca.nrc.cadc.vos.server.transfers.TransferRunner; */ 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() { 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(); - //this.config = jobPersist.getJobSchema(); + this.config = jobPersist.getJobSchema(); // exec jobs in in new thread using our custom TransferRunner JobExecutor jobExec = new ThreadPoolExecutor(jobPersist, TransferRunner.class, 6); @@ -35,4 +38,12 @@ public class TransferJobManager extends SimpleJobManager { super.setMaxDestruction(MAX_DESTRUCTION); super.setMaxQuote(MAX_QUOTE); } + + public JobSchema getConfig() { + + return config; + + } + } + -- GitLab