Fix: remove unused checkpoints from memory (#258)

This commit is contained in:
Luis Uguina
2020-06-16 22:03:17 +10:00
committed by GitHub
parent fe69d6faa2
commit 231c1ee448

View File

@@ -242,6 +242,7 @@ import lombok.Data;
catch (InterruptedException e1) { catch (InterruptedException e1) {
return -3; return -3;
} }
this.log.removeCheckPoint(step);
continue; // go back to ask job continue; // go back to ask job
} }
catch (FermeExceptionServerOverloaded e) { catch (FermeExceptionServerOverloaded e) {
@@ -255,6 +256,7 @@ import lombok.Data;
catch (InterruptedException e1) { catch (InterruptedException e1) {
return -3; return -3;
} }
this.log.removeCheckPoint(step);
continue; // go back to ask job continue; // go back to ask job
} }
catch (FermeExceptionServerInMaintenance e) { catch (FermeExceptionServerInMaintenance e) {
@@ -268,6 +270,7 @@ import lombok.Data;
catch (InterruptedException e1) { catch (InterruptedException e1) {
return -3; return -3;
} }
this.log.removeCheckPoint(step);
continue; // go back to ask job continue; // go back to ask job
} }
catch (FermeExceptionBadResponseFromServer e) { catch (FermeExceptionBadResponseFromServer e) {
@@ -280,6 +283,7 @@ import lombok.Data;
catch (InterruptedException e1) { catch (InterruptedException e1) {
return -3; return -3;
} }
this.log.removeCheckPoint(step);
continue; // go back to ask job continue; // go back to ask job
} }
catch (FermeException e) { catch (FermeException e) {
@@ -289,6 +293,7 @@ import lombok.Data;
e.printStackTrace(pw); e.printStackTrace(pw);
this.log.debug("Client::run exception " + e + " stacktrace: " + sw.toString()); this.log.debug("Client::run exception " + e + " stacktrace: " + sw.toString());
this.sendError(step); this.sendError(step);
this.log.removeCheckPoint(step);
continue; continue;
} }
@@ -309,6 +314,7 @@ import lombok.Data;
} }
time_slept += 250; time_slept += 250;
} }
this.log.removeCheckPoint(step);
continue; // go back to ask job continue; // go back to ask job
} }