Thibaut/ffsaf-site
1
0
Fork 0
Code Issues Pull Requests Actions Packages Releases Activity

feat: send record v2

Browse Source
This commit is contained in:
Thibaut Valentin 2024-03-22 20:43:39 +01:00
parent 3c0f1b01d6
commit d5b4820c79
1 changed files with 3 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/fr/titionfire/ffsaf/ws/FileSocket.java
View File

@ -51,19 +51,13 @@ public class FileSocket {
fileRecv.fos = new FileOutputStream(fileRecv.file, false); fileRecv.fos = new FileOutputStream(fileRecv.file, false);
logger.info("Start reception of file: " + fileRecv.file.getAbsolutePath()); logger.info("Start reception of file: " + fileRecv.file.getAbsolutePath());
} else { } else {
// session.close(new CloseReason(CloseReason.CloseCodes.VIOLATED_POLICY, "File not found")); session.close(new CloseReason(CloseReason.CloseCodes.VIOLATED_POLICY, "File not found"));
} }
} catch (IOException e) { } catch (IOException e) {
StringWriter errors = new StringWriter(); StringWriter errors = new StringWriter();
e.printStackTrace(new PrintWriter(errors)); e.printStackTrace(new PrintWriter(errors));
logger.error(errors.toString()); logger.error(errors.toString());
} }
session.getAsyncRemote().sendText("ok", result -> {
if (result.getException() != null) {
System.out.println("Unable to send message: " + result.getException());
}
});
} }
@OnClose @OnClose
@ -137,7 +131,7 @@ public class FileSocket {
if (check_sum != data[0]) { if (check_sum != data[0]) {
fileRecv.session.getAsyncRemote().sendText("Error: Checksum error", result -> { fileRecv.session.getAsyncRemote().sendText("Error: Checksum error", result -> {
if (result.getException() != null) { if (result.getException() != null) {
System.out.println("Unable to send message: " + result.getException()); logger.error("Unable to send message: " + result.getException());
} }
}); });
return; return;
@ -151,15 +145,9 @@ public class FileSocket {
logger.error(errors.toString()); logger.error(errors.toString());
} }
try {
Thread.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
fileRecv.session.getAsyncRemote().sendText("ok", result -> { fileRecv.session.getAsyncRemote().sendText("ok", result -> {
if (result.getException() != null) { if (result.getException() != null) {
System.out.println("Unable to send message: " + result.getException()); logger.error("Unable to send message: " + result.getException());
} }
}); });
} }