[server] Add support for CoW sessions

1 files changed, 3 insertions, 14 deletions

diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/IncomingDataTransfer.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/IncomingDataTransfer.java
index 2b1e3d18..61a2cfc4 100644
--- a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/IncomingDataTransfer.java
+++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/IncomingDataTransfer.java
@@ -2,7 +2,6 @@ package org.openslx.bwlp.sat.fileserv;
 
 import java.io.File;
 import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -47,8 +46,6 @@ public class IncomingDataTransfer extends IncomingTransferBase {
 
 	private static final Logger LOGGER = LogManager.getLogger(IncomingDataTransfer.class);
 
-	private static final long MIN_FREE_SPACE_BYTES = FileChunk.CHUNK_SIZE * (2 + Constants.MAX_UPLOADS);
-
 	/**
 	 * User owning this uploaded file.
 	 */
@@ -305,20 +302,12 @@ public class IncomingDataTransfer extends IncomingTransferBase {
 			return false;
 		}
 		// Dump CRC32 list
-		byte[] dnbd3Crc32List = null;
 		try {
-			dnbd3Crc32List = getChunks().getDnbd3Crc32List();
+			String crcfile = destination.getAbsolutePath() + ".crc";
+			getChunks().writeCrc32List(crcfile);
 		} catch (Exception e) {
 			LOGGER.warn("Could not get CRC32 list for upload of " + image.getImageName(), e);
 		}
-		if (dnbd3Crc32List != null) {
-			String crcfile = destination.getAbsolutePath() + ".crc";
-			try (FileOutputStream fos = new FileOutputStream(crcfile)) {
-				fos.write(dnbd3Crc32List);
-			} catch (Exception e) {
-				LOGGER.warn("Could not write CRC32 list for DNBD3 at " + crcfile, e);
-			}
-		}
 		return true;
 	}
 
@@ -368,7 +357,7 @@ public class IncomingDataTransfer extends IncomingTransferBase {
 
 	@Override
 	protected boolean hasEnoughFreeSpace() {
-		return FileSystem.getAvailableStorageBytes() > MIN_FREE_SPACE_BYTES;
+		return FileSystem.getAvailableStorageBytes() > FileServer.MIN_FREE_SPACE_BYTES;
 	}
 
 	@Override