Raincloud/sheepit-shadow-nabber
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'feature/exp_backoff' into 'master'

Browse Source 
Add exponential backoff for SendFile failures

See merge request sheepitrenderfarm/client!139
This commit is contained in:
harlekin
2022-05-06 11:45:08 +00:00
parent ec04f9ccfc 46de81d377
commit 5068c96405
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/sheepit/client/Client.java
View File

@@ -1049,19 +1049,21 @@ import okhttp3.HttpUrl;
this.isValidatingJob = true; this.isValidatingJob = true;
int max_try = 3; int max_try = 3;
int timeToSleep = 22000;
ServerCode ret = ServerCode.UNKNOWN; ServerCode ret = ServerCode.UNKNOWN;
Type confirmJobReturnCode = Error.Type.OK; Type confirmJobReturnCode = Error.Type.OK;
retryLoop: retryLoop:
for (int nb_try = 0; nb_try < max_try; nb_try++) { for (int nb_try = 0; nb_try < max_try; nb_try++) {
if (nb_try >= 1) { if (nb_try >= 1) {
// sleep before retrying // sleep before retrying
this.log.debug(checkpoint, "Sleep for 32s before trying to re-upload the frame"); this.log.debug(checkpoint, "Sleep for " + timeToSleep / 1000 + "s before trying to re-upload the frame");
try { try {
Thread.sleep(32000); Thread.sleep(timeToSleep);
} }
catch (InterruptedException e) { catch (InterruptedException e) {
confirmJobReturnCode = Error.Type.UNKNOWN; confirmJobReturnCode = Error.Type.UNKNOWN;
} }
timeToSleep *= 2; // exponential backoff
} }
ret = this.server.HTTPSendFile(url_real, ajob.getOutputImagePath(), checkpoint, this.gui); ret = this.server.HTTPSendFile(url_real, ajob.getOutputImagePath(), checkpoint, this.gui);