From: Sweidan Omar Date: Tue, 14 Dec 2021 09:46:48 +0000 (+0000) Subject: git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube... X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=6619cf756605a0591270b0815344d45542be561f;p=mediacube.git git-tfs-id: [tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32578 --- diff --git a/server/-product/production/LOCAL/jobs/steps/CalculateMD5Step.java b/server/-product/production/LOCAL/jobs/steps/CalculateMD5Step.java index ef72b09a..9db442c7 100644 --- a/server/-product/production/LOCAL/jobs/steps/CalculateMD5Step.java +++ b/server/-product/production/LOCAL/jobs/steps/CalculateMD5Step.java @@ -17,13 +17,11 @@ public class CalculateMD5Step extends JobStep { @StepEntry public Object[] execute(String fileName) throws Exception { logger.info(getMarker(), "Executing"); -// Message msg = new ParameterizedMessage(""); -// logger.info(new MediaCubeMarker("vasary@elgekko.net,vasary@gmail.com", "MediaCube rendszerüzenet"), msg); MessageDigest messageDigest = MessageDigest.getInstance("MD5"); InputStream is = Files.newInputStream(Paths.get(fileName)); DigestInputStream dis = new DigestInputStream(is, messageDigest); - byte[] digest = new byte[1024]; + byte[] digest = new byte[32768]; //32k buffer while ((dis.read(digest)) != -1) { messageDigest.update(digest); diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java index ef72b09a..7f0aa908 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java @@ -17,13 +17,11 @@ public class CalculateMD5Step extends JobStep { @StepEntry public Object[] execute(String fileName) throws Exception { logger.info(getMarker(), "Executing"); -// Message msg = new ParameterizedMessage(""); -// logger.info(new MediaCubeMarker("vasary@elgekko.net,vasary@gmail.com", "MediaCube rendszerüzenet"), msg); MessageDigest messageDigest = MessageDigest.getInstance("MD5"); InputStream is = Files.newInputStream(Paths.get(fileName)); DigestInputStream dis = new DigestInputStream(is, messageDigest); - byte[] digest = new byte[1024]; + byte[] digest = new byte[32768]; // 32k buffer while ((dis.read(digest)) != -1) { messageDigest.update(digest);