git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorSweidan Omar <TFS\sweidan.omar>
Tue, 14 Dec 2021 09:46:48 +0000 (09:46 +0000)
committerSweidan Omar <TFS\sweidan.omar>
Tue, 14 Dec 2021 09:46:48 +0000 (09:46 +0000)
server/-product/production/LOCAL/jobs/steps/CalculateMD5Step.java
server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java

index ef72b09a70b37867607e2cbabd79a7926315f1ca..9db442c78dd75e35b3016e92c9c1012e1b8149cd 100644 (file)
@@ -17,13 +17,11 @@ public class CalculateMD5Step extends JobStep {
        @StepEntry\r
        public Object[] execute(String fileName) throws Exception {\r
                logger.info(getMarker(), "Executing");\r
-//             Message msg = new ParameterizedMessage("");\r
-//             logger.info(new MediaCubeMarker("vasary@elgekko.net,vasary@gmail.com", "MediaCube rendszerüzenet"), msg);\r
 \r
                MessageDigest messageDigest = MessageDigest.getInstance("MD5");\r
                InputStream is = Files.newInputStream(Paths.get(fileName));\r
                DigestInputStream dis = new DigestInputStream(is, messageDigest);\r
-               byte[] digest = new byte[1024];\r
+               byte[] digest = new byte[32768]; //32k buffer\r
 \r
                while ((dis.read(digest)) != -1) {\r
                        messageDigest.update(digest);\r
index ef72b09a70b37867607e2cbabd79a7926315f1ca..7f0aa908981dd5af70b13192d7e5bda1acc38b32 100644 (file)
@@ -17,13 +17,11 @@ public class CalculateMD5Step extends JobStep {
        @StepEntry\r
        public Object[] execute(String fileName) throws Exception {\r
                logger.info(getMarker(), "Executing");\r
-//             Message msg = new ParameterizedMessage("");\r
-//             logger.info(new MediaCubeMarker("vasary@elgekko.net,vasary@gmail.com", "MediaCube rendszerüzenet"), msg);\r
 \r
                MessageDigest messageDigest = MessageDigest.getInstance("MD5");\r
                InputStream is = Files.newInputStream(Paths.get(fileName));\r
                DigestInputStream dis = new DigestInputStream(is, messageDigest);\r
-               byte[] digest = new byte[1024];\r
+               byte[] digest = new byte[32768]; // 32k buffer\r
 \r
                while ((dis.read(digest)) != -1) {\r
                        messageDigest.update(digest);\r