Fix multi-instance mode (hibernate)

Some jobs were never ending or were being run twice because the
job status was put back to RUNNING when the client was getting the
status.

core/build.gradle

@@ -335,4 +335,5 @@ task createDocker(type: Docker, dependsOn: 'unzipWar') {
     setEnvironment('SPRING_LOG_LEVEL', 'WARN')
     setEnvironment('JASPER_LOG_LEVEL', 'WARN')
     setEnvironment('APACHE_LOG_LEVEL', 'WARN')
+    setEnvironment('SQL_LOG_LEVEL', 'WARN')
 }

core/logback-custom.xml

@@ -8,4 +8,5 @@
     <logger name="com.codahale.metrics" level="INFO" />
     <logger name="net.sf.jasperreports" level="${JASPER_LOG_LEVEL}" />
     <logger name="org.apache" level="${APACHE_LOG_LEVEL}" />
+    <logger name="org.hibernate" level="${SQL_LOG_LEVEL}" />
 </included>

core/src/main/java/org/mapfish/print/servlet/job/impl/ThreadPoolJobManager.java

@@ -363,10 +363,8 @@ public final void cancel(final String referenceId) throws NoSuchReferenceExcepti
 
     @Override
     public final PrintJobStatus getStatus(final String referenceId) throws NoSuchReferenceException {
-        PrintJobStatus jobStatus = null;
-
         // check if the reference id is valid
-        jobStatus = this.jobQueue.get(referenceId, true);
+        final PrintJobStatus jobStatus = this.jobQueue.get(referenceId, true);
         jobStatus.getEntry().assertAccess();
 
         if (jobStatus.getStatus() == PrintJobStatus.Status.WAITING) {

core/src/main/java/org/mapfish/print/servlet/job/impl/hibernate/HibernateJobQueue.java

@@ -28,7 +28,6 @@
  */
 @Transactional
 public class HibernateJobQueue implements JobQueue {
-
     private static final int DEFAULT_TIME_TO_KEEP_AFTER_ACCESS = 30; /* minutes */
 
     private static final long DEFAULT_CLEAN_UP_INTERVAL = 300; /* seconds */
@@ -96,8 +95,7 @@ public final PrintJobStatus get(final String referenceId, final boolean external
         }
         record.setStatusTime(now);
         if (!record.isDone() && external) {
-            record.setLastCheckTime(System.currentTimeMillis());
-            this.dao.save(record);
+            this.dao.updateLastCheckTime(referenceId, System.currentTimeMillis());
         }
         return record;
     }
@@ -222,5 +220,4 @@ protected void doInTransactionWithoutResult(final TransactionStatus status) {
             }
         });
     }
-
 }

core/src/main/java/org/mapfish/print/servlet/job/impl/hibernate/PrintJobDao.java

@@ -47,6 +47,8 @@ public final Session getSession() {
      */
     public final void save(final PrintJobStatusExtImpl entry) {  
         getSession().merge(entry);
+        getSession().flush();
+        getSession().evict(entry);
     }
 
     /**
@@ -57,7 +59,9 @@ public final void save(final PrintJobStatusExtImpl entry) {
      * @return
      */
     public final PrintJobStatusExtImpl get(final String id) {
-        return get(id, false);
+        final PrintJobStatusExtImpl result = get(id, false);
+        getSession().evict(result);
+        return result;
     }
 
     /**
@@ -72,8 +76,10 @@ public final PrintJobStatusExtImpl get(final String id, final boolean lock) {
         Criteria c = getSession().createCriteria(PrintJobStatusExtImpl.class);
         c.add(Restrictions.idEq(id));
         if (lock) { //LOCK means SELECT FOR UPDATE which prevents these records to be pulled by different instances
-           c.setLockMode("pj", LockMode.PESSIMISTIC_READ);
-           c.setFetchMode("result", FetchMode.SELECT);
+            c.setLockMode("pj", LockMode.PESSIMISTIC_READ);
+            c.setFetchMode("result", FetchMode.SELECT);
+        } else {
+            c.setReadOnly(true);  // make sure the object is not updated if there is no lock
         }
         return (PrintJobStatusExtImpl) c.uniqueResult();
     }
@@ -152,6 +158,19 @@ public final void cancelOld(final long starttimeThreshold, final long checkTimeT
         query.executeUpdate();
     }
 
+    /**
+     * Update the lastCheckTime of the given record.
+     * @param id the id
+     * @param lastCheckTime the new value
+     */
+    public final void updateLastCheckTime(final String id, final long lastCheckTime) {
+        Query query = getSession().createQuery("update PrintJobStatusExtImpl pj " + "set lastCheckTime=:lastCheckTime "
+                + "where pj.referenceId = :id");
+        query.setParameter("id", id);
+        query.setParameter("lastCheckTime", lastCheckTime);
+        query.executeUpdate();
+    }
+
     /**
      * Delete old jobs.
      * 
@@ -195,5 +214,4 @@ public final PrintJobResultExtImpl getResult(final URI reportURI) {
         c.add(Restrictions.idEq(reportURI.toString()));
         return (PrintJobResultExtImpl) c.uniqueResult();
     }
-
 }

core/src/main/resources/logback.xml

@@ -14,6 +14,7 @@
     <logger name="com.codahale.metrics.JmxReporter" level="INFO" />
     <logger name="org.springframework" level="WARN" />
     <logger name="org.apache" level="WARN" />
+    <logger name="org.hibernate" level="WARN" />
 
     <root level="INFO">
         <appender-ref ref="standardOut" />