move corruption into multipart

Author: bcully

modules/repository-s3/src/internalClusterTest/java/org/elasticsearch/repositories/s3/S3RepositoryThirdPartyTests.java

@@ -110,7 +110,7 @@ protected void createRepository(String repoName) {
         Settings.Builder settings = Settings.builder()
             .put("bucket", System.getProperty("test.s3.bucket"))
             .put("base_path", System.getProperty("test.s3.base", "testpath"))
-            .put("buffer_size", S3Repository.MIN_PART_SIZE_USING_MULTIPART);
+            .put("buffer_size", S3Repository.MIN_PART_SIZE_USING_MULTIPART.getBytes());
         final String endpoint = USE_FIXTURE ? minio.getAddress() : System.getProperty("test.s3.endpoint");
         if (endpoint != null) {
             settings.put("endpoint", endpoint);

modules/repository-s3/src/main/java/org/elasticsearch/repositories/s3/S3BlobContainer.java

@@ -547,6 +547,8 @@ void executeMultipartUpload(
             long bytesCount = 0;
             for (int i = 1; i <= nbParts; i++) {
                 final boolean lastPart = i == nbParts;
+                // XXX
+                md5s[i][0] = (byte) ~md5s[i][0];
                 final UploadPartRequest uploadRequest = createPartUploadRequest(
                     purpose,
                     input,
@@ -600,8 +602,6 @@ private byte[] md5DigestOfInputStream(final InputStream inputStream, long remain
             final MessageDigest md5 = MessageDigest.getInstance("MD5");
             // update in chunks to bound memory usage while amortizing read cost
             byte[] buffer = new byte[65536];
-            // XXX force fail
-            md5.update((byte) 'x');
             int bytesRead;
             do {
                 final int toRead = (int) Math.min(remaining, buffer.length);