Do not cancel monitoring if unable to fetch status from chronos control

Author: vogti

src/main/java/ch/unibas/dmi/dbis/chronos/agent/AbstractChronosAgent.java

@@ -45,6 +45,7 @@ of this software and associated documentation files (the "Software"), to deal
 import java.util.TimerTask;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
 import lombok.extern.slf4j.Slf4j;
 import net.lingala.zip4j.ZipFile;
 import net.lingala.zip4j.model.ZipParameters;
@@ -678,6 +679,8 @@ private class AbortedMonitorTask extends TimerTask {
 
             private final ChronosJob observable;
 
+            private final AtomicInteger getStatusErrorCounter = new AtomicInteger( 0 );
+
 
             /**
              *
@@ -710,9 +713,13 @@ public void run() {
                         // Quietly cancelObservation and de-register this observable since it is already finished
                         cancelAndRemoveObservable();
                     }
+                    getStatusErrorCounter.set( 0 );
                 } catch ( NoSuchElementException | ChronosException | IOException ex ) {
-                    log.warn( "getStatus for \"" + this.observable + "\" failed. Canceling monitoring!", ex );
-                    cancelAndRemoveObservable();
+                    getStatusErrorCounter.incrementAndGet();
+                    if ( getStatusErrorCounter.get() % 10 == 0 ) {
+                        log.warn( "Unable to get status of \"" + this.observable + "\" since quite a while.", ex );
+                    }
+                    //cancelAndRemoveObservable();
                 } catch ( InterruptedException ex ) {
                     log.warn( "We have been interrupted!", ex );
                     cancelAndRemoveObservable();

src/main/java/ch/unibas/dmi/dbis/chronos/agent/ChronosHttpClient.java

@@ -567,7 +567,6 @@ private boolean notifyChronos( final ChronosJob job, final Properties uploadConf
         Exception lastException;
 
         do {
-
             try {
                 // NOTICE: intentional return!
                 return this.doNotifyChronos( job, uploadConfiguration, parameters );
@@ -579,7 +578,6 @@ private boolean notifyChronos( final ChronosJob job, final Properties uploadConf
             if ( norifyChronosAttempt < maxAttempts ) {
                 Thread.sleep( failedAttemptSleepTimeMillis );
             }
-
         } while ( norifyChronosAttempt++ < maxAttempts );
 
         throw new IOException( "The maximum number of attempts reached. See above WARNINGs for details. The last exception was: ", lastException );