summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSimon Rettberg2019-10-08 11:58:00 +0200
committerSimon Rettberg2019-10-08 11:58:00 +0200
commit12b9ee380df3e40f3b6da112065b0664483889b4 (patch)
tree95f8827d54c970cecd71f606a03819643ca4ddf7
parent[client] Don't chop off @org suffix from user name (diff)
downloadtutor-module-12b9ee380df3e40f3b6da112065b0664483889b4.tar.gz
tutor-module-12b9ee380df3e40f3b6da112065b0664483889b4.tar.xz
tutor-module-12b9ee380df3e40f3b6da112065b0664483889b4.zip
[client] Log error message if upload gets rejected
-rw-r--r--dozentenmodul/src/main/java/org/openslx/dozmod/thrift/UploadInitiator.java25
1 files changed, 14 insertions, 11 deletions
diff --git a/dozentenmodul/src/main/java/org/openslx/dozmod/thrift/UploadInitiator.java b/dozentenmodul/src/main/java/org/openslx/dozmod/thrift/UploadInitiator.java
index 34e27d8e..1e4ef05a 100644
--- a/dozentenmodul/src/main/java/org/openslx/dozmod/thrift/UploadInitiator.java
+++ b/dozentenmodul/src/main/java/org/openslx/dozmod/thrift/UploadInitiator.java
@@ -112,22 +112,19 @@ public class UploadInitiator {
Session.getSatelliteToken(), imageBaseId, fileSize, null, // TODO remove deprecated parameter
machineDescription);
} catch (TAuthorizationException e) {
- errorMessage = "Upload vom Server verweigert";
- cancelError();
+ cancelWithErrorMessage("Upload vom Server verweigert");
this.cancel();
return;
} catch (TTransferRejectedException e) {
if (e.message != null && e.message.startsWith("Server busy")) {
initState = UploadInitState.WAITING_FOR_SLOT;
} else {
- errorMessage = "Upload-Anfrage gescheitert!";
- cancelError();
+ cancelWithErrorMessage("Upload-Anfrage gescheitert (" + e.message + ")");
this.cancel();
}
return;
} catch (TException e) {
- errorMessage = "Upload-Anfrage gescheitert!";
- cancelError();
+ cancelWithErrorMessage("Upload-Anfrage gescheitert!");
this.cancel();
return;
}
@@ -169,9 +166,8 @@ public class UploadInitiator {
uploadTask = new UploadTask(Session.getSatelliteAddress(),
transferInformation.getPlainPort(), transferInformation.getToken(), diskFile);
} catch (FileNotFoundException e) {
- errorMessage = "Kann VM nicht hochladen: Datei nicht gefunden\n\n"
- + diskFile.getAbsolutePath();
- cancelError();
+ cancelWithErrorMessage("Kann VM nicht hochladen: Datei nicht gefunden\n\n"
+ + diskFile.getAbsolutePath());
this.cancel();
return;
}
@@ -188,8 +184,7 @@ public class UploadInitiator {
}
if (!uploadTask.isComplete() && uploadTask.getTransferCount() == 0) {
// Init failed
- errorMessage = "Aufbau der Verbindung zum Hochladen fehlgeschlagen";
- cancelError();
+ cancelWithErrorMessage("Aufbau der Verbindung zum Hochladen fehlgeschlagen");
this.cancel();
return;
}
@@ -228,6 +223,14 @@ public class UploadInitiator {
return errorMessage;
}
+ public void cancelWithErrorMessage(String errorMessage) {
+ if (!errorMessage.equals(this.errorMessage)) {
+ LOGGER.warn(errorMessage);
+ }
+ this.errorMessage = errorMessage;
+ cancelError();
+ }
+
public AsyncHashGenerator getHasher() {
return hashGen;
}